Hi,
I think the problem is that the case class has generic parameters. You can
try making TypeInformation for those parameters implicitly available at the
call site, i.e:
implicit val typeT = createTypeInformation[T] // where you insert the
specific type for T and do the same for the other generic
I've tested it, but unfortunately it does not solve the problem.
The error message remains the same.
Am 04.06.2016 um 19:38 schrieb Simone Robutti:
I'm not sure if this is the solution and I don't have the possibility
to try right now, but you should move the case class "State"
definition outsid
I'm not sure if this is the solution and I don't have the possibility to
try right now, but you should move the case class "State" definition
outside the abstract class.
2016-06-04 17:34 GMT+02:00 Dan Drewes :
>
> Hi,
>
> compiling the code:
>
> def minimize(f: DF, init: T): T = {
>
> //create
Hi,
compiling the code:
def minimize(f:DF, init:T):T = {
//create execution environment val env =
ExecutionEnvironment.getExecutionEnvironment
valinitialstate =initialState(f, init)
val iterativestate= env.fromElements(initialstate).iterate(1) {
iterationInput: DataSet[State] =>
