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

Class Grouping<T>

java.lang.Object

org.apache.flink.api.java.operators.Grouping<T>

Type Parameters:

T - The type of the elements of the grouped DataSet.

Direct Known Subclasses:

SortedGrouping, UnsortedGrouping

@Deprecated
@Public
public abstract class Grouping<T>
extends Object

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.

Grouping is an intermediate step for a transformation on a grouped DataSet.

The following transformation can be applied on Grouping:

• UnsortedGrouping.reduce(org.apache.flink.api.common.functions.ReduceFunction),
• UnsortedGrouping.reduceGroup(org.apache.flink.api.common.functions.GroupReduceFunction), and
• UnsortedGrouping.aggregate(org.apache.flink.api.java.aggregation.Aggregations, int).

See Also:

DataSet, 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.functions.Partitioner<?>	customPartitioner	Deprecated.
protected DataSet<T>	inputDataSet	Deprecated.
protected org.apache.flink.api.common.operators.Keys<T>	keys	Deprecated.

Constructor Summary

Constructors

Constructor	Description
Grouping(DataSet<T> set, org.apache.flink.api.common.operators.Keys<T> keys)	Deprecated.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.functions.Partitioner<?>	getCustomPartitioner()	Deprecated. Gets the custom partitioner to be used for this grouping, or null, if none was defined.
DataSet<T>	getInputDataSet()	Deprecated. Returns the input DataSet of a grouping operation, that is the one before the grouping.
org.apache.flink.api.common.operators.Keys<T>	getKeys()	Deprecated.

Methods inherited from class java.lang.Object

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

Field Detail

inputDataSet

protected final DataSet<T> inputDataSet

Deprecated.

keys

protected final org.apache.flink.api.common.operators.Keys<T> keys

Deprecated.

customPartitioner

protected org.apache.flink.api.common.functions.Partitioner<?> customPartitioner

Deprecated.

Constructor Detail

Grouping

public Grouping(DataSet<T> set,
                org.apache.flink.api.common.operators.Keys<T> keys)

Deprecated.

Method Detail

getInputDataSet

@Internal
public DataSet<T> getInputDataSet()

Deprecated.

Returns the input DataSet of a grouping operation, that is the one before the grouping. This means that if it is applied directly to the result of a grouping operation, it will cancel its effect. As an example, in the following snippet:

 DataSet<X> notGrouped = input.groupBy().getDataSet();
 DataSet<Y> allReduced = notGrouped.reduce()
 

the groupBy() is as if it never happened, as the notGrouped DataSet corresponds to the input of the groupBy() (because of the getDataset()).

getKeys

@Internal
public org.apache.flink.api.common.operators.Keys<T> getKeys()

Deprecated.

getCustomPartitioner

@Internal
public org.apache.flink.api.common.functions.Partitioner<?> getCustomPartitioner()

Deprecated.

Gets the custom partitioner to be used for this grouping, or null, if none was defined.

Returns:

The custom partitioner to be used for this grouping.