Skip navigation links

Back to Flink Website

Package org.apache.flink.streaming.runtime.tasks

This package contains classes that realize streaming tasks.

See: Description

Package org.apache.flink.streaming.runtime.tasks Description

This package contains classes that realize streaming tasks. These tasks are executable stream consumers and producers that are scheduled by the distributed dataflow runtime. Each task occupies one execution slot and is run with by an executing thread.

The tasks merely set up the distributed stream coordination and the checkpointing. Internally, the tasks create one or more operators, perform the stream transformations.

Skip navigation links

Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.