Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.connectors.kafka |
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.
|
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.printToErr()
Writes a DataStream to the standard output stream (stderr).
|
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> |
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)
Writes a DataStream to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode)
Writes a DataStream to the file specified by the path parameter.
|
<X extends Tuple> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode,
String rowDelimiter,
String fieldDelimiter)
Writes a DataStream to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsText(String path)
Writes a DataStream to the file specified by path in text format.
|
DataStreamSink<T> |
DataStream.writeAsText(String path,
FileSystem.WriteMode writeMode)
Writes a DataStream to the file specified by path in text format.
|
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)
Writes the dataStream into an output, described by an OutputFormat.
|
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.addSink(scala.Function1<T,scala.runtime.BoxedUnit> fun)
Adds the given sink to this DataStream.
|
DataStreamSink<T> |
DataStream.addSink(SinkFunction<T> sinkFunction)
Adds the given sink to this DataStream.
|
DataStreamSink<T> |
DataStream.print()
Writes a DataStream to the standard output stream (stdout).
|
DataStreamSink<T> |
DataStream.printToErr()
Writes a DataStream to the standard output stream (stderr).
|
DataStreamSink<T> |
DataStream.writeAsCsv(String path)
Writes the DataStream in CSV format to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode)
Writes the DataStream in CSV format to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsCsv(String path,
FileSystem.WriteMode writeMode,
String rowDelimiter,
String fieldDelimiter)
Writes the DataStream in CSV format to the file specified by the path parameter.
|
DataStreamSink<T> |
DataStream.writeAsText(String path)
Writes a DataStream to the file specified by path in text format.
|
DataStreamSink<T> |
DataStream.writeAsText(String path,
FileSystem.WriteMode writeMode)
Writes a DataStream to the file specified by path in text format.
|
DataStreamSink<T> |
DataStream.writeToSocket(String hostname,
Integer port,
SerializationSchema<T> schema)
Writes the DataStream to a socket as a byte array.
|
DataStreamSink<T> |
DataStream.writeUsingOutputFormat(OutputFormat<T> format)
Writes a DataStream using the given
OutputFormat . |
Modifier and Type | Class and Description |
---|---|
static class |
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration<T>
Configuration object returned by the writeToKafkaWithTimestamps() call.
|
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration.disableChaining() |
DataStreamSink<T> |
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration.name(String name) |
DataStreamSink<T> |
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration.setParallelism(int parallelism) |
DataStreamSink<T> |
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration.setUidHash(String uidHash) |
DataStreamSink<T> |
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration.slotSharingGroup(String slotSharingGroup) |
DataStreamSink<T> |
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration.uid(String uid) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.