Uses of Class
co.cask.cdap.data.stream.StreamEventOffset

Packages that use StreamEventOffset

Package	Description
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 StreamEventOffset in co.cask.cdap.data.stream

Method parameters in co.cask.cdap.data.stream with type arguments of type StreamEventOffset

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

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

Method parameters in co.cask.cdap.data2.transaction.stream with type arguments of type StreamEventOffset

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.

Constructor parameters in co.cask.cdap.data2.transaction.stream with type arguments of type StreamEventOffset

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

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

Method parameters in co.cask.cdap.data2.transaction.stream.hbase with type arguments of type StreamEventOffset

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)

Constructor parameters in co.cask.cdap.data2.transaction.stream.hbase with type arguments of type StreamEventOffset

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 StreamEventOffset in co.cask.cdap.data2.transaction.stream.leveldb

Method parameters in co.cask.cdap.data2.transaction.stream.leveldb with type arguments of type StreamEventOffset

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)

Constructor parameters in co.cask.cdap.data2.transaction.stream.leveldb with type arguments of type StreamEventOffset

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)