Uses of Class
co.cask.cdap.data.file.ReadFilter

Packages that use ReadFilter

Package	Description
co.cask.cdap.data.file	This package contains classes for interacting with data files.
co.cask.cdap.data.file.filter
co.cask.cdap.data.stream	This package contains classes for management and manipulation of stream files.
co.cask.cdap.data2.transaction.stream	This package contains transaction stream consumer classes for maintaining stateful consumption of stream entries.
co.cask.cdap.data2.transaction.stream.hbase	This package contains class for stream consumer implementation that uses HBase as state store.
co.cask.cdap.data2.transaction.stream.leveldb	This package contains class for stream consumer implementation that uses LevelDB as state store.

Uses of ReadFilter in co.cask.cdap.data.file

Fields in co.cask.cdap.data.file declared as ReadFilter

Modifier and Type	Field and Description
static ReadFilter	ReadFilter.ALWAYS_ACCEPT Always accept what it sees.
static ReadFilter	ReadFilter.ALWAYS_REJECT_OFFSET Always reject offset.

Methods in co.cask.cdap.data.file that return ReadFilter

Modifier and Type	Method and Description
static ReadFilter	ReadFilters.and(ReadFilter... filters)

Methods in co.cask.cdap.data.file with parameters of type ReadFilter

Modifier and Type	Method and Description
static ReadFilter	ReadFilters.and(ReadFilter... filters)
int	FileReader.read(Collection<? super T> events, int maxEvents, long timeout, TimeUnit unit, ReadFilter readFilter) Reads as much data as possible that passes the given filter until maxEvents.
int	LiveFileReader.read(Collection<? super T> events, int maxEvents, long timeout, TimeUnit unit, ReadFilter readFilter)

Uses of ReadFilter in co.cask.cdap.data.file.filter

Subclasses of ReadFilter in co.cask.cdap.data.file.filter

Modifier and Type	Class and Description
class	AndReadFilter AND multiple @{link ReadFilter}s.
class	TTLReadFilter ReadFilter for filtering expired stream events according to TTL and current time.

Constructors in co.cask.cdap.data.file.filter with parameters of type ReadFilter

Constructor and Description
AndReadFilter(ReadFilter... filters)

Uses of ReadFilter in co.cask.cdap.data.stream

Subclasses of ReadFilter in co.cask.cdap.data.stream

Modifier and Type	Class and Description
class	TimeRangeReadFilter A ReadFilter for accepting events that are within a given time range.

Methods in co.cask.cdap.data.stream with parameters of type ReadFilter

Modifier and Type	Method and Description
int	StreamDataFileReader.read(Collection<? super PositionStreamEvent> events, int maxEvents, long timeout, TimeUnit unit, ReadFilter readFilter)
int	MultiLiveStreamFileReader.read(Collection<? super StreamEventOffset> events, int maxEvents, long timeout, TimeUnit unit, ReadFilter readFilter)

Uses of ReadFilter in co.cask.cdap.data2.transaction.stream

Methods in co.cask.cdap.data2.transaction.stream with parameters of type ReadFilter

Modifier and Type	Method and Description
protected abstract StreamConsumer	AbstractStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter) Creates a StreamConsumer.

Constructors in co.cask.cdap.data2.transaction.stream with parameters of type ReadFilter

Constructor and Description
AbstractStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore consumerStateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter)

Uses of ReadFilter in co.cask.cdap.data2.transaction.stream.hbase

Methods in co.cask.cdap.data2.transaction.stream.hbase with parameters of type ReadFilter

Modifier and Type	Method and Description
protected StreamConsumer	HBaseStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter)

Constructors in co.cask.cdap.data2.transaction.stream.hbase with parameters of type ReadFilter

Constructor and Description
HBaseStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, HBaseTableUtil tableUtil, org.apache.hadoop.hbase.client.HTable hTable, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter, AbstractRowKeyDistributor keyDistributor) Constructor.

Uses of ReadFilter in co.cask.cdap.data2.transaction.stream.leveldb

Methods in co.cask.cdap.data2.transaction.stream.leveldb with parameters of type ReadFilter

Modifier and Type	Method and Description
protected StreamConsumer	LevelDBStreamFileConsumerFactory.create(TableId tableId, StreamConfig streamConfig, ConsumerConfig consumerConfig, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, ReadFilter extraFilter)

Constructors in co.cask.cdap.data2.transaction.stream.leveldb with parameters of type ReadFilter

Constructor and Description
LevelDBStreamFileConsumer(CConfiguration cConf, StreamConfig streamConfig, ConsumerConfig consumerConfig, FileReader<StreamEventOffset,Iterable<StreamFileOffset>> reader, StreamConsumerStateStore stateStore, StreamConsumerState beginConsumerState, ReadFilter extraFilter, LevelDBTableCore tableCore, Object dbLock)