Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs | |
org.apache.flink.streaming.connectors.fs.bucketing |
Class and Description |
---|
Bucketer
Deprecated.
use
Bucketer instead. |
Clock
A clock that can provide the current time.
|
RollingSink
Deprecated.
use
BucketingSink instead. |
RollingSink.BucketState
Deprecated.
This is used for keeping track of the current in-progress files and files that we mark
for moving from pending to final location after we get a checkpoint-complete notification.
|
StreamWriterBase
Base class for
Writers that write to a FSDataOutputStream . |
Writer
An implementation of
Writer is used in conjunction with a
BucketingSink to perform the actual
writing to the bucket files. |
Class and Description |
---|
Clock
A clock that can provide the current time.
|
RollingSink.BucketState
Deprecated.
This is used for keeping track of the current in-progress files and files that we mark
for moving from pending to final location after we get a checkpoint-complete notification.
|
Writer
An implementation of
Writer is used in conjunction with a
BucketingSink to perform the actual
writing to the bucket files. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.