Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs |
Modifier and Type | Class and Description |
---|---|
class |
AvroKeyValueSinkWriter<K,V>
Implementation of AvroKeyValue writer that can be used in Sink.
|
class |
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 . |
class |
StreamWriterBase<T>
Base class for
Writers that write to a FSDataOutputStream . |
class |
StringWriter<T>
A
Writer that uses toString() on the input elements and writes them to
the output bucket file separated by newline. |
Modifier and Type | Method and Description |
---|---|
Writer<T> |
Writer.duplicate()
Duplicates the
Writer . |
Writer<Tuple2<K,V>> |
AvroKeyValueSinkWriter.duplicate() |
Writer<T> |
StringWriter.duplicate() |
Writer<Tuple2<K,V>> |
SequenceFileWriter.duplicate() |
Modifier and Type | Method and Description |
---|---|
RollingSink<T> |
RollingSink.setWriter(Writer<T> writer)
Sets the
Writer to be used for writing the incoming elements to bucket files. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.