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

Class CrossOperator<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,CrossOperator<I1,I2,OUT>>

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

Type Parameters:

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

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

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

All Implemented Interfaces:

UdfOperator<CrossOperator<I1,I2,OUT>>

Direct Known Subclasses:

CrossOperator.DefaultCross, CrossOperator.ProjectCross

@Deprecated
@Public
public class CrossOperator<I1,I2,OUT>
extends TwoInputUdfOperator<I1,I2,OUT,CrossOperator<I1,I2,OUT>>

Deprecated.

All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.

A DataSet that is the result of a Cross transformation.

See Also:

DataSet, FLIP-131: Consolidate the user-facing Dataflow SDKs/APIs (and deprecate the DataSet API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CrossOperator.CrossProjection<I1,I2>	Deprecated.
static class	CrossOperator.DefaultCross<I1,I2>	Deprecated. A Cross transformation that wraps pairs of crossed elements into Tuple2.
static class	CrossOperator.ProjectCross<I1,I2,OUT extends org.apache.flink.api.java.tuple.Tuple>	Deprecated. A Cross transformation that projects crossing elements or fields of crossing Tuples into result Tuples.
static class	CrossOperator.ProjectCrossFunction<T1,T2,R extends org.apache.flink.api.java.tuple.Tuple>	Deprecated.

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
CrossOperator(DataSet<I1> input1, DataSet<I2> input2, org.apache.flink.api.common.functions.CrossFunction<I1,I2,OUT> function, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> returnType, org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossHint hint, String defaultName)	Deprecated.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossHint	getCrossHint()	Deprecated.
protected org.apache.flink.api.common.functions.CrossFunction<I1,I2,OUT>	getFunction()	Deprecated.
protected org.apache.flink.api.common.operators.base.CrossOperatorBase<I1,I2,OUT,org.apache.flink.api.common.functions.CrossFunction<I1,I2,OUT>>	translateToDataFlow(org.apache.flink.api.common.operators.Operator<I1> input1, org.apache.flink.api.common.operators.Operator<I2> input2)	Deprecated. 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

CrossOperator

public CrossOperator(DataSet<I1> input1,
                     DataSet<I2> input2,
                     org.apache.flink.api.common.functions.CrossFunction<I1,I2,OUT> function,
                     org.apache.flink.api.common.typeinfo.TypeInformation<OUT> returnType,
                     org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossHint hint,
                     String defaultName)

Deprecated.

Method Detail

getFunction

protected org.apache.flink.api.common.functions.CrossFunction<I1,I2,OUT> getFunction()

Deprecated.

Specified by:

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

getCrossHint

@Internal
public org.apache.flink.api.common.operators.base.CrossOperatorBase.CrossHint getCrossHint()

Deprecated.

translateToDataFlow

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

Deprecated.

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,CrossOperator<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.