| 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 TimePartitionedStreamFileWriter.TimePartition |
TimePartitionedStreamFileWriter.getPartition(co.cask.cdap.api.flow.flowlet.StreamEvent event) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
TimePartitionedStreamFileWriter.partitionChanged(TimePartitionedStreamFileWriter.TimePartition oldPartition,
TimePartitionedStreamFileWriter.TimePartition newPartition) |
Copyright © 2016 Cask Data, Inc. Licensed under the Apache License, Version 2.0.