org.apache.storm.mqtt.trident

Class MqttPublishFunction

java.lang.Object

org.apache.storm.trident.operation.BaseOperation

org.apache.storm.trident.operation.BaseFunction

org.apache.storm.mqtt.trident.MqttPublishFunction

All Implemented Interfaces:

Serializable, EachOperation, Function, Operation

public class MqttPublishFunction
extends BaseFunction

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MqttPublishFunction(MqttOptions options, MqttTupleMapper mapper, KeyStoreLoader keyStoreLoader, boolean retain)

Method Summary

Modifier and Type	Method and Description
void	execute(TridentTuple tuple, TridentCollector collector) Performs the function logic on an individual tuple and emits 0 or more tuples.
void	prepare(Map conf, TridentOperationContext context) No-op implementation.

Methods inherited from class org.apache.storm.trident.operation.BaseOperation

cleanup

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup

Constructor Detail

MqttPublishFunction

public MqttPublishFunction(MqttOptions options,
                           MqttTupleMapper mapper,
                           KeyStoreLoader keyStoreLoader,
                           boolean retain)

Method Detail

prepare

public void prepare(Map conf,
                    TridentOperationContext context)

Description copied from class: BaseOperation

No-op implementation.

Specified by:

prepare in interface Operation

Overrides:

prepare in class BaseOperation

Parameters:

conf - the Storm configuration map

context - the operation context which provides information such as the number of partitions in the stream, and the current partition index. It also provides methods for registering operation-specific metrics.

See Also:

TridentOperationContext

execute

public void execute(TridentTuple tuple,
                    TridentCollector collector)

Description copied from interface: Function

Performs the function logic on an individual tuple and emits 0 or more tuples.

Parameters:

tuple - The incoming tuple

collector - A collector instance that can be used to emit tuples