backtype.storm.transactional.partitioned

Interface IPartitionedTransactionalSpout<T>

All Superinterfaces:

IComponent, Serializable

All Known Implementing Classes:

BasePartitionedTransactionalSpout, MemoryTransactionalSpout

public interface IPartitionedTransactionalSpout<T>
extends IComponent

This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. It automates the storing of metadata for each partition to ensure that the same batch is always emitted for the same transaction id. The partition metadata is stored in Zookeeper.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	IPartitionedTransactionalSpout.Coordinator
static interface	IPartitionedTransactionalSpout.Emitter<X>

Method Summary

Methods

Modifier and Type	Method and Description
IPartitionedTransactionalSpout.Coordinator	getCoordinator(Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Emitter<T>	getEmitter(Map conf, TopologyContext context)

Methods inherited from interface backtype.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Detail

getCoordinator

IPartitionedTransactionalSpout.Coordinator getCoordinator(Map conf,
                                                        TopologyContext context)

getEmitter

IPartitionedTransactionalSpout.Emitter<T> getEmitter(Map conf,
                                                   TopologyContext context)