org.apache.flink.datastream.api.function

Interface ApplyPartitionFunction<OUT>

All Superinterfaces:

Function, Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
 @Experimental
public interface ApplyPartitionFunction<OUT>
extends Function

A function to be applied to all partitions .

Method Summary

Modifier and Type	Method and Description
void	apply(Collector<OUT> collector, PartitionedContext ctx) The actual method to be applied to each partition.

Method Detail

apply

void apply(Collector<OUT> collector,
           PartitionedContext ctx)
    throws Exception

The actual method to be applied to each partition.

Parameters:

collector - to output data.

ctx - runtime context in which this function is executed.

Throws:

Exception