com.amazonaws.services.kinesis.connectors.interfaces

Interface IFilter<T>

Type Parameters:

T - the data type stored in the record

All Known Implementing Classes:

AllPassFilter

public interface IFilter<T>

The IFilter is associated with an IBuffer. The IBuffer may use the result of calling the keepRecord() method to decide whether to store a record or discard it.

Method Summary

Modifier and Type	Method and Description
boolean	keepRecord(T record) A method enabling the buffer to filter records.

Method Detail

keepRecord

boolean keepRecord(T record)

A method enabling the buffer to filter records. Return false if you don't want to hold on to the record.

Parameters:

record -

Returns:

true if the record should be added to the buffer.