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

async-operations.mddocs/

Asynchronous I/O Operations

High-performance asynchronous I/O operations for external system integration with configurable parallelism, timeouts, and result ordering.

Imports

import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.api.scala.async.{AsyncFunction, AsyncCollector}
import java.util.concurrent.TimeUnit

AsyncDataStream Operations

object AsyncDataStream {
  def unorderedWait[IN, OUT: TypeInformation](
    input: DataStream[IN],
    asyncFunction: AsyncFunction[IN, OUT],
    timeout: Long,
    timeUnit: TimeUnit
  ): DataStream[OUT]
  
  def orderedWait[IN, OUT: TypeInformation](
    input: DataStream[IN],
    asyncFunction: AsyncFunction[IN, OUT],
    timeout: Long,
    timeUnit: TimeUnit
  ): DataStream[OUT]
}

AsyncFunction Interface

trait AsyncFunction[IN, OUT] {
  def asyncInvoke(input: IN, collector: AsyncCollector[OUT]): Unit
}

trait AsyncCollector[OUT] {
  def collect(result: Iterable[OUT]): Unit
  def collect(throwable: Throwable): Unit
}

Enables non-blocking I/O operations for database lookups, REST API calls, and other external system interactions.

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