or run

npx @tessl/cli init

Version

Tile

Overview

Evals

Files

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

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.