Package | Description |
---|---|
org.apache.storm.rocketmq.bolt | |
org.apache.storm.rocketmq.common.mapper | |
org.apache.storm.rocketmq.trident.state |
Class and Description |
---|
TupleToMessageMapper
Interface defining a mapping from storm tuple to rocketmq key and message.
|
Class and Description |
---|
FieldNameBasedTupleToMessageMapper |
TupleToMessageMapper
Interface defining a mapping from storm tuple to rocketmq key and message.
|
Class and Description |
---|
TupleToMessageMapper
Interface defining a mapping from storm tuple to rocketmq key and message.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.