org.apache.flink.streaming.examples.iteration

Class IterateExample.Step

java.lang.Object

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

org.apache.flink.streaming.api.functions.ProcessFunction<Tuple5<Integer,Integer,Integer,Integer,Integer>,Tuple5<Integer,Integer,Integer,Integer,Integer>>

org.apache.flink.streaming.examples.iteration.IterateExample.Step

All Implemented Interfaces:

Serializable, Function, RichFunction

Enclosing class:

IterateExample

public static class IterateExample.Step
extends ProcessFunction<Tuple5<Integer,Integer,Integer,Integer,Integer>,Tuple5<Integer,Integer,Integer,Integer,Integer>>

Iteration step function that calculates the next Fibonacci number.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.ProcessFunction

ProcessFunction.Context, ProcessFunction.OnTimerContext

Constructor Summary

Constructors

Constructor and Description
Step()

Method Summary

Modifier and Type	Method and Description
void	processElement(Tuple5<Integer,Integer,Integer,Integer,Integer> value, ProcessFunction.Context ctx, Collector<Tuple5<Integer,Integer,Integer,Integer,Integer>> out) Process one element from the input stream.

Methods inherited from class org.apache.flink.streaming.api.functions.ProcessFunction

onTimer

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

Constructor Detail

Step

public Step()

Method Detail

processElement

public void processElement(Tuple5<Integer,Integer,Integer,Integer,Integer> value,
                           ProcessFunction.Context ctx,
                           Collector<Tuple5<Integer,Integer,Integer,Integer,Integer>> out)
                    throws Exception

Description copied from class: ProcessFunction

Process one element from the input stream.

This function can output zero or more elements using the Collector parameter and also update internal state or set timers using the ProcessFunction.Context parameter.

Specified by:

processElement in class ProcessFunction<Tuple5<Integer,Integer,Integer,Integer,Integer>,Tuple5<Integer,Integer,Integer,Integer,Integer>>

Parameters:

value - The input value.

ctx - A ProcessFunction.Context that allows querying the timestamp of the element and getting a TimerService for registering timers and querying the time. The context is only valid during the invocation of this method, do not store it.

out - The collector for returning result values.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.