Package org.apache.beam.sdk.fn

package org.apache.beam.sdk.fn

The top level package for the Fn Execution Java libraries.

Related Packages

Package	Description
org.apache.beam.sdk	Provides a simple, powerful model for building both batch and streaming parallel data processing Pipelines.
org.apache.beam.sdk.fn.channel	gRPC channel management.
org.apache.beam.sdk.fn.data	Classes to interact with the portability framework data plane.
org.apache.beam.sdk.fn.server	gPRC server factory.
org.apache.beam.sdk.fn.splittabledofn	Defines utilities related to executing splittable DoFn.
org.apache.beam.sdk.fn.stream	gRPC stream management.
org.apache.beam.sdk.fn.test	Utilities for testing use of this package.
org.apache.beam.sdk.fn.windowing	Common utilities related to windowing during execution of a pipeline.

Class	Description
CancellableQueue<T extends @NonNull Object>	A simplified ThreadSafe blocking queue that can be cancelled freeing any blocked Threads and preventing future Threads from blocking.
IdGenerator	A generator of unique IDs.
IdGenerators	Common IdGenerator implementations.
JvmInitializers	Helpers for executing JvmInitializer implementations.