public static interface PTransforms.TransformPayloadTranslator<T extends PTransform<?,?>>
PTransform application and produces the appropriate
FunctionSpec for a distinguished or primitive transform within the Beam runner API.| Modifier and Type | Method and Description |
|---|---|
RunnerApi.FunctionSpec |
translate(AppliedPTransform<?,?,T> transform,
org.apache.beam.runners.core.construction.SdkComponents components) |
RunnerApi.FunctionSpec translate(AppliedPTransform<?,?,T> transform, org.apache.beam.runners.core.construction.SdkComponents components)
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.