org.apache.beam.sdk.io

Class FileBasedSink.FilenamePolicy.Context

java.lang.Object

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

Enclosing class:

FileBasedSink.FilenamePolicy

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

Context used for generating a name based on shard number, and num shards. The policy must produce unique filenames for unique FileBasedSink.FilenamePolicy.Context 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
Context(int shardNumber, int numShards)

Method Summary

Modifier and Type	Method and Description
int	getNumShards()
int	getShardNumber()

Methods inherited from class java.lang.Object

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

Constructor Detail

Context

public Context(int shardNumber,
               int numShards)

Method Detail

getShardNumber

public int getShardNumber()

getNumShards

public int getNumShards()