org.apache.beam.sdk.io

Class TFRecordWriteSchemaTransformConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.TFRecordWriteSchemaTransformConfiguration.Builder

Enclosing class:

TFRecordWriteSchemaTransformConfiguration

public abstract static class TFRecordWriteSchemaTransformConfiguration.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract TFRecordWriteSchemaTransformConfiguration	build() Builds the TFRecordWriteSchemaTransformConfiguration configuration.
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setCompression(java.lang.String value)
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setErrorHandling(ErrorHandling errorHandling)
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setFilenameSuffix(java.lang.String value)
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setMaxNumWritersPerBundle(@Nullable java.lang.Integer maxNumWritersPerBundle)
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setNoSpilling(java.lang.Boolean value)
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setNumShards(int value)
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setOutputPrefix(java.lang.String value)
abstract TFRecordWriteSchemaTransformConfiguration.Builder	setShardTemplate(java.lang.String value)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setOutputPrefix

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setOutputPrefix(java.lang.String value)

setShardTemplate

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setShardTemplate(java.lang.String value)

setFilenameSuffix

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setFilenameSuffix(java.lang.String value)

setNumShards

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setNumShards(int value)

setCompression

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setCompression(java.lang.String value)

setNoSpilling

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setNoSpilling(java.lang.Boolean value)

setMaxNumWritersPerBundle

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setMaxNumWritersPerBundle(@Nullable java.lang.Integer maxNumWritersPerBundle)

setErrorHandling

public abstract TFRecordWriteSchemaTransformConfiguration.Builder setErrorHandling(ErrorHandling errorHandling)

build

public abstract TFRecordWriteSchemaTransformConfiguration build()

Builds the TFRecordWriteSchemaTransformConfiguration configuration.