Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs |
Class and Description |
---|
Bucketer
A bucketer is used with a
RollingSink
to put emitted elements into rolling files. |
Clock
A clock that can provide the current time.
|
RollingSink
Sink that emits its input elements to rolling
FileSystem files. |
Writer
An implementation of
Writer is used in conjunction with a
RollingSink to perform the actual
writing to the bucket files. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.