org.apache.beam.sdk.io

Class TFRecordReadSchemaTransformConfiguration

java.lang.Object

org.apache.beam.sdk.io.TFRecordReadSchemaTransformConfiguration

All Implemented Interfaces:

java.io.Serializable

@DefaultSchema(value=AutoValueSchema.class)
public abstract class TFRecordReadSchemaTransformConfiguration
extends java.lang.Object
implements java.io.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 and Description
static class	TFRecordReadSchemaTransformConfiguration.Builder Builder for TFRecordReadSchemaTransformConfiguration.

Constructor Summary

Constructors

Constructor and Description
TFRecordReadSchemaTransformConfiguration()

Method Summary

Modifier and Type	Method and Description
static TFRecordReadSchemaTransformConfiguration.Builder	builder() Instantiates a TFRecordReadSchemaTransformConfiguration.Builder instance.
abstract java.lang.String	getCompression()
abstract ErrorHandling	getErrorHandling()
abstract java.lang.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 Detail

TFRecordReadSchemaTransformConfiguration

public TFRecordReadSchemaTransformConfiguration()

Method Detail

validate

public void validate()

builder

public static TFRecordReadSchemaTransformConfiguration.Builder builder()

Instantiates a TFRecordReadSchemaTransformConfiguration.Builder instance.

getValidate

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

getCompression

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

getFilePattern

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

getErrorHandling

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