Package beamline.sources

Class MQTTXesSource

java.lang.Object

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

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

beamline.sources.BeamlineAbstractSource

beamline.sources.MQTTXesSource

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>

public class MQTTXesSource
extends BeamlineAbstractSource

This implementation of a BeamlineAbstractSource produces events as they are observed in an MQTT-XES broker.

Example of usage:

 MQTTXesSource source = new MQTTXesSource("tcp://broker.hivemq.com:1883", "topicBase", "processName");
 

See also the documentation of MQTT-XES at http://www.beamline.cloud/mqtt-xes/

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
MQTTXesSource(String brokerHost, String topicBase, String processName)	Constructs the source

Method Summary

Modifier and Type	Method	Description
void	run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<BEvent> ctx)

Methods inherited from class beamline.sources.BeamlineAbstractSource

cancel, isRunning

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

MQTTXesSource

public MQTTXesSource(String brokerHost,
                     String topicBase,
                     String processName)

Constructs the source

Parameters:

brokerHost - the URL of the broker host

topicBase - the base of the topic for the

processName - the name of the process

Method Detail

run

public void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<BEvent> ctx)
         throws Exception

Throws:

Exception