Package 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 Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setFormat

public abstract FileReadSchemaTransformConfiguration.Builder setFormat(String format)

setFilepattern

public abstract FileReadSchemaTransformConfiguration.Builder setFilepattern(String filepattern)

setSchema

public abstract FileReadSchemaTransformConfiguration.Builder setSchema(String schema)

setPollIntervalMillis

public abstract FileReadSchemaTransformConfiguration.Builder setPollIntervalMillis(Long millis)

setTerminateAfterSecondsSinceNewOutput

public abstract FileReadSchemaTransformConfiguration.Builder setTerminateAfterSecondsSinceNewOutput(Long seconds)

build

public FileReadSchemaTransformConfiguration build()