storm.kafka

Class PartitionManager

java.lang.Object

storm.kafka.PartitionManager

public class PartitionManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id)

Method Summary

Modifier and Type	Method and Description
void	ack(Long offset)
void	close()
void	commit()
void	fail(Long offset)
Map	getMetricsDataMap()
Partition	getPartition()
long	lastCompletedOffset()
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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

PartitionManager

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

Method Detail

getMetricsDataMap

public Map getMetricsDataMap()

next

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

ack

public void ack(Long offset)

fail

public void fail(Long offset)

commit

public void commit()

lastCompletedOffset

public long lastCompletedOffset()

getPartition

public Partition getPartition()

close

public void close()