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 |
BlockingShuffleOutputFormat<T>
This is the inner OutputFormat used for specify the BLOCKING_PERSISTENT result partition type of
coming edge.
|
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 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
Deprecated.
please use
JdbcOutputFormat |
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 | 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 |
CassandraPojoOutputFormat<OUT>
OutputFormat to write data to Apache Cassandra and from a custom Cassandra annotated object.
|
class |
CassandraRowOutputFormat
OutputFormat to write Flink
Row s into a Cassandra cluster. |
class |
CassandraTupleOutputFormat<OUT extends Tuple>
OutputFormat to write Flink
Tuple s into a Cassandra cluster. |
Modifier and Type | Class and Description |
---|---|
class |
JdbcOutputFormat
OutputFormat to write Rows into a JDBC database.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractJdbcOutputFormat<T>
Base jdbc outputFormat.
|
class |
JdbcBatchingOutputFormat<In,JdbcIn,JdbcExec extends JdbcBatchStatementExecutor<JdbcIn>>
A JDBC outputFormat that supports batching records before writing records to database.
|
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. |
Modifier and Type | Method and Description |
---|---|
Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>> |
InputOutputFormatContainer.getOutputFormats() |
Map<OperatorID,UserCodeWrapper<? extends OutputFormat<?>>> |
InputOutputFormatContainer.FormatUserCodeTable.getOutputFormats() |
<IT> org.apache.commons.lang3.tuple.Pair<OperatorID,OutputFormat<IT>> |
InputOutputFormatContainer.getUniqueOutputFormat() |
Modifier and Type | Method and Description |
---|---|
InputOutputFormatContainer |
InputOutputFormatContainer.addOutputFormat(OperatorID operatorId,
OutputFormat<?> outputFormat) |
Modifier and Type | Method and Description |
---|---|
InputOutputFormatContainer |
InputOutputFormatContainer.addOutputFormat(OperatorID operatorId,
UserCodeWrapper<? extends OutputFormat<?>> wrapper) |
void |
InputOutputFormatContainer.FormatUserCodeTable.addOutputFormat(OperatorID operatorId,
UserCodeWrapper<? extends OutputFormat<?>> wrapper) |
Modifier and Type | Class and Description |
---|---|
class |
SavepointOutputFormat
An output format to serialize
CheckpointMetadata metadata to distributed storage. |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.writeUsingOutputFormat(OutputFormat<T> format)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
Modifier and Type | Method and Description |
---|---|
OutputFormat<IN> |
OutputFormatSinkFunction.getFormat()
Deprecated.
|
Constructor and Description |
---|
OutputFormatSinkFunction(OutputFormat<IN> format)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
OutputFormat<?> |
StreamNode.getOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setOutputFormat(Integer vertexID,
OutputFormat<?> outputFormat) |
void |
StreamNode.setOutputFormat(OutputFormat<?> outputFormat) |
Modifier and Type | Method and Description |
---|---|
OutputFormat<IN> |
SimpleOutputFormatOperatorFactory.getOutputFormat() |
OutputFormat<IN> |
OutputFormatOperatorFactory.getOutputFormat() |
Modifier and Type | Method and Description |
---|---|
OutputFormat<Row> |
CollectBatchTableSink.getOutputFormat() |
Modifier and Type | Method and Description |
---|---|
OutputFormat<RowData> |
OutputFormatProvider.createOutputFormat()
Creates an
OutputFormat instance. |
Modifier and Type | Method and Description |
---|---|
static OutputFormatProvider |
OutputFormatProvider.of(OutputFormat<RowData> outputFormat)
Helper method for creating a static provider.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemOutputFormat<T>
File system
OutputFormat for batch job. |
Modifier and Type | Method and Description |
---|---|
OutputFormat<T> |
OutputFormatFactory.createOutputFormat(Path path)
Create a
OutputFormat with specific path. |
Modifier and Type | Method and Description |
---|---|
abstract OutputFormat<T> |
OutputFormatTableSink.getOutputFormat()
Returns an
OutputFormat for writing the data of the table. |
Modifier and Type | Class and Description |
---|---|
class |
LoggerOutputFormat
A basic output format that logs all records at level INFO.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.