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