Package org.apache.beam.sdk.io

Interface FileIO.Write.FileNaming

All Superinterfaces:

Serializable

Enclosing class:

FileIO.Write<DestinationT,UserT>

public static interface FileIO.Write.FileNaming
extends Serializable

A policy for generating names for shard files.

Method Summary

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

Method Details

getFilename

String getFilename(BoundedWindow window,
 PaneInfo paneInfo,
 int numShards,
 int shardIndex,
 Compression compression)

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