public class PTransformTranslation
extends java.lang.Object
PTransforms
to Runner API protocol
buffers
.Modifier and Type | Class and Description |
---|---|
static class |
PTransformTranslation.RawPTransform<InputT extends PInput,OutputT extends POutput>
A
PTransform that indicates its URN and payload directly. |
static interface |
PTransformTranslation.TransformPayloadTranslator<T extends PTransform<?,?>>
A translator between a Java-based
PTransform and a protobuf payload for that transform. |
static interface |
PTransformTranslation.TransformTranslator<T extends PTransform<?,?>>
A translator between a Java-based
PTransform and a protobuf for that transform. |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ASSIGN_WINDOWS_TRANSFORM_URN |
static java.lang.String |
COMBINE_GLOBALLY_TRANSFORM_URN |
static java.lang.String |
COMBINE_GROUPED_VALUES_TRANSFORM_URN |
static java.lang.String |
COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS_TRANSFORM_URN |
static java.lang.String |
COMBINE_PER_KEY_EXTRACT_OUTPUTS_TRANSFORM_URN |
static java.lang.String |
COMBINE_PER_KEY_MERGE_ACCUMULATORS_TRANSFORM_URN |
static java.lang.String |
COMBINE_PER_KEY_PRECOMBINE_TRANSFORM_URN |
static java.lang.String |
COMBINE_PER_KEY_TRANSFORM_URN |
static java.lang.String |
CONFIG_ROW_KEY |
static java.lang.String |
CONFIG_ROW_SCHEMA_KEY |
static java.lang.String |
CREATE_TRANSFORM_URN |
static java.lang.String |
CREATE_VIEW_TRANSFORM_URN
Deprecated.
runners should move away from translating `CreatePCollectionView` and treat this as
part of the translation for a `ParDo` side input.
|
static java.lang.String |
FLATTEN_TRANSFORM_URN |
static java.lang.String |
GROUP_BY_KEY_TRANSFORM_URN |
static java.lang.String |
GROUP_INTO_BATCHES_URN |
static java.lang.String |
GROUP_INTO_BATCHES_WITH_SHARDED_KEY_URN |
static java.lang.String |
IMPULSE_TRANSFORM_URN |
static java.lang.String |
MAP_WINDOWS_TRANSFORM_URN |
static java.lang.String |
MERGE_WINDOWS_TRANSFORM_URN |
static java.lang.String |
PAR_DO_TRANSFORM_URN |
static java.lang.String |
PUBSUB_READ |
static java.lang.String |
PUBSUB_WRITE |
static java.lang.String |
PUBSUB_WRITE_DYNAMIC |
static java.lang.String |
READ_TRANSFORM_URN
Deprecated.
SDKs should move away from creating `Read` transforms and migrate to using Impulse
+ SplittableDoFns.
|
static java.lang.String |
RESHUFFLE_URN |
static org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableSet<java.lang.String> |
RUNNER_IMPLEMENTED_TRANSFORMS |
static java.lang.String |
SPLITTABLE_PAIR_WITH_RESTRICTION_URN |
static java.lang.String |
SPLITTABLE_PROCESS_ELEMENTS_URN
Deprecated.
runners should move away from using `SplittableProcessElements` and prefer to
internalize any necessary SplittableDoFn expansion.
|
static java.lang.String |
SPLITTABLE_PROCESS_KEYED_URN
Deprecated.
runners should move away from using `SplittableProcessKeyedElements` and prefer to
internalize any necessary SplittableDoFn expansion.
|
static java.lang.String |
SPLITTABLE_PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS_URN |
static java.lang.String |
SPLITTABLE_SPLIT_AND_SIZE_RESTRICTIONS_URN |
static java.lang.String |
SPLITTABLE_TRUNCATE_SIZED_RESTRICTION_URN |
static java.lang.String |
TEST_STREAM_TRANSFORM_URN |
static java.lang.String |
TO_STRING_TRANSFORM_URN |
static java.lang.String |
WRITE_FILES_TRANSFORM_URN |
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.Class<? extends PTransform>,PTransformTranslation.TransformPayloadTranslator> |
getKnownPayloadTranslators() |
static java.lang.String |
urnForTransform(PTransform<?,?> transform)
Returns the URN for the transform if it is known, otherwise throws.
|
static @Nullable java.lang.String |
urnForTransformOrNull(PTransform<?,?> transform)
Returns the URN for the transform if it is known, otherwise
null . |
static @Nullable java.lang.String |
urnForTransformOrNull(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform transform)
Returns the URN for the transform if it is known, otherwise
null . |
public static final java.lang.String CREATE_TRANSFORM_URN
public static final java.lang.String PAR_DO_TRANSFORM_URN
public static final java.lang.String FLATTEN_TRANSFORM_URN
public static final java.lang.String GROUP_BY_KEY_TRANSFORM_URN
public static final java.lang.String IMPULSE_TRANSFORM_URN
public static final java.lang.String ASSIGN_WINDOWS_TRANSFORM_URN
public static final java.lang.String TEST_STREAM_TRANSFORM_URN
public static final java.lang.String MAP_WINDOWS_TRANSFORM_URN
public static final java.lang.String MERGE_WINDOWS_TRANSFORM_URN
public static final java.lang.String TO_STRING_TRANSFORM_URN
public static final org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableSet<java.lang.String> RUNNER_IMPLEMENTED_TRANSFORMS
public static final java.lang.String CONFIG_ROW_KEY
public static final java.lang.String CONFIG_ROW_SCHEMA_KEY
@Deprecated public static final java.lang.String READ_TRANSFORM_URN
@Deprecated public static final java.lang.String CREATE_VIEW_TRANSFORM_URN
public static final java.lang.String COMBINE_PER_KEY_TRANSFORM_URN
public static final java.lang.String COMBINE_GLOBALLY_TRANSFORM_URN
public static final java.lang.String RESHUFFLE_URN
public static final java.lang.String WRITE_FILES_TRANSFORM_URN
public static final java.lang.String GROUP_INTO_BATCHES_WITH_SHARDED_KEY_URN
public static final java.lang.String PUBSUB_READ
public static final java.lang.String PUBSUB_WRITE
public static final java.lang.String PUBSUB_WRITE_DYNAMIC
public static final java.lang.String COMBINE_PER_KEY_PRECOMBINE_TRANSFORM_URN
public static final java.lang.String COMBINE_PER_KEY_MERGE_ACCUMULATORS_TRANSFORM_URN
public static final java.lang.String COMBINE_PER_KEY_EXTRACT_OUTPUTS_TRANSFORM_URN
public static final java.lang.String COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS_TRANSFORM_URN
public static final java.lang.String COMBINE_GROUPED_VALUES_TRANSFORM_URN
public static final java.lang.String SPLITTABLE_PAIR_WITH_RESTRICTION_URN
public static final java.lang.String SPLITTABLE_TRUNCATE_SIZED_RESTRICTION_URN
@Deprecated public static final java.lang.String SPLITTABLE_PROCESS_KEYED_URN
@Deprecated public static final java.lang.String SPLITTABLE_PROCESS_ELEMENTS_URN
public static final java.lang.String SPLITTABLE_SPLIT_AND_SIZE_RESTRICTIONS_URN
public static final java.lang.String SPLITTABLE_PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS_URN
public static final java.lang.String GROUP_INTO_BATCHES_URN
public static @Nullable java.lang.String urnForTransformOrNull(PTransform<?,?> transform)
null
.public static java.lang.String urnForTransform(PTransform<?,?> transform)
public static @Nullable java.lang.String urnForTransformOrNull(org.apache.beam.model.pipeline.v1.RunnerApi.PTransform transform)
null
.@Internal public static java.util.Map<java.lang.Class<? extends PTransform>,PTransformTranslation.TransformPayloadTranslator> getKnownPayloadTranslators()