backtype.storm.spout

Interface ISpoutWaitStrategy

All Known Implementing Classes:

NothingEmptyEmitStrategy, SleepSpoutWaitStrategy

public interface ISpoutWaitStrategy

The strategy a spout needs to use when its waiting. Waiting is triggered in one of two conditions:

1. nextTuple emits no tuples 2. The spout has hit maxSpoutPending and can't emit any more tuples

The default strategy sleeps for one millisecond.

Method Summary

Modifier and Type	Method and Description
void	emptyEmit(long streak)
void	prepare(java.util.Map<java.lang.String,java.lang.Object> conf)

Method Detail

prepare

void prepare(java.util.Map<java.lang.String,java.lang.Object> conf)

emptyEmit

void emptyEmit(long streak)