stream.scotty.flinkconnector.demo

Class DemoSource

java.lang.Object

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

org.apache.flink.streaming.api.functions.source.RichSourceFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>

flink.demo.stream.scotty.DemoSource

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>

public class DemoSource
extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction

org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T>

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	canceled
private java.util.Random	key
long	lastWatermark
private java.util.Random	value

Constructor Summary

Constructors

Constructor and Description
DemoSource()

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	open(org.apache.flink.configuration.Configuration parameters)
void	run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>> ctx)

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

close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Field Detail

key

private java.util.Random key

value

private java.util.Random value

canceled

private boolean canceled

lastWatermark

public long lastWatermark

Constructor Detail

DemoSource

public DemoSource()

Method Detail

open

public void open(org.apache.flink.configuration.Configuration parameters)
          throws java.lang.Exception

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

java.lang.Exception

run

public void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>> ctx)
         throws java.lang.Exception

Specified by:

run in interface org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>

Throws:

java.lang.Exception

cancel

public void cancel()

Specified by:

cancel in interface org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.Integer,java.lang.Integer>>