Package org.apache.flink.api.java.functions

Class GroupReduceIterator<IN,OUT>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT>

org.apache.flink.api.java.functions.GroupReduceIterator<IN,OUT>

Type Parameters:

IN -

OUT -

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.GroupReduceFunction<IN,OUT>, org.apache.flink.api.common.functions.RichFunction

@Deprecated
@PublicEvolving
public abstract class GroupReduceIterator<IN,OUT>
extends org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,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 that simplifies reducing all values provided as Iterable.

See Also:

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

Constructor Summary

Constructors

Constructor	Description
GroupReduceIterator()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	reduce(Iterable<IN> values, org.apache.flink.util.Collector<OUT> out)	Deprecated.
abstract Iterator<OUT>	reduceGroup(Iterable<IN> values)	Deprecated.

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.functions.RichFunction

open

Constructor Detail

GroupReduceIterator

public GroupReduceIterator()

Deprecated.

Method Detail

reduceGroup

public abstract Iterator<OUT> reduceGroup(Iterable<IN> values)
                                   throws Exception

Deprecated.

Throws:

Exception

reduce

public final void reduce(Iterable<IN> values,
                         org.apache.flink.util.Collector<OUT> out)
                  throws Exception

Deprecated.

Specified by:

reduce in interface org.apache.flink.api.common.functions.GroupReduceFunction<IN,OUT>

Specified by:

reduce in class org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT>

Throws:

Exception