SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet,
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer) |
SolutionSetFastUpdateOutputCollector(CompactingHashTable<T> solutionSet,
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
org.apache.flink.util.Collector<T> delegate) |
SolutionSetUpdateOutputCollector(CompactingHashTable<T> solutionSet,
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer) |
SolutionSetUpdateOutputCollector(CompactingHashTable<T> solutionSet,
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
org.apache.flink.util.Collector<T> delegate) |