co.cask.cdap.data.stream

Class LiveStreamFileReader

java.lang.Object

co.cask.cdap.data.file.LiveFileReader<PositionStreamEvent,StreamFileOffset>

co.cask.cdap.data.stream.LiveStreamFileReader

All Implemented Interfaces:

FileReader<PositionStreamEvent,StreamFileOffset>, PositionReporter<StreamFileOffset>, Closeable, AutoCloseable

public final class LiveStreamFileReader
extends LiveFileReader<PositionStreamEvent,StreamFileOffset>

A LiveFileReader that gives infinite stream event.

Constructor Summary

Constructors

Constructor and Description
LiveStreamFileReader(StreamConfig streamConfig, StreamFileOffset beginOffset) Construct a reader with Constants.Stream.NEW_FILE_CHECK_INTERVAL as the max interval to check for new file.
LiveStreamFileReader(StreamConfig streamConfig, StreamFileOffset beginOffset, long maxFileCheckInterval) Creates a new file reader.

Method Summary

Methods

Modifier and Type	Method and Description
protected FileReader<PositionStreamEvent,StreamFileOffset>	renewReader()

Methods inherited from class co.cask.cdap.data.file.LiveFileReader

close, getPosition, initialize, read, read

Methods inherited from class java.lang.Object

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

Constructor Detail

LiveStreamFileReader

public LiveStreamFileReader(StreamConfig streamConfig,
                    StreamFileOffset beginOffset)

Construct a reader with Constants.Stream.NEW_FILE_CHECK_INTERVAL as the max interval to check for new file.

Same as calling LiveStreamFileReader(streamConfig, beginOffset, Constants.Stream.NEW_FILE_CHECK_INTERVAL).

LiveStreamFileReader

public LiveStreamFileReader(StreamConfig streamConfig,
                    StreamFileOffset beginOffset,
                    long maxFileCheckInterval)

Creates a new file reader.

Parameters:

streamConfig - the stream configuration.

beginOffset - the offset information to begin with.

maxFileCheckInterval - maximum interval in milliseconds for checking for new stream file.

Method Detail

renewReader

@Nullable
protected FileReader<PositionStreamEvent,StreamFileOffset> renewReader()
                                                                throws IOException

Specified by:

renewReader in class LiveFileReader<PositionStreamEvent,StreamFileOffset>

Returns:

A new FileReader or null if no update.

Throws:

IOException