Package 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<org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>,org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

Enclosing class:

IterateExample

public static class IterateExample.Step
extends org.apache.flink.streaming.api.functions.ProcessFunction<org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>,org.apache.flink.api.java.tuple.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

org.apache.flink.streaming.api.functions.ProcessFunction.Context, org.apache.flink.streaming.api.functions.ProcessFunction.OnTimerContext

Constructor Summary

Constructors

Constructor	Description
Step()

Method Summary

Modifier and Type	Method	Description
void	processElement(org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer> value, org.apache.flink.streaming.api.functions.ProcessFunction.Context ctx, org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>> out)

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(org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer> value,
                           org.apache.flink.streaming.api.functions.ProcessFunction.Context ctx,
                           org.apache.flink.util.Collector<org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>> out)
                    throws Exception

Specified by:

processElement in class org.apache.flink.streaming.api.functions.ProcessFunction<org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>,org.apache.flink.api.java.tuple.Tuple5<Integer,Integer,Integer,Integer,Integer>>

Throws:

Exception