@AutoService(value=org.apache.beam.sdk.util.construction.TransformPayloadTranslatorRegistrar.class)
public static class PubSubPayloadTranslation.ReadRegistrar
extends java.lang.Object
implements org.apache.beam.sdk.util.construction.TransformPayloadTranslatorRegistrar
Constructor and Description |
---|
ReadRegistrar() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<? extends java.lang.Class<? extends PTransform>,? extends org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator> |
getTransformPayloadTranslators() |
public java.util.Map<? extends java.lang.Class<? extends PTransform>,? extends org.apache.beam.sdk.util.construction.PTransformTranslation.TransformPayloadTranslator> getTransformPayloadTranslators()
getTransformPayloadTranslators
in interface org.apache.beam.sdk.util.construction.TransformPayloadTranslatorRegistrar