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

Class CoGroupRawOperator<I1,I2,OUT>

java.lang.Object

org.apache.flink.api.java.DataSet<OUT>

org.apache.flink.api.java.operators.Operator<OUT,O>

org.apache.flink.api.java.operators.TwoInputOperator<IN1,IN2,OUT,O>

org.apache.flink.api.java.operators.TwoInputUdfOperator<I1,I2,OUT,CoGroupRawOperator<I1,I2,OUT>>

org.apache.flink.api.java.operators.CoGroupRawOperator<I1,I2,OUT>

Type Parameters:

I1 - The type of the first input DataSet of the CoGroup transformation.

I2 - The type of the second input DataSet of the CoGroup transformation.

OUT - The type of the result of the CoGroup transformation.

All Implemented Interfaces:

UdfOperator<CoGroupRawOperator<I1,I2,OUT>>

@Internal
public class CoGroupRawOperator<I1,I2,OUT>
extends TwoInputUdfOperator<I1,I2,OUT,CoGroupRawOperator<I1,I2,OUT>>

A DataSet that is the result of a CoGroup transformation.

See Also:

DataSet

Field Summary

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

minResources, name, parallelism, preferredResources

Fields inherited from class org.apache.flink.api.java.DataSet

context

Constructor Summary

Constructors

Constructor	Description
CoGroupRawOperator(DataSet<I1> input1, DataSet<I2> input2, org.apache.flink.api.common.operators.Keys<I1> keys1, org.apache.flink.api.common.operators.Keys<I2> keys2, org.apache.flink.api.common.functions.CoGroupFunction<I1,I2,OUT> function, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> returnType, String defaultName)

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.api.common.functions.Function	getFunction()
protected org.apache.flink.api.common.operators.Keys<I1>	getKeys1()
protected org.apache.flink.api.common.operators.Keys<I2>	getKeys2()
protected org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,OUT,?>	translateToDataFlow(org.apache.flink.api.common.operators.Operator<I1> input1, org.apache.flink.api.common.operators.Operator<I2> input2)	Translates this java API operator into a common API operator with two inputs.

Methods inherited from class org.apache.flink.api.java.operators.TwoInputUdfOperator

extractSemanticAnnotationsFromUdf, getAnalyzedUdfSemanticsFlag, getBroadcastSets, getParameters, getSemanticProperties, returns, returns, returns, setAnalyzedUdfSemanticsFlag, setSemanticProperties, udfWithForwardedFieldsFirstAnnotation, udfWithForwardedFieldsSecondAnnotation, withBroadcastSet, withForwardedFieldsFirst, withForwardedFieldsSecond, withParameters

Methods inherited from class org.apache.flink.api.java.operators.TwoInputOperator

getInput1, getInput1Type, getInput2, getInput2Type

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

getMinResources, getName, getParallelism, getPreferredResources, getResultType, name, setParallelism

Methods inherited from class org.apache.flink.api.java.DataSet

aggregate, checkSameExecutionContext, clean, coGroup, collect, combineGroup, count, cross, crossWithHuge, crossWithTiny, distinct, distinct, distinct, distinct, fillInType, filter, first, flatMap, fullOuterJoin, fullOuterJoin, getExecutionEnvironment, getType, groupBy, groupBy, groupBy, iterate, iterateDelta, join, join, joinWithHuge, joinWithTiny, leftOuterJoin, leftOuterJoin, map, mapPartition, max, maxBy, min, minBy, output, partitionByHash, partitionByHash, partitionByHash, partitionByRange, partitionByRange, partitionByRange, partitionCustom, partitionCustom, partitionCustom, print, print, printOnTaskManager, printToErr, printToErr, project, rebalance, reduce, reduceGroup, rightOuterJoin, rightOuterJoin, runOperation, sortPartition, sortPartition, sortPartition, sum, union, write, write, writeAsCsv, writeAsCsv, writeAsCsv, writeAsCsv, writeAsFormattedText, writeAsFormattedText, writeAsText, writeAsText

Methods inherited from class java.lang.Object

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

Constructor Detail

CoGroupRawOperator

public CoGroupRawOperator(DataSet<I1> input1,
                          DataSet<I2> input2,
                          org.apache.flink.api.common.operators.Keys<I1> keys1,
                          org.apache.flink.api.common.operators.Keys<I2> keys2,
                          org.apache.flink.api.common.functions.CoGroupFunction<I1,I2,OUT> function,
                          org.apache.flink.api.common.typeinfo.TypeInformation<OUT> returnType,
                          String defaultName)

Method Detail

getKeys1

protected org.apache.flink.api.common.operators.Keys<I1> getKeys1()

getKeys2

protected org.apache.flink.api.common.operators.Keys<I2> getKeys2()

translateToDataFlow

protected org.apache.flink.api.common.operators.base.CoGroupRawOperatorBase<?,?,OUT,?> translateToDataFlow(org.apache.flink.api.common.operators.Operator<I1> input1,
                                                                                                                             org.apache.flink.api.common.operators.Operator<I2> input2)

Description copied from class: TwoInputOperator

Translates this java API operator into a common API operator with two inputs.

Specified by:

translateToDataFlow in class TwoInputOperator<I1,I2,OUT,CoGroupRawOperator<I1,I2,OUT>>

Parameters:

input1 - The first input of the operation, as a common API operator.

input2 - The second input of the operation, as a common API operator.

Returns:

The created common API operator.

getFunction

protected org.apache.flink.api.common.functions.Function getFunction()

Specified by:

getFunction in class TwoInputUdfOperator<I1,I2,OUT,CoGroupRawOperator<I1,I2,OUT>>