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 |
RichOutputFormat<IT>
An abstract stub implementation for Rich output formats.
|
class |
SerializedOutputFormat<T extends IOReadableWritable>
Stores elements by serializing them with their regular serialization/deserialization functionality.
|
Modifier and Type | Field and Description |
---|---|
protected UserCodeWrapper<? extends OutputFormat<IN>> |
GenericDataSinkBase.formatWrapper |
Modifier and Type | Method and Description |
---|---|
UserCodeWrapper<? extends OutputFormat<IN>> |
GenericDataSinkBase.getFormatWrapper()
Gets the class describing this sinks output format.
|
UserCodeWrapper<? extends OutputFormat<IN>> |
GenericDataSinkBase.getUserCodeWrapper()
Gets the class describing the output format.
|
Constructor and Description |
---|
GenericDataSinkBase(OutputFormat<IN> f,
UnaryOperatorInformation<IN,Nothing> operatorInfo,
String name)
Creates a GenericDataSink with the provided
OutputFormat implementation
and the given name. |
Constructor and Description |
---|
GenericDataSinkBase(UserCodeWrapper<? extends OutputFormat<IN>> f,
UnaryOperatorInformation<IN,Nothing> operatorInfo,
String name)
Creates a GenericDataSink with the provided
OutputFormat implementation
and the given name. |
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 | Method and Description |
---|---|
DataSink<T> |
DataSet.output(OutputFormat<T> outputFormat)
Emits a DataSet using an
OutputFormat . |
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 |
DiscardingOutputFormat<T>
An output format that simply discards all elements.
|
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
OutputFormat to write tuples into a database.
|
Modifier and Type | Method and Description |
---|---|
OutputFormat<T> |
DataSink.getFormat() |
Constructor and Description |
---|
DataSink(DataSet<T> data,
OutputFormat<T> format,
TypeInformation<T> type) |
Modifier and Type | Method and Description |
---|---|
DataSink<T> |
DataSet.output(OutputFormat<T> outputFormat)
Emits
this DataSet using a custom OutputFormat . |
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>
OutputFormat to write
Tuple into Apache Cassandra. |
Modifier and Type | Class and Description |
---|---|
static class |
ExampleUtils.PrintingOutputFormatWithMessage<T> |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.writeUsingOutputFormat(OutputFormat<T> format)
Writes the dataStream into an output, described by an OutputFormat.
|
Constructor and Description |
---|
OutputFormatSinkFunction(OutputFormat<IN> format) |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.writeUsingOutputFormat(OutputFormat<T> format)
Writes a DataStream using the given
OutputFormat . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.