| 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 |
CsvOutputFormat<T extends Tuple>
This is an OutputFormat to serialize
Tuples to text. |
class |
LocalCollectionOutputFormat<T>
An output format that adds records to a collection.
|
class |
PrintingOutputFormat<T>
Output format that prints results into either stdout or stderr.
|
class |
TextOutputFormat<T>
A
FileOutputFormat that writes objects to a text file. |
class |
TypeSerializerOutputFormat<T>
Stores elements by serializing them with their type serializer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JDBCOutputFormat
OutputFormat to write Rows into a JDBC database.
|
| 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 |
CassandraOutputFormat<OUT extends Tuple>
Deprecated.
Please use CassandraTupleOutputFormat instead.
|
class |
CassandraOutputFormatBase<OUT>
CassandraOutputFormatBase is the common abstract class for writing into Apache Cassandra.
|
class |
CassandraRowOutputFormat
OutputFormat to write Flink
Rows into a Cassandra cluster. |
class |
CassandraTupleOutputFormat<OUT extends Tuple>
OutputFormat to write Flink
Tuples into a Cassandra cluster. |
| Modifier and Type | Class and Description |
|---|---|
class |
AvroOutputFormat<E>
FileOutputFormat for Avro records. |
| Modifier and Type | Class and Description |
|---|---|
class |
AnalyticHelper<T>
A
GraphAnalytic computes over a DataSet and returns the results via
Flink accumulators. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.