| Package | Description |
|---|---|
| co.cask.cdap.data.stream |
This package contains classes for management and manipulation of stream files.
|
| co.cask.cdap.data.stream.service |
This package contains class for running stream http service as well as twill runnable for running the service in
YARN.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StreamDataFileWriter
File format
Stream event file:
|
| Modifier and Type | Method and Description |
|---|---|
void |
ConcurrentStreamWriter.appendFile(Id.Stream streamId,
Location eventFile,
Location indexFile,
long eventCount,
TimestampCloseable timestampCloseable)
Appends a new stream file to the given stream.
|
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.