IPartitionedTridentSpout.Coordinator<Partitions> |
TransactionalTridentEventHubSpout.getCoordinator(Map<String,Object> conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Coordinator<Partitions> |
OpaqueTridentEventHubSpout.getCoordinator(Map<String,Object> conf,
TopologyContext context) |
IPartitionedTridentSpout.Emitter<Partitions,Partition,Map<String,Object>> |
TransactionalTridentEventHubSpout.getEmitter(Map<String,Object> conf,
TopologyContext context) |
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map> |
OpaqueTridentEventHubSpout.getEmitter(Map<String,Object> conf,
TopologyContext context) |