public class NativeTransforms
extends java.lang.Object
Warning:Usage of native transforms within pipelines will prevent users from migrating between runners as there is no expectation that the transform will be understood by all runners. Note that for some use cases this can be a way to test out a new type of transform on a limited set of runners and promote its adoption as a primitive within the Apache Beam model.
Note that users are required to ensure that translation and execution for the native transform is supported by their runner.
Automatic registration occurs by creating a ServiceLoader
entry and a concrete
implementation of the NativeTransforms.IsNativeTransform
interface. It is optional but recommended to use
one of the many build time tools such as AutoService
to generate the necessary META-INF
files automatically.
Modifier and Type | Class and Description |
---|---|
static interface |
NativeTransforms.IsNativeTransform
A predicate which returns true if and only if the transform is a native transform.
|
Constructor and Description |
---|
NativeTransforms() |
Modifier and Type | Method and Description |
---|---|
static boolean |
isNative(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform pTransform)
Returns true if an only if the Runner understands this transform and can handle it directly.
|