Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs | |
org.apache.flink.streaming.connectors.fs.bucketing |
Modifier and Type | Class and Description |
---|---|
class |
AvroKeyValueSinkWriter<K,V>
Deprecated.
|
class |
SequenceFileWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
Deprecated.
|
class |
StreamWriterBase<T>
Deprecated.
|
class |
StringWriter<T>
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Writer<T> |
Writer.duplicate()
Deprecated.
Duplicates the
Writer . |
Modifier and Type | Method and Description |
---|---|
BucketingSink<T> |
BucketingSink.setWriter(Writer<T> writer)
Deprecated.
Sets the
Writer to be used for writing the incoming elements to bucket files. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.