org.apache.beam.sdk.io

Interface FileIO.Write.FileNaming

All Superinterfaces:

java.io.Serializable

Enclosing class:

FileIO.Write<DestinationT,UserT>

public static interface FileIO.Write.FileNaming
extends java.io.Serializable

A policy for generating names for shard files.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getFilename(BoundedWindow window, PaneInfo pane, int numShards, int shardIndex, Compression compression) Generates the filename.

Method Detail

getFilename

java.lang.String getFilename(BoundedWindow window,
                             PaneInfo pane,
                             int numShards,
                             int shardIndex,
                             Compression compression)

Generates the filename. MUST use each argument and return different values for each combination of the arguments.