org.apache.beam.sdk.io.fileschematransform

Class FileReadSchemaTransformConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.fileschematransform.FileReadSchemaTransformConfiguration.Builder

Enclosing class:

FileReadSchemaTransformConfiguration

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

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
FileReadSchemaTransformConfiguration	build()
abstract FileReadSchemaTransformConfiguration.Builder	setFilepattern(java.lang.String filepattern)
abstract FileReadSchemaTransformConfiguration.Builder	setFormat(java.lang.String format)
abstract FileReadSchemaTransformConfiguration.Builder	setPollIntervalMillis(java.lang.Long millis)
abstract FileReadSchemaTransformConfiguration.Builder	setSchema(java.lang.String schema)
abstract FileReadSchemaTransformConfiguration.Builder	setTerminateAfterSecondsSinceNewOutput(java.lang.Long seconds)

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

setFormat

public abstract FileReadSchemaTransformConfiguration.Builder setFormat(java.lang.String format)

setFilepattern

public abstract FileReadSchemaTransformConfiguration.Builder setFilepattern(java.lang.String filepattern)

setSchema

public abstract FileReadSchemaTransformConfiguration.Builder setSchema(java.lang.String schema)

setPollIntervalMillis

public abstract FileReadSchemaTransformConfiguration.Builder setPollIntervalMillis(java.lang.Long millis)

setTerminateAfterSecondsSinceNewOutput

public abstract FileReadSchemaTransformConfiguration.Builder setTerminateAfterSecondsSinceNewOutput(java.lang.Long seconds)

build

public FileReadSchemaTransformConfiguration build()