Package org.apache.flink.streaming.connectors.fs

Interface Summary

Interface	Description
Bucketer	Deprecated use Bucketer instead.
Clock	A clock that can provide the current time.
Writer<T>	An implementation of Writer is used in conjunction with a BucketingSink to perform the actual writing to the bucket files.

Class Summary

Class	Description
AvroKeyValueSinkWriter<K,V>	Implementation of AvroKeyValue writer that can be used in Sink.
AvroKeyValueSinkWriter.AvroKeyValue<K,V>	A reusable Avro generic record for writing key/value pairs to the file.
DateTimeBucketer	Deprecated use DateTimeBucketer instead.
NonRollingBucketer	Deprecated use BasePathBucketer instead.
RollingSink<T>	Deprecated use BucketingSink instead.
RollingSink.BucketState	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.
SequenceFileWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>	A Writer that writes the bucket files as Hadoop SequenceFiles.
StreamWriterBase<T>	Base class for Writers that write to a FSDataOutputStream.
StringWriter<T>	A Writer that uses toString() on the input elements and writes them to the output bucket file separated by newline.
SystemClock	A Clock that uses System.currentTimeMillis() to determine the system time.