backtype.storm.transactional.partitioned
Class OpaquePartitionedTransactionalSpoutExecutor.Coordinator

java.lang.Object
  backtype.storm.transactional.partitioned.OpaquePartitionedTransactionalSpoutExecutor.Coordinator

All Implemented Interfaces:

ITransactionalSpout.Coordinator<java.lang.Object>

Enclosing class:

OpaquePartitionedTransactionalSpoutExecutor

public class OpaquePartitionedTransactionalSpoutExecutor.Coordinator
extends java.lang.Object
implements ITransactionalSpout.Coordinator<java.lang.Object>

Constructor Summary

OpaquePartitionedTransactionalSpoutExecutor.Coordinator()

Method Summary

void	close() Release any resources from this coordinator.
java.lang.Object	initializeTransaction(java.math.BigInteger txid, java.lang.Object prevMetadata) Create metadata for this particular transaction id which has never been emitted before.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OpaquePartitionedTransactionalSpoutExecutor.Coordinator

public OpaquePartitionedTransactionalSpoutExecutor.Coordinator()

Method Detail

initializeTransaction

public java.lang.Object initializeTransaction(java.math.BigInteger txid,
                                              java.lang.Object prevMetadata)

Description copied from interface: ITransactionalSpout.Coordinator

Create metadata for this particular transaction id which has never been emitted before. The metadata should contain whatever is necessary to be able to replay the exact batch for the transaction at a later point. The metadata is stored in Zookeeper. Storm uses the Kryo serializations configured in the component configuration for this spout to serialize and deserialize the metadata.

Specified by:

initializeTransaction in interface ITransactionalSpout.Coordinator<java.lang.Object>

Parameters:

txid - The id of the transaction.

prevMetadata - The metadata of the previous transaction

Returns:

the metadata for this new transaction

close

public void close()

Description copied from interface: ITransactionalSpout.Coordinator

Release any resources from this coordinator.

Specified by:

close in interface ITransactionalSpout.Coordinator<java.lang.Object>