Package org.apache.beam.sdk.io.iceberg

Enum Class SchemaEvolutionConfig.IncompatibleSchemaHandling

java.lang.Object

java.lang.Enum<SchemaEvolutionConfig.IncompatibleSchemaHandling>

org.apache.beam.sdk.io.iceberg.SchemaEvolutionConfig.IncompatibleSchemaHandling

All Implemented Interfaces:

Serializable, Comparable<SchemaEvolutionConfig.IncompatibleSchemaHandling>, Constable

Enclosing class:

SchemaEvolutionConfig

public static enum SchemaEvolutionConfig.IncompatibleSchemaHandling
extends Enum<SchemaEvolutionConfig.IncompatibleSchemaHandling>

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Enum

Enum.EnumDesc<E extends Enum<E>>

Enum Constant Summary

Enum Constants

Enum Constant	Description
FAIL_PIPELINE	Fail the pipeline before committing any schema change, with a message listing every incompatible schema, its reason and file count.
ROUTE_TO_ERRORS	Skip the incompatible schema, commit the rest, and route its files to the error output with the specific reason.

Method Summary

Modifier and Type	Method	Description
static SchemaEvolutionConfig.IncompatibleSchemaHandling	valueOf(String name)	Returns the enum constant of this class with the specified name.
static SchemaEvolutionConfig.IncompatibleSchemaHandling[]	values()	Returns an array containing the constants of this enum class, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, describeConstable, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Details

FAIL_PIPELINE

public static final SchemaEvolutionConfig.IncompatibleSchemaHandling FAIL_PIPELINE

Fail the pipeline before committing any schema change, with a message listing every incompatible schema, its reason and file count. The batch default, and batch only: in streaming a failing window's commit would be retried forever and hold every later window, so AddFiles rejects this setting for unbounded input.

ROUTE_TO_ERRORS

public static final SchemaEvolutionConfig.IncompatibleSchemaHandling ROUTE_TO_ERRORS

Skip the incompatible schema, commit the rest, and route its files to the error output with the specific reason. The streaming default.

Method Details

values

public static SchemaEvolutionConfig.IncompatibleSchemaHandling[] values()

Returns an array containing the constants of this enum class, in the order they are declared.

Returns:

an array containing the constants of this enum class, in the order they are declared

valueOf

public static SchemaEvolutionConfig.IncompatibleSchemaHandling valueOf(String name)

Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum class has no constant with the specified name

NullPointerException - if the argument is null