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

Packages that use StreamDataFileReader

Package	Description
co.cask.cdap.data.stream	This package contains classes for management and manipulation of stream files.

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

Methods in co.cask.cdap.data.stream that return StreamDataFileReader

Modifier and Type	Method and Description
static StreamDataFileReader	StreamDataFileReader.create(com.google.common.io.InputSupplier<? extends SeekableInputStream> eventInputSupplier) Opens a new StreamDataFileReader with the given inputs.
static StreamDataFileReader	StreamDataFileReader.createByStartTime(com.google.common.io.InputSupplier<? extends SeekableInputStream> eventInputSupplier, com.google.common.io.InputSupplier<? extends InputStream> indexInputSupplier, long startTime) Opens a new StreamDataFileReader with the given inputs that starts reading events that are written at or after the given timestamp.
static StreamDataFileReader	StreamDataFileReader.createWithOffset(com.google.common.io.InputSupplier<? extends SeekableInputStream> eventInputSupplier, com.google.common.io.InputSupplier<? extends InputStream> indexInputSupplier, long offset) Opens a new StreamDataFileReader with the given inputs, which starts reading events at a the smallest event position that is larger than or equal to the given offset.