Package org.apache.beam.sdk.io

Class DefaultFilenamePolicy.Params

java.lang.Object

org.apache.beam.sdk.io.DefaultFilenamePolicy.Params

All Implemented Interfaces:

Serializable

Enclosing class:

DefaultFilenamePolicy

public static class DefaultFilenamePolicy.Params
extends Object
implements Serializable

Encapsulates constructor parameters to DefaultFilenamePolicy.

This is used as the DestinationT argument to allow DefaultFilenamePolicy objects to be dynamically generated.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Params()	Construct a default Params object.

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object o)
int	hashCode()
String	toString()
DefaultFilenamePolicy.Params	withBaseFilename(ResourceId baseFilename)	Sets the base filename.
DefaultFilenamePolicy.Params	withBaseFilename(ValueProvider<ResourceId> baseFilename)	Like withBaseFilename(ResourceId), but takes in a ValueProvider.
DefaultFilenamePolicy.Params	withShardTemplate(String shardTemplate)	Sets the shard template.
DefaultFilenamePolicy.Params	withSuffix(String suffix)	Sets the suffix.
DefaultFilenamePolicy.Params	withWindowedWrites()	Specify that writes are windowed.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

Params

public Params()

Construct a default Params object. The shard template will be set to the default DefaultFilenamePolicy.DEFAULT_UNWINDOWED_SHARD_TEMPLATE value.

Method Details

withWindowedWrites

public DefaultFilenamePolicy.Params withWindowedWrites()

Specify that writes are windowed. This affects the default shard template, changing it to DefaultFilenamePolicy.DEFAULT_WINDOWED_SHARD_TEMPLATE.

withBaseFilename

public DefaultFilenamePolicy.Params withBaseFilename(ResourceId baseFilename)

Sets the base filename.

withBaseFilename

public DefaultFilenamePolicy.Params withBaseFilename(ValueProvider<ResourceId> baseFilename)

Like withBaseFilename(ResourceId), but takes in a ValueProvider.

withShardTemplate

public DefaultFilenamePolicy.Params withShardTemplate(String shardTemplate)

Sets the shard template.

withSuffix

public DefaultFilenamePolicy.Params withSuffix(String suffix)

Sets the suffix.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object