| Package | Description |
|---|---|
| co.cask.cdap.data.stream |
This package contains classes for management and manipulation of stream files.
|
| Modifier and Type | Method and Description |
|---|---|
protected FileReader<PositionStreamEvent,StreamFileOffset> |
LiveStreamFileReader.renewReader() |
| Modifier and Type | Method and Description |
|---|---|
int |
StreamDataFileReader.read(Collection<? super PositionStreamEvent> events,
int maxEvents,
long timeout,
TimeUnit unit) |
int |
StreamDataFileReader.read(Collection<? super PositionStreamEvent> events,
int maxEvents,
long timeout,
TimeUnit unit,
ReadFilter readFilter) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.