Package beamline.sources

Class BeamlineAbstractSource

java.lang.Object

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

org.apache.flink.streaming.api.functions.source.RichSourceFunction<BEvent>

beamline.sources.BeamlineAbstractSource

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.streaming.api.functions.source.SourceFunction<BEvent>

Direct Known Subclasses:

CSVLogSource, MQTTXesSource, StringTestSource, XesLogSource

public abstract class BeamlineAbstractSource
extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<BEvent>

This class represents the general source to generate BEvents. The goal of the class is to bind the type of the underlying RichSourceFunction to BEvent as well as provide basic management for running/not running.

Since the source is a "rich" one, it means that it is possible to access the state from within all sources derived from this one.

Author:

Andrea Burattin

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 extends Object>

Constructor Summary

Constructors

Constructor	Description
BeamlineAbstractSource()

Method Summary

Modifier and Type	Method	Description
void	cancel()
boolean	isRunning()	Returns if the source is still generting events

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

Methods inherited from interface org.apache.flink.streaming.api.functions.source.SourceFunction

run

Constructor Detail

BeamlineAbstractSource

public BeamlineAbstractSource()

Method Detail

isRunning

public boolean isRunning()

Returns if the source is still generting events

Returns:

whether the current source is still running or not

cancel

public void cancel()