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	getMetricsData()
void	open()
EventData	receive()

Method Detail

open

void open()
   throws Exception

Throws:

Exception

close

void close()

receive

EventData receive()

checkpoint

void checkpoint()

ack

void ack(String offset)

fail

void fail(String offset)

getMetricsData

Map getMetricsData()