org.apache.beam.sdk |
Provides a simple, powerful model for building both batch and streaming parallel data processing
Pipeline s.
|
org.apache.beam.sdk.annotations |
Defines annotations used across the SDK.
|
org.apache.beam.sdk.coders |
Defines Coders to specify how data is encoded to and
decoded from byte strings.
|
org.apache.beam.sdk.expansion |
Contains classes needed to expose transforms to other SDKs.
|
org.apache.beam.sdk.function |
Java 8 functional interface extensions.
|
org.apache.beam.sdk.harness |
Utilities for configuring worker environment.
|
org.apache.beam.sdk.io |
Defines transforms for reading and writing common storage formats, including AvroIO , and TextIO .
|
org.apache.beam.sdk.io.fs |
Apache Beam FileSystem interfaces and their default implementations.
|
org.apache.beam.sdk.io.range |
Provides thread-safe helpers for implementing dynamic work rebalancing in position-based bounded
sources.
|
org.apache.beam.sdk.metrics |
Metrics allow exporting information about the execution of a pipeline.
|
org.apache.beam.sdk.options |
|
org.apache.beam.sdk.runners |
For internal use only; no backwards compatibility guarantees.
|
org.apache.beam.sdk.schemas |
Defines Schema and other classes for representing schema'd
data in a Pipeline .
|
org.apache.beam.sdk.schemas.annotations |
Defines Schema and other classes for representing schema'd
data in a Pipeline .
|
org.apache.beam.sdk.schemas.io |
Provides abstractions for schema-aware IOs.
|
org.apache.beam.sdk.schemas.io.payloads |
Provides abstractions for schema-aware IOs.
|
org.apache.beam.sdk.schemas.logicaltypes |
A set of common LogicalTypes for use with schemas.
|
org.apache.beam.sdk.schemas.parser |
Defines utilities for deailing with schemas.
|
org.apache.beam.sdk.schemas.parser.generated |
Defines utilities for deailing with schemas.
|
org.apache.beam.sdk.schemas.transforms |
Defines transforms that work on PCollections with schemas..
|
org.apache.beam.sdk.schemas.utils |
Defines utilities for deailing with schemas.
|
org.apache.beam.sdk.state |
Classes and interfaces for interacting with state.
|
org.apache.beam.sdk.testing |
Defines utilities for unit testing Apache Beam pipelines.
|
org.apache.beam.sdk.transforms |
Defines PTransform s for transforming data in a pipeline.
|
org.apache.beam.sdk.transforms.display |
|
org.apache.beam.sdk.transforms.join |
Defines the CoGroupByKey transform for joining
multiple PCollections.
|
org.apache.beam.sdk.transforms.reflect |
For internal use only; no backwards-compatibility guarantees.
|
org.apache.beam.sdk.transforms.resourcehints |
|
org.apache.beam.sdk.transforms.splittabledofn |
|
org.apache.beam.sdk.transforms.windowing |
Defines the Window transform for dividing the
elements in a PCollection into windows, and the Trigger for controlling when those elements are output.
|
org.apache.beam.sdk.util |
For internal use only; no backwards compatibility guarantees.
|
org.apache.beam.sdk.util.common |
Defines utilities shared by multiple PipelineRunner implementations.
|
org.apache.beam.sdk.values |
|