co.cask.cdap.data.file.filter

Class AndReadFilter

java.lang.Object

co.cask.cdap.data.file.ReadFilter

co.cask.cdap.data.file.filter.AndReadFilter

public final class AndReadFilter
extends ReadFilter

AND multiple @{link ReadFilter}s.

Field Summary

Fields inherited from class co.cask.cdap.data.file.ReadFilter

ALWAYS_ACCEPT, ALWAYS_REJECT_OFFSET

Constructor Summary

Constructors

Constructor and Description
AndReadFilter(ReadFilter... filters)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	acceptOffset(long offset) Accept or reject based on file offset.
boolean	acceptTimestamp(long timestamp) Accept or reject based on event timestamp.
long	getNextTimestampHint() If the ReadFilter.acceptTimestamp(long) returns false, the filter can provide a hint for the next timestamp the reader should start reading from.
void	reset() Invoked before filtering a new data block.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AndReadFilter

public AndReadFilter(ReadFilter... filters)

Method Detail

reset

public void reset()

Description copied from class: ReadFilter

Invoked before filtering a new data block.

Overrides:

reset in class ReadFilter

acceptOffset

public boolean acceptOffset(long offset)

Description copied from class: ReadFilter

Accept or reject based on file offset.

Overrides:

acceptOffset in class ReadFilter

Parameters:

offset - The file offset.

Returns:

true to accept, false to reject.

acceptTimestamp

public boolean acceptTimestamp(long timestamp)

Description copied from class: ReadFilter

Accept or reject based on event timestamp.

Overrides:

acceptTimestamp in class ReadFilter

Parameters:

timestamp - The timestamp of the event.

Returns:

true to accept, false to reject.

getNextTimestampHint

public long getNextTimestampHint()

Description copied from class: ReadFilter

If the ReadFilter.acceptTimestamp(long) returns false, the filter can provide a hint for the next timestamp the reader should start reading from.

Overrides:

getNextTimestampHint in class ReadFilter

Returns:

the timestamp for the next event should be or a negative value if no hint is provided.