Package org.apache.beam.sdk.io

Class TFRecordReadSchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.TFRecordReadSchemaTransformConfiguration

All Implemented Interfaces:

Serializable

@DefaultSchema(AutoValueSchema.class)
public abstract class TFRecordReadSchemaTransformConfiguration
extends Object
implements Serializable

Configuration for reading from TFRecord.

This class is meant to be used with TFRecordReadSchemaTransformProvider.

Internal only: This class is actively being worked on, and it will likely change. We provide no backwards compatibility guarantees, and it should not be implemented outside the Beam repository.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TFRecordReadSchemaTransformConfiguration.Builder	Builder for TFRecordReadSchemaTransformConfiguration.

Constructor Summary

Constructors

Constructor	Description
TFRecordReadSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method	Description
static TFRecordReadSchemaTransformConfiguration.Builder	builder()	Instantiates a TFRecordReadSchemaTransformConfiguration.Builder instance.
abstract String	getCompression()
abstract ErrorHandling	getErrorHandling()
abstract String	getFilePattern()
abstract boolean	getValidate()
void	validate()

Methods inherited from class java.lang.Object

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

Constructor Details

TFRecordReadSchemaTransformConfiguration

public TFRecordReadSchemaTransformConfiguration()

Method Details

validate

public void validate()

builder

public static TFRecordReadSchemaTransformConfiguration.Builder builder()

Instantiates a TFRecordReadSchemaTransformConfiguration.Builder instance.

getValidate

@SchemaFieldDescription("Validate file pattern.")
public abstract boolean getValidate()

getCompression

@SchemaFieldDescription("Decompression type to use when reading input files.")
public abstract String getCompression()

getFilePattern

@SchemaFieldDescription("Filename or file pattern used to find input files.")
public abstract String getFilePattern()

getErrorHandling

@SchemaFieldDescription("This option specifies whether and where to output unwritable rows.")
@Nullable
public abstract ErrorHandling getErrorHandling()