Package | Description |
---|---|
org.apache.flink.api.java.io | |
org.apache.flink.api.scala.operators | |
org.apache.flink.streaming.api.functions.sink |
Modifier and Type | Class and Description |
---|---|
class |
CsvOutputFormat<T extends Tuple>
This is an OutputFormat to serialize
Tuple s to text. |
class |
LocalCollectionOutputFormat<T>
An output format that adds records to a collection.
|
class |
TypeSerializerOutputFormat<T>
Stores elements by serializing them with their type serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaCsvOutputFormat<T extends scala.Product>
This is an OutputFormat to serialize Scala Tuples to text.
|
Modifier and Type | Class and Description |
---|---|
class |
OutputFormatSinkFunction<IN>
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.