Modifier and Type | Class and Description |
---|---|
class |
BinaryOutputFormat<T> |
class |
FileOutputFormat<IT>
The abstract base class for all Rich output formats that are file based.
|
class |
SerializedOutputFormat<T extends IOReadableWritable>
Stores elements by serializing them with their regular serialization/deserialization functionality.
|
Modifier and Type | Class and Description |
---|---|
static class |
Utils.ChecksumHashCodeHelper<T> |
static class |
Utils.CollectHelper<T>
Utility sink function that collects elements into an accumulator,
from which it they can be retrieved by the client.
|
static class |
Utils.CountHelper<T>
Utility sink function that counts elements and writes the count into an accumulator,
from which it can be retrieved by the client.
|
Modifier and Type | Class and Description |
---|---|
class |
HadoopOutputFormatCommonBase<T>
A common base for both "mapred" and "mapreduce" Hadoop output formats.
|
Modifier and Type | Class and Description |
---|---|
class |
HadoopOutputFormat<K,V>
OutputFormat implementation allowing to use Hadoop (mapreduce) OutputFormats with Flink.
|
class |
HadoopOutputFormatBase<K,V,T>
Base class shared between the Java and Scala API of Flink
|
Modifier and Type | Class and Description |
---|---|
class |
AvroOutputFormat<E> |
class |
CsvOutputFormat<T extends Tuple>
This is an OutputFormat to serialize
Tuple s to text. |
class |
LocalCollectionOutputFormat<T>
An output format that writes record into collection
|
class |
PrintingOutputFormat<T> |
class |
TextOutputFormat<T> |
class |
TypeSerializerOutputFormat<T>
Stores elements by serializing them with their type serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
JDBCOutputFormat<OUT extends Tuple>
OutputFormat to write tuples into a database.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaCsvOutputFormat<T extends scala.Product>
This is an OutputFormat to serialize Scala Tuples to text.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.