CtrlK
BlogDocsLog inGet started
Tessl Logo

tessl/maven-org-apache-flink--flink-streaming-scala-2-10

Apache Flink Scala API for DataStream processing with type-safe, functional programming constructs for building streaming data processing applications.

Overview
Eval results
Files

output-operations.mddocs/

Output Operations and Sinks

Comprehensive output functionality for writing stream results to various destinations including files, databases, message queues, and custom sinks.

Built-in Sinks

class DataStream[T] {
  def print(): DataStreamSink[T]
  def printToErr(): DataStreamSink[T]
  def writeAsText(path: String): DataStreamSink[T]
  def writeAsCsv(path: String): DataStreamSink[T]
  def writeUsingOutputFormat(format: OutputFormat[T]): DataStreamSink[T]
  def writeToSocket(hostname: String, port: Integer, schema: SerializationSchema[T]): DataStreamSink[T]
}

Custom Sinks

class DataStream[T] {
  def addSink(sinkFunction: SinkFunction[T]): DataStreamSink[T]
  def addSink(fun: T => Unit): DataStreamSink[T]
}

Output operations provide the final step in stream processing pipelines, writing results to external systems for storage, visualization, or further processing.

Install with Tessl CLI

npx tessl i tessl/maven-org-apache-flink--flink-streaming-scala-2-10

docs

async-operations.md

data-sources.md

function-interfaces.md

index.md

keyed-streams.md

output-operations.md

scala-extensions.md

stream-composition.md

stream-environment.md

stream-partitioning.md

stream-transformations.md

window-operations.md

windowing.md

tile.json