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

Class Operator<OUT,O extends Operator<OUT,O>>

java.lang.Object

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

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

Type Parameters:

OUT - The type of the data set produced by this operator.

O - The type of the operator, so that we can return it.

Direct Known Subclasses:

DataSource, SingleInputOperator, TwoInputOperator

@Deprecated
@Public
public abstract class Operator<OUT,O extends Operator<OUT,O>>
extends DataSet<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.

Base class of all operators in the Java API.

See Also:

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

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.flink.api.common.operators.ResourceSpec	minResources	Deprecated.
protected String	name	Deprecated.
protected int	parallelism	Deprecated.
protected org.apache.flink.api.common.operators.ResourceSpec	preferredResources	Deprecated.

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

context

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Operator(ExecutionEnvironment context, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> resultType)	Deprecated.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.operators.ResourceSpec	getMinResources()	Deprecated. Returns the minimum resource of this operator.
String	getName()	Deprecated. Returns the name of the operator.
int	getParallelism()	Deprecated. Returns the parallelism of this operator.
org.apache.flink.api.common.operators.ResourceSpec	getPreferredResources()	Deprecated. Returns the preferred resource of this operator.
org.apache.flink.api.common.typeinfo.TypeInformation<OUT>	getResultType()	Deprecated. Returns the type of the result of this operator.
O	name(String newName)	Deprecated. Sets the name of this operator.
O	setParallelism(int parallelism)	Deprecated. Sets the parallelism for this operator.

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

Field Detail

name

protected String name

Deprecated.

parallelism

protected int parallelism

Deprecated.

minResources

protected org.apache.flink.api.common.operators.ResourceSpec minResources

Deprecated.

preferredResources

protected org.apache.flink.api.common.operators.ResourceSpec preferredResources

Deprecated.

Constructor Detail

Operator

protected Operator(ExecutionEnvironment context,
                   org.apache.flink.api.common.typeinfo.TypeInformation<OUT> resultType)

Deprecated.

Method Detail

getResultType

public org.apache.flink.api.common.typeinfo.TypeInformation<OUT> getResultType()

Deprecated.

Returns the type of the result of this operator.

Returns:

The result type of the operator.

getName

public String getName()

Deprecated.

Returns the name of the operator. If no name has been set, it returns the name of the operation, or the name of the class implementing the function of this operator.

Returns:

The name of the operator.

getParallelism

public int getParallelism()

Deprecated.

Returns the parallelism of this operator.

Returns:

The parallelism of this operator.

getMinResources

public org.apache.flink.api.common.operators.ResourceSpec getMinResources()

Deprecated.

Returns the minimum resource of this operator. If no minimum resource has been set, it returns the default empty resource.

Returns:

The minimum resource of this operator.

getPreferredResources

public org.apache.flink.api.common.operators.ResourceSpec getPreferredResources()

Deprecated.

Returns the preferred resource of this operator. If no preferred resource has been set, it returns the default empty resource.

Returns:

The preferred resource of this operator.

name

public O name(String newName)

Deprecated.

Sets the name of this operator. This overrides the default name, which is either a generated description of the operation (such as for example "Aggregate(1:SUM, 2:MIN)") or the name the user-defined function or input/output format executed by the operator.

Parameters:

newName - The name for this operator.

Returns:

The operator with a new name.

setParallelism

public O setParallelism(int parallelism)

Deprecated.

Sets the parallelism for this operator. The parallelism must be 1 or more.

Parameters:

parallelism - The parallelism for this operator. A value equal to ExecutionConfig.PARALLELISM_DEFAULT will use the system default.

Returns:

The operator with set parallelism.