org.apache.beam.sdk.io

Class FileBasedSink.FilenamePolicy.WindowedContext

java.lang.Object

org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy.WindowedContext

Enclosing class:

FileBasedSink.FilenamePolicy

public static class FileBasedSink.FilenamePolicy.WindowedContext
extends java.lang.Object

Context used for generating a name based on window, pane, shard number, and num shards. The policy must produce unique filenames for unique FileBasedSink.FilenamePolicy.WindowedContext objects.

Be careful about adding fields to this as existing strategies will not notice the new fields, and may not produce unique filenames.

Constructor Summary

Constructors

Constructor and Description
WindowedContext(BoundedWindow window, PaneInfo paneInfo, int shardNumber, int numShards)

Method Summary

Modifier and Type	Method and Description
int	getNumShards()
PaneInfo	getPaneInfo()
int	getShardNumber()
BoundedWindow	getWindow()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WindowedContext

public WindowedContext(BoundedWindow window,
                       PaneInfo paneInfo,
                       int shardNumber,
                       int numShards)

Method Detail

getWindow

public BoundedWindow getWindow()

getPaneInfo

public PaneInfo getPaneInfo()

getShardNumber

public int getShardNumber()

getNumShards

public int getNumShards()