org.apache.flink.streaming.examples.join

Class WindowJoinSampleData.GradeSource

java.lang.Object

org.apache.flink.streaming.examples.join.WindowJoinSampleData.GradeSource

All Implemented Interfaces:

Serializable, Iterator<Tuple2<String,Integer>>

Enclosing class:

WindowJoinSampleData

public static class WindowJoinSampleData.GradeSource
extends Object
implements Iterator<Tuple2<String,Integer>>, Serializable

Continuously generates (name, grade).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GradeSource()

Method Summary

Modifier and Type	Method and Description
static DataStream<Tuple2<String,Integer>>	getSource(StreamExecutionEnvironment env, long rate)
boolean	hasNext()
Tuple2<String,Integer>	next()
void	remove()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

GradeSource

public GradeSource()

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<Tuple2<String,Integer>>

next

public Tuple2<String,Integer> next()

Specified by:

next in interface Iterator<Tuple2<String,Integer>>

remove

public void remove()

Specified by:

remove in interface Iterator<Tuple2<String,Integer>>

getSource

public static DataStream<Tuple2<String,Integer>> getSource(StreamExecutionEnvironment env,
                                                           long rate)