org.apache.flink.streaming.examples.statemachine.generator

Class EventsGeneratorFunction

java.lang.Object

org.apache.flink.streaming.examples.statemachine.generator.EventsGeneratorFunction

All Implemented Interfaces:

Serializable, Function, GeneratorFunction<Long,Event>

public class EventsGeneratorFunction
extends Object
implements GeneratorFunction<Long,Event>

A generator function that produces the events on the fly. Useful for self-contained demos.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EventsGeneratorFunction(double errorProbability)

Method Summary

Modifier and Type	Method and Description
Event	map(Long value)
void	open(SourceReaderContext readerContext) Initialization method for the function.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.connector.datagen.source.GeneratorFunction

close

Constructor Detail

EventsGeneratorFunction

public EventsGeneratorFunction(double errorProbability)

Method Detail

open

public void open(SourceReaderContext readerContext)
          throws Exception

Description copied from interface: GeneratorFunction

Initialization method for the function. It is called once before the actual data mapping methods.

Specified by:

open in interface GeneratorFunction<Long,Event>

Throws:

Exception

map

public Event map(Long value)
          throws Exception

Specified by:

map in interface GeneratorFunction<Long,Event>

Throws:

Exception