See: Description
| Interface | Description |
|---|---|
| ExpansionService.ExpansionServiceRegistrar |
A registrar that creates
TransformProvider instances from RunnerApi.FunctionSpecs. |
| ExpansionServiceOptions |
Options used to configure the
ExpansionService. |
| 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. |
| Class | Description |
|---|---|
| Dependency | |
| ExpansionServer |
A
gRPC Server for an ExpansionService. |
| ExpansionService |
A service that allows pipeline expand transforms from a remote SDK.
|
| ExpansionService.ExternalTransformRegistrarLoader |
Exposes Java transforms via
ExternalTransformRegistrar. |
| ExpansionServiceConfig | |
| ExpansionServiceOptions.ExpansionServiceConfigFactory |
Loads the ExpansionService config.
|
| ExpansionServiceOptions.JavaClassLookupAllowListFactory |
Loads the allow list from
ExpansionServiceOptions.getJavaClassLookupAllowlistFile(), defaulting to an empty
JavaClassLookupTransformProvider.AllowList. |
| ExpansionServiceSchemaTransformProvider | |
| WindowIntoTransformProvider |
An implementation of
TypedSchemaTransformProvider for WindowInto. |
| WindowIntoTransformProvider.Configuration | |
| WindowIntoTransformProvider.Configuration.Builder |
| Annotation Type | Description |
|---|---|
| MultiLanguageBuilderMethod | |
| MultiLanguageConstructorMethod |