org.apache.storm.eventhubs.spout

Interface IPartitionManager

All Known Implementing Classes:

PartitionManager, SimplePartitionManager

public interface IPartitionManager

Method Summary

Modifier and Type	Method and Description
void	ack(String offset)
void	checkpoint()
void	close()
void	fail(String offset)
Map<String,Object>	getMetricsData()
void	open()
EventDataWrap	receive()

Method Detail

open

void open()
   throws Exception

Throws:

Exception

close

void close()

receive

EventDataWrap receive()

checkpoint

void checkpoint()

ack

void ack(String offset)

fail

void fail(String offset)

getMetricsData

Map<String,Object> getMetricsData()