Package | Description |
---|---|
org.apache.storm.kafka.trident |
Constructor and Description |
---|
OpaqueTridentKafkaSpout(TridentKafkaConfig config)
Deprecated.
|
TransactionalTridentKafkaSpout(TridentKafkaConfig config)
Deprecated.
|
TridentKafkaEmitter(Map conf,
TopologyContext context,
TridentKafkaConfig config,
String topologyInstanceId) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.