Package org.apache.flink.api.java.operators.translation

Class PlanUnwrappingReduceOperator<T,K>

java.lang.Object

org.apache.flink.api.common.operators.Operator<OUT>

org.apache.flink.api.common.operators.AbstractUdfOperator<OUT,FT>

org.apache.flink.api.common.operators.SingleInputOperator<T,T,FT>

org.apache.flink.api.common.operators.base.ReduceOperatorBase<org.apache.flink.api.java.tuple.Tuple2<K,T>,org.apache.flink.api.common.functions.ReduceFunction<org.apache.flink.api.java.tuple.Tuple2<K,T>>>

org.apache.flink.api.java.operators.translation.PlanUnwrappingReduceOperator<T,K>

All Implemented Interfaces:

org.apache.flink.util.Visitable<org.apache.flink.api.common.operators.Operator<?>>

@Internal
public class PlanUnwrappingReduceOperator<T,K>
extends org.apache.flink.api.common.operators.base.ReduceOperatorBase<org.apache.flink.api.java.tuple.Tuple2<K,T>,org.apache.flink.api.common.functions.ReduceFunction<org.apache.flink.api.java.tuple.Tuple2<K,T>>>

A reduce operator that takes 2-tuples (key-value pairs), and applies the reduce operation only on the unwrapped values.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.operators.base.ReduceOperatorBase

org.apache.flink.api.common.operators.base.ReduceOperatorBase.CombineHint

Field Summary

Fields inherited from class org.apache.flink.api.common.operators.SingleInputOperator

input

Fields inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

broadcastInputs, userFunction

Fields inherited from class org.apache.flink.api.common.operators.Operator

compilerHints, name, operatorInfo, parameters

Constructor Summary

Constructors

Constructor	Description
PlanUnwrappingReduceOperator(org.apache.flink.api.common.functions.ReduceFunction<T> udf, org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key, String name, org.apache.flink.api.common.typeinfo.TypeInformation<T> type, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.java.tuple.Tuple2<K,T>> typeInfoWithKey)

Method Summary

Methods inherited from class org.apache.flink.api.common.operators.base.ReduceOperatorBase

executeOnCollections, getCombineHint, getCustomPartitioner, setCombineHint, setCustomPartitioner

Methods inherited from class org.apache.flink.api.common.operators.SingleInputOperator

accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSemanticProperties, setInput, setInput, setInputs, setSemanticProperties

Methods inherited from class org.apache.flink.api.common.operators.AbstractUdfOperator

asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables

Methods inherited from class org.apache.flink.api.common.operators.Operator

createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PlanUnwrappingReduceOperator

public PlanUnwrappingReduceOperator(org.apache.flink.api.common.functions.ReduceFunction<T> udf,
                                    org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key,
                                    String name,
                                    org.apache.flink.api.common.typeinfo.TypeInformation<T> type,
                                    org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.java.tuple.Tuple2<K,T>> typeInfoWithKey)