Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs |
Modifier and Type | Class and Description |
---|---|
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 |
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<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.