Package org.apache.beam.sdk.expansion.service

package org.apache.beam.sdk.expansion.service

Classes used to expand cross-language transforms.

Related Packages

Package	Description
org.apache.beam.sdk.expansion	Contains classes needed to expose transforms to other SDKs.

Class	Description
Dependency
ExpansionServer	A gRPC Server for an ExpansionService.
ExpansionService	A service that allows pipeline expand transforms from a remote SDK.
ExpansionService.ExpansionServiceRegistrar	A registrar that creates TransformProvider instances from RunnerApi.FunctionSpecs.
ExpansionService.ExternalTransformRegistrarLoader	Exposes Java transforms via ExternalTransformRegistrar.
ExpansionServiceConfig
ExpansionServiceOptions	Options used to configure the ExpansionService.
ExpansionServiceOptions.ExpansionServiceConfigFactory	Loads the ExpansionService config.
ExpansionServiceOptions.JavaClassLookupAllowListFactory	Loads the allow list from ExpansionServiceOptions.getJavaClassLookupAllowlistFile(), defaulting to an empty JavaClassLookupTransformProvider.AllowList.
ExpansionServiceSchemaTransformProvider
MultiLanguageBuilderMethod
MultiLanguageConstructorMethod
TransformProvider<InputT extends PInput,OutputT extends POutput>	Provides a mapping of RunnerApi.FunctionSpec to a PTransform, together with mappings of its inputs and outputs to maps of PCollections.
WindowIntoTransformProvider	An implementation of TypedSchemaTransformProvider for WindowInto.
WindowIntoTransformProvider.Configuration
WindowIntoTransformProvider.Configuration.Builder