Package | Description |
---|---|
org.apache.storm.rocketmq.trident.state |
Modifier and Type | Method and Description |
---|---|
RocketMqState.Options |
RocketMqState.Options.withMapper(TupleToMessageMapper mapper) |
RocketMqState.Options |
RocketMqState.Options.withProperties(Properties properties) |
RocketMqState.Options |
RocketMqState.Options.withSelector(TopicSelector selector) |
Constructor and Description |
---|
RocketMqState(Map<String,Object> map,
RocketMqState.Options options) |
RocketMqStateFactory(RocketMqState.Options options) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.