Thanks! Looks like that worked!
Fwiw, the error message is very confusing. Is there any way this can be
improved?
Thanks :)
On Sun, Oct 25, 2020 at 6:42 PM Xingbo Huang wrote:
> Hi,
> I think you can directly declare `def accumulate(acc: MembershipsIDsAcc,
> value1: Long, value2: Boolean)`
>
>
Hi,
I think you can directly declare `def accumulate(acc: MembershipsIDsAcc,
value1: Long, value2: Boolean)`
Best,
Xingbo
Rex Fenley 于2020年10月26日周一 上午9:28写道：
> If I switch accumulate to the following:
> def accumulate(acc: MembershipsIDsAcc, value:
> org.apache.flink.api.java.tuple.Tuple2[java.
If I switch accumulate to the following:
def accumulate(acc: MembershipsIDsAcc, value:
org.apache.flink.api.java.tuple.Tuple2[java.lang.Long, java.lang.Boolean]):
Unit = {...}
I instead receive:
Tuple needs to be parameterized by using generics.
org.apache.flink.api.java.typeutils.TypeExtractor.
Imports:
import java.util.Date
import org.apache.flink.api.scala._
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.api.java.typeutils.RowTypeInfo
import org.apache.flink.table.api.{
DataTypes,
EnvironmentSettings,
TableEnvironment,
TableSchema
}
import org.apach
