org.apache.beam.sdk.io

Class FileIO.MatchConfiguration

java.lang.Object

org.apache.beam.sdk.io.FileIO.MatchConfiguration

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

Enclosing class:

FileIO

public abstract static class FileIO.MatchConfiguration
extends java.lang.Object
implements HasDisplayData, java.io.Serializable

Describes configuration for matching filepatterns, such as EmptyMatchTreatment and continuous watching for matching files.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MatchConfiguration()

Method Summary

Modifier and Type	Method and Description
FileIO.MatchConfiguration	continuously(Duration interval, Watch.Growth.TerminationCondition<java.lang.String,?> condition) Continuously watches for new files at the given interval until the given termination condition is reached, where the input to the condition is the filepattern.
static FileIO.MatchConfiguration	create(EmptyMatchTreatment emptyMatchTreatment) Creates a FileIO.MatchConfiguration with the given EmptyMatchTreatment.
void	populateDisplayData(DisplayData.Builder builder) Register display data for the given transform or component.
FileIO.MatchConfiguration	withEmptyMatchTreatment(EmptyMatchTreatment treatment) Sets the EmptyMatchTreatment.

Methods inherited from class java.lang.Object

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

Constructor Detail

MatchConfiguration

public MatchConfiguration()

Method Detail

create

public static FileIO.MatchConfiguration create(EmptyMatchTreatment emptyMatchTreatment)

Creates a FileIO.MatchConfiguration with the given EmptyMatchTreatment.

withEmptyMatchTreatment

public FileIO.MatchConfiguration withEmptyMatchTreatment(EmptyMatchTreatment treatment)

Sets the EmptyMatchTreatment.

continuously

public FileIO.MatchConfiguration continuously(Duration interval,
                                              Watch.Growth.TerminationCondition<java.lang.String,?> condition)

Continuously watches for new files at the given interval until the given termination condition is reached, where the input to the condition is the filepattern.

populateDisplayData

public void populateDisplayData(DisplayData.Builder builder)

Description copied from interface: HasDisplayData

Register display data for the given transform or component.

populateDisplayData(DisplayData.Builder) is invoked by Pipeline runners to collect display data via DisplayData.from(HasDisplayData). Implementations may call super.populateDisplayData(builder) in order to register display data in the current namespace, but should otherwise use subcomponent.populateDisplayData(builder) to use the namespace of the subcomponent.

Specified by:

populateDisplayData in interface HasDisplayData

Parameters:

builder - The builder to populate with display data.

See Also:

HasDisplayData