@Internal public class PlanBothUnwrappingCoGroupOperator<I1,I2,OUT,K> extends CoGroupOperatorBase<Tuple2<K,I1>,Tuple2<K,I2>,OUT,CoGroupFunction<Tuple2<K,I1>,Tuple2<K,I2>,OUT>>
input1, input2
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
PlanBothUnwrappingCoGroupOperator(CoGroupFunction<I1,I2,OUT> udf,
Keys.SelectorFunctionKeys<I1,K> key1,
Keys.SelectorFunctionKeys<I2,K> key2,
String name,
TypeInformation<OUT> type,
TypeInformation<Tuple2<K,I1>> typeInfoWithKey1,
TypeInformation<Tuple2<K,I2>> typeInfoWithKey2) |
executeOnCollections, getCustomPartitioner, getGroupOrder, getGroupOrderForInputOne, getGroupOrderForInputTwo, isCombinableFirst, isCombinableSecond, setCombinableFirst, setCombinableSecond, setCustomPartitioner, setGroupOrder, setGroupOrderForInputOne, setGroupOrderForInputTwo
accept, addFirstInput, addFirstInputs, addSecondInput, addSecondInputs, clearFirstInput, clearSecondInput, getFirstInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSecondInput, getSemanticProperties, setFirstInput, setFirstInput, setFirstInputs, setSecondInput, setSecondInput, setSecondInputs, setSemanticProperties
asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables
createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString
public PlanBothUnwrappingCoGroupOperator(CoGroupFunction<I1,I2,OUT> udf, Keys.SelectorFunctionKeys<I1,K> key1, Keys.SelectorFunctionKeys<I2,K> key2, String name, TypeInformation<OUT> type, TypeInformation<Tuple2<K,I1>> typeInfoWithKey1, TypeInformation<Tuple2<K,I2>> typeInfoWithKey2)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.