Unused TypeInformation parameter in DeltaIteration constructor
Posted by Vasiliki Kalavri on
URL: http://deprecated-apache-flink-mailing-list-archive.368.s1.nabble.com/Unused-TypeInformation-parameter-in-DeltaIteration-constructor-tp351.html
Hey,
the DeltaIteration constructor has a TypeInformation parameter that is not
used:
DeltaIteration(ExecutionEnvironment context, TypeInformation<ST> type,
DataSet<ST> solutionSet, DataSet<WT> workset, Keys<ST> keys, int
maxIterations) {
initialSolutionSet = solutionSet;
initialWorkset = workset;
solutionSetPlaceholder = new SolutionSetPlaceHolder<ST>(context,
solutionSet.getType(), this);
worksetPlaceholder = new WorksetPlaceHolder<WT>(context, workset.getType());
this.keys = keys;
this.maxIterations = maxIterations;
}
The solution set and workset types are set separately, so I guess this is a
leftover parameter because of some copy-paste? Or was it meant to be used
somewhere else?
Cheers,
V.