Uses of Class
org.apache.flink.api.java.operators.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate
-
Packages that use CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate Package Description org.apache.flink.api.java.operators -
-
Uses of CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate in org.apache.flink.api.java.operators
Methods in org.apache.flink.api.java.operators that return CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicate Modifier and Type Method Description CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicateCoGroupOperator.CoGroupOperatorSets. where(int... fields)Continues a CoGroup transformation.CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicateCoGroupOperator.CoGroupOperatorSets. where(String... fields)Continues a CoGroup transformation.<K> CoGroupOperator.CoGroupOperatorSets.CoGroupOperatorSetsPredicateCoGroupOperator.CoGroupOperatorSets. where(org.apache.flink.api.java.functions.KeySelector<I1,K> keyExtractor)Continues a CoGroup transformation and defines aKeySelectorfunction for the first co-groupedDataSet.
-