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
Encapsulates constructor parameters to
DefaultFilenamePolicy
.
This is used as the DestinationT
argument to allow DefaultFilenamePolicy
objects to be dynamically generated.
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
int
hashCode()
toString()
withBaseFilename
(ResourceId baseFilename) Sets the base filename.withBaseFilename
(ValueProvider<ResourceId> baseFilename) LikewithBaseFilename(ResourceId)
, but takes in aValueProvider
.withShardTemplate
(String shardTemplate) Sets the shard template.withSuffix
(String suffix) Sets the suffix.Specify that writes are windowed.
-
Constructor Details
-
Params
public Params()Construct a default Params object. The shard template will be set to the defaultDefaultFilenamePolicy.DEFAULT_UNWINDOWED_SHARD_TEMPLATE
value.
-
-
Method Details
-
withWindowedWrites
Specify that writes are windowed. This affects the default shard template, changing it toDefaultFilenamePolicy.DEFAULT_WINDOWED_SHARD_TEMPLATE
. -
withBaseFilename
Sets the base filename. -
withBaseFilename
LikewithBaseFilename(ResourceId)
, but takes in aValueProvider
. -
withShardTemplate
Sets the shard template. -
withSuffix
Sets the suffix. -
hashCode
public int hashCode() -
equals
-
toString
-