org.apache.storm.kafka

Class PartitionManager

java.lang.Object

org.apache.storm.kafka.PartitionManager

public class PartitionManager
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PartitionManager.OffsetData

Constructor Summary

Constructors

Constructor and Description
PartitionManager(DynamicPartitionConnections connections, java.lang.String topologyInstanceId, ZkState state, java.util.Map<java.lang.String,java.lang.Object> stormConf, SpoutConfig spoutConfig, Partition id) Constructor

Method Summary

Modifier and Type	Method and Description
void	ack(java.lang.Long offset)
void	close()
void	commit()
void	fail(java.lang.Long offset)
java.util.Map<java.lang.String,java.lang.Object>	getMetricsDataMap()
PartitionManager.OffsetData	getOffsetData()
Partition	getPartition()
long	lastCompletedOffset()
org.apache.storm.kafka.KafkaSpout.EmitState	next(SpoutOutputCollector collector)

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionManager

public PartitionManager(DynamicPartitionConnections connections,
                        java.lang.String topologyInstanceId,
                        ZkState state,
                        java.util.Map<java.lang.String,java.lang.Object> stormConf,
                        SpoutConfig spoutConfig,
                        Partition id)

Constructor

Parameters:

connections -

topologyInstanceId -

state -

stormConf -

spoutConfig -

id -

Method Detail

getMetricsDataMap

public java.util.Map<java.lang.String,java.lang.Object> getMetricsDataMap()

next

public org.apache.storm.kafka.KafkaSpout.EmitState next(SpoutOutputCollector collector)

ack

public void ack(java.lang.Long offset)

fail

public void fail(java.lang.Long offset)

commit

public void commit()

lastCompletedOffset

public long lastCompletedOffset()

getOffsetData

public PartitionManager.OffsetData getOffsetData()

getPartition

public Partition getPartition()

close

public void close()