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

Class ReduceOperator<IN>

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.SingleInputOperator<IN,OUT,O>

org.apache.flink.api.java.operators.SingleInputUdfOperator<IN,IN,ReduceOperator<IN>>

org.apache.flink.api.java.operators.ReduceOperator<IN>

Type Parameters:

IN - The type of the data set reduced by the operator.

All Implemented Interfaces:

UdfOperator<ReduceOperator<IN>>

@Deprecated
@Public
public class ReduceOperator<IN>
extends SingleInputUdfOperator<IN,IN,ReduceOperator<IN>>

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.

This operator represents the application of a "reduce" function on a data set, and the result data set produced by the function.

See Also:

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

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
ReduceOperator(DataSet<IN> input, org.apache.flink.api.common.functions.ReduceFunction<IN> function, String defaultName)	Deprecated. This is the case for a reduce-all case (in contrast to the reduce-per-group case).
ReduceOperator(Grouping<IN> input, org.apache.flink.api.common.functions.ReduceFunction<IN> function, String defaultName)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected org.apache.flink.api.common.functions.ReduceFunction<IN>	getFunction()	Deprecated.
org.apache.flink.api.common.operators.SingleInputSemanticProperties	getSemanticProperties()	Deprecated. Gets the semantic properties that have been set for the user-defined functions (UDF).
ReduceOperator<IN>	setCombineHint(org.apache.flink.api.common.operators.base.ReduceOperatorBase.CombineHint strategy)	Deprecated. Sets the strategy to use for the combine phase of the reduce.
protected org.apache.flink.api.common.operators.SingleInputOperator<?,IN,?>	translateToDataFlow(org.apache.flink.api.common.operators.Operator<IN> input)	Deprecated. Translates this operation to a data flow operator of the common data flow API.

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

extractSemanticAnnotations, getAnalyzedUdfSemanticsFlag, getBroadcastSets, getParameters, returns, returns, returns, setAnalyzedUdfSemanticsFlag, setSemanticProperties, udfWithForwardedFieldsAnnotation, withBroadcastSet, withForwardedFields, withParameters

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

getInput, getInputType

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

ReduceOperator

public ReduceOperator(DataSet<IN> input,
                      org.apache.flink.api.common.functions.ReduceFunction<IN> function,
                      String defaultName)

Deprecated.

This is the case for a reduce-all case (in contrast to the reduce-per-group case).

Parameters:

input -

function -

ReduceOperator

public ReduceOperator(Grouping<IN> input,
                      org.apache.flink.api.common.functions.ReduceFunction<IN> function,
                      String defaultName)

Deprecated.

Method Detail

getFunction

protected org.apache.flink.api.common.functions.ReduceFunction<IN> getFunction()

Deprecated.

Specified by:

getFunction in class SingleInputUdfOperator<IN,IN,ReduceOperator<IN>>

getSemanticProperties

@Internal
public org.apache.flink.api.common.operators.SingleInputSemanticProperties getSemanticProperties()

Deprecated.

Description copied from interface: UdfOperator

Gets the semantic properties that have been set for the user-defined functions (UDF).

Specified by:

getSemanticProperties in interface UdfOperator<IN>

Overrides:

getSemanticProperties in class SingleInputUdfOperator<IN,IN,ReduceOperator<IN>>

Returns:

The semantic properties of the UDF.

translateToDataFlow

protected org.apache.flink.api.common.operators.SingleInputOperator<?,IN,?> translateToDataFlow(org.apache.flink.api.common.operators.Operator<IN> input)

Deprecated.

Description copied from class: SingleInputOperator

Translates this operation to a data flow operator of the common data flow API.

Specified by:

translateToDataFlow in class SingleInputOperator<IN,IN,ReduceOperator<IN>>

Parameters:

input - The data flow operator that produces this operation's input data.

Returns:

The translated data flow operator.

setCombineHint

@PublicEvolving
public ReduceOperator<IN> setCombineHint(org.apache.flink.api.common.operators.base.ReduceOperatorBase.CombineHint strategy)

Deprecated.

Sets the strategy to use for the combine phase of the reduce.

If this method is not called, then the default hint will be used. (ReduceOperatorBase.CombineHint.OPTIMIZER_CHOOSES)

Parameters:

strategy - The hint to use.

Returns:

The ReduceOperator object, for function call chaining.