org.apache.flink.streaming.connectors.kinesis.util

Interface RecordEmitter.RecordQueue<T>

Type Parameters:

T -

Enclosing class:

RecordEmitter<T extends TimestampedValue>

public static interface RecordEmitter.RecordQueue<T>

Accepts records from readers.

Method Summary

Modifier and Type	Method and Description
int	getSize()
T	peek()
void	put(T record)

Method Detail

put

void put(T record)
  throws InterruptedException

Throws:

InterruptedException

getSize

int getSize()

peek

T peek()