org.apache.storm.kafka

Class PartitionManager

java.lang.Object

org.apache.storm.kafka.PartitionManager

public class PartitionManager
extends 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, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id)
PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id, PartitionManager previousManager)

Method Summary

Modifier and Type	Method and Description
void	ack(Long offset)
void	close()
void	commit()
protected String	committedPath()
void	fail(Long offset)
Map	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,
                        String topologyInstanceId,
                        ZkState state,
                        Map stormConf,
                        SpoutConfig spoutConfig,
                        Partition id)

PartitionManager

public PartitionManager(DynamicPartitionConnections connections,
                        String topologyInstanceId,
                        ZkState state,
                        Map stormConf,
                        SpoutConfig spoutConfig,
                        Partition id,
                        PartitionManager previousManager)

Parameters:

previousManager - previous partition manager if manager for partition is being recreated

Method Detail

getMetricsDataMap

public Map getMetricsDataMap()

next

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

ack

public void ack(Long offset)

fail

public void fail(Long offset)

commit

public void commit()

committedPath

protected String committedPath()

lastCompletedOffset

public long lastCompletedOffset()

getOffsetData

public PartitionManager.OffsetData getOffsetData()

getPartition

public Partition getPartition()

close

public void close()