| Package | Description |
|---|---|
| co.cask.cdap.data.file |
This package contains classes for interacting with data files.
|
| co.cask.cdap.data.runtime |
This package contains implementations and guice-bindings needed for data-fabric runtime.
|
| co.cask.cdap.data.stream |
This package contains classes for management and manipulation of stream files.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PartitionedFileWriter<T,P>
An abstract base class for implementation partitioned
FileWriter. |
| Modifier and Type | Method and Description |
|---|---|
FileWriter<T> |
PartitionedFileWriter.PartitionedFileWriterFactory.create(P partition)
Creates a
FileWriter for writing event of type T for the given partition. |
static <U,V> FileWriter<U> |
FileWriters.transform(FileWriter<V> writer,
com.google.common.base.Function<U,V> transform)
Creates a
FileWriter that writes to the given FileWriter with each event transformed by the
given transformation function. |
| Modifier and Type | Method and Description |
|---|---|
static <U,V> FileWriter<U> |
FileWriters.transform(FileWriter<V> writer,
com.google.common.base.Function<U,V> transform)
Creates a
FileWriter that writes to the given FileWriter with each event transformed by the
given transformation function. |
| Modifier and Type | Method and Description |
|---|---|
FileWriter<co.cask.cdap.api.flow.flowlet.StreamEvent> |
LocationStreamFileWriterFactory.create(StreamConfig config,
int generation) |
FileWriter<co.cask.cdap.api.flow.flowlet.StreamEvent> |
InMemoryStreamFileWriterFactory.create(StreamConfig config,
int generation) |
| Modifier and Type | Class and Description |
|---|---|
class |
StreamDataFileWriter
File format
Stream event file:
|
class |
TimePartitionedStreamFileWriter
Stream file path format:
Each file has path pattern |
| Modifier and Type | Method and Description |
|---|---|
FileWriter<co.cask.cdap.api.flow.flowlet.StreamEvent> |
StreamFileWriterFactory.create(StreamConfig config,
int generation) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.