org.apache.beam.sdk.io

Class DefaultFilenamePolicy.Params

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

DefaultFilenamePolicy

public static class DefaultFilenamePolicy.Params
extends java.lang.Object
implements java.io.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 and Description
Params() Construct a default Params object.

Method Summary

Modifier and Type	Method and Description
boolean	equals(@Nullable java.lang.Object o)
int	hashCode()
java.lang.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(java.lang.String shardTemplate) Sets the shard template.
DefaultFilenamePolicy.Params	withSuffix(java.lang.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 Detail

Params

public Params()

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

Method Detail

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(java.lang.String shardTemplate)

Sets the shard template.

withSuffix

public DefaultFilenamePolicy.Params withSuffix(java.lang.String suffix)

Sets the suffix.

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(@Nullable java.lang.Object o)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object