org.apache.storm.rocketmq.trident.state

Class RocketMqState.Options

java.lang.Object

org.apache.storm.rocketmq.trident.state.RocketMqState.Options

All Implemented Interfaces:

Serializable

Enclosing class:

RocketMqState

public static class RocketMqState.Options
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Options()

Method Summary

Modifier and Type	Method and Description
RocketMqState.Options	withMapper(TupleToMessageMapper mapper)
RocketMqState.Options	withProperties(Properties properties)
RocketMqState.Options	withSelector(TopicSelector selector)

Methods inherited from class java.lang.Object

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

Constructor Detail

Options

public Options()

Method Detail

withSelector

public RocketMqState.Options withSelector(TopicSelector selector)

withMapper

public RocketMqState.Options withMapper(TupleToMessageMapper mapper)

withProperties

public RocketMqState.Options withProperties(Properties properties)