Modifier and Type | Method and Description |
---|---|
static DataStreamSink<?> |
StreamingSink.sink(ProviderContext providerContext,
DataStream<PartitionCommitInfo> writer,
Path locationPath,
ObjectIdentifier identifier,
List<String> partitionKeys,
TableMetaStoreFactory msFactory,
FileSystemFactory fsFactory,
Configuration options)
Create a sink from file writer.
|
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
KeyedStream.addSink(SinkFunction<T> sinkFunction) |
DataStreamSink<T> |
DataStream.addSink(SinkFunction<T> sinkFunction)
Adds the given sink to this DataStream.
|
DataStreamSink<T> |
DataStreamSink.disableChaining()
Turns off chaining for this operator so thread co-location will not be used as an
optimization.
|
static <T> DataStreamSink<T> |
DataStreamSink.forSink(DataStream<T> inputStream,
Sink<T> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
static <T> DataStreamSink<T> |
DataStreamSink.forSinkV1(DataStream<T> inputStream,
Sink<T,?,?,?> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes) |
DataStreamSink<T> |
DataStreamSink.name(String name)
Sets the name of this sink.
|
DataStreamSink<T> |
DataStream.print()
Writes a DataStream to the standard output stream (stdout).
|
DataStreamSink<T> |
DataStream.print(String sinkIdentifier)
Writes a DataStream to the standard output stream (stdout).
|
DataStreamSink<T> |
DataStream.printToErr()
Writes a DataStream to the standard error stream (stderr).
|
DataStreamSink<T> |
DataStream.printToErr(String sinkIdentifier)
Writes a DataStream to the standard error stream (stderr).
|
DataStreamSink<T> |
DataStreamSink.setDescription(String description)
Sets the description for this sink.
|
DataStreamSink<T> |
DataStreamSink.setParallelism(int parallelism)
Sets the parallelism for this sink.
|
DataStreamSink<T> |
DataStreamSink.setUidHash(String uidHash)
Sets an user provided hash for this operator.
|
DataStreamSink<T> |
DataStream.sinkTo(Sink<T,?,?,?> sink)
Adds the given
Sink to this DataStream. |
DataStreamSink<T> |
DataStream.sinkTo(Sink<T,?,?,?> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes)
Adds the given
Sink to this DataStream. |
DataStreamSink<T> |
DataStream.sinkTo(Sink<T> sink)
Adds the given
Sink to this DataStream. |
DataStreamSink<T> |
DataStream.sinkTo(Sink<T> sink,
CustomSinkOperatorUidHashes customSinkOperatorUidHashes)
Adds the given
Sink to this DataStream. |
DataStreamSink<T> |
DataStreamSink.slotSharingGroup(SlotSharingGroup slotSharingGroup)
Sets the slot sharing group of this operation.
|
DataStreamSink<T> |
DataStreamSink.slotSharingGroup(String slotSharingGroup)
Sets the slot sharing group of this operation.
|
DataStreamSink<T> |
DataStreamSink.uid(String uid)
Sets an ID for this operator.
|
DataStreamSink<T> |
DataStream.writeAsCsv(String path)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
<X extends Tuple> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode,
String rowDelimiter,
String fieldDelimiter)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
DataStreamSink<T> |
DataStream.writeAsText(String path)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
DataStreamSink<T> |
DataStream.writeAsText(String path,
FileSystem.WriteMode writeMode)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
DataStreamSink<T> |
DataStream.writeToSocket(String hostName,
int port,
SerializationSchema<T> schema)
Writes the DataStream to a socket as a byte array.
|
DataStreamSink<T> |
DataStream.writeUsingOutputFormat(OutputFormat<T> format)
Deprecated.
Please use the
StreamingFileSink explicitly
using the DataStream.addSink(SinkFunction) method. |
Modifier and Type | Class and Description |
---|---|
class |
CollectStreamSink<T>
A
DataStreamSink which is used to collect results of a data stream. |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<?> |
CassandraAppendTableSink.consumeDataStream(DataStream<Row> dataStream) |
Modifier and Type | Method and Description |
---|---|
default DataStreamSink<?> |
DataStreamSinkProvider.consumeDataStream(DataStream<RowData> dataStream)
Deprecated.
Use
DataStreamSinkProvider.consumeDataStream(ProviderContext, DataStream)
and correctly set a unique identifier for each data stream transformation. |
default DataStreamSink<?> |
DataStreamSinkProvider.consumeDataStream(ProviderContext providerContext,
DataStream<RowData> dataStream)
Consumes the given Java
DataStream and returns the sink transformation DataStreamSink . |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<?> |
CsvTableSink.consumeDataStream(DataStream<Row> dataStream)
Deprecated.
|
DataStreamSink<T> |
OutputFormatTableSink.consumeDataStream(DataStream<T> dataStream)
Deprecated.
|
DataStreamSink<?> |
StreamTableSink.consumeDataStream(DataStream<T> dataStream)
Deprecated.
Consumes the DataStream and return the sink transformation
DataStreamSink . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.