org.apache.beam.sdk.managed

Class ManagedTransformConstants

java.lang.Object

org.apache.beam.sdk.managed.ManagedTransformConstants

public class ManagedTransformConstants
extends java.lang.Object

This class contains constants for supported managed transforms, including:

• Identifiers of supported transforms
• Configuration parameter renaming

Configuration parameter names exposed via Managed interface may differ from the parameter names in the underlying SchemaTransform implementation.

Any naming differences are laid out in MAPPINGS to update the configuration object before it's used to build the underlying transform.

Mappings don't need to include ALL underlying parameter names, as we may not want to expose every single parameter through the Managed interface.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ICEBERG_READ
static java.lang.String	ICEBERG_WRITE
static java.lang.String	INPUT
static java.lang.String	KAFKA_READ
static java.lang.String	KAFKA_WRITE
static java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>>	MAPPINGS

Constructor Summary

Constructors

Constructor and Description
ManagedTransformConstants()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INPUT

public static final java.lang.String INPUT

See Also:

Constant Field Values

ICEBERG_READ

public static final java.lang.String ICEBERG_READ

See Also:

Constant Field Values

ICEBERG_WRITE

public static final java.lang.String ICEBERG_WRITE

See Also:

Constant Field Values

KAFKA_READ

public static final java.lang.String KAFKA_READ

See Also:

Constant Field Values

KAFKA_WRITE

public static final java.lang.String KAFKA_WRITE

See Also:

Constant Field Values

MAPPINGS

public static final java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.String>> MAPPINGS

Constructor Detail

ManagedTransformConstants

public ManagedTransformConstants()