org.apache.beam.sdk.io

Class FileBasedSink.FileResult

java.lang.Object

org.apache.beam.sdk.io.FileBasedSink.FileResult

Enclosing class:

FileBasedSink<T>

public static final class FileBasedSink.FileResult
extends java.lang.Object

Result of a single bundle write. Contains the filename produced by the bundle, and if known the final output filename.

Constructor Summary

Constructors

Constructor and Description
FileResult(ResourceId tempFilename, int shard, BoundedWindow window, PaneInfo paneInfo)

Method Summary

Modifier and Type	Method and Description
ResourceId	getDestinationFile(FileBasedSink.FilenamePolicy policy, ResourceId outputDirectory, int numShards, java.lang.String extension)
PaneInfo	getPaneInfo()
int	getShard()
ResourceId	getTempFilename()
BoundedWindow	getWindow()
java.lang.String	toString()
FileBasedSink.FileResult	withShard(int shard)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileResult

@Experimental(value=FILESYSTEM)
public FileResult(ResourceId tempFilename,
                                                  int shard,
                                                  BoundedWindow window,
                                                  PaneInfo paneInfo)

Method Detail

getTempFilename

@Experimental(value=FILESYSTEM)
public ResourceId getTempFilename()

getShard

public int getShard()

withShard

public FileBasedSink.FileResult withShard(int shard)

getWindow

public BoundedWindow getWindow()

getPaneInfo

public PaneInfo getPaneInfo()

getDestinationFile

@Experimental(value=FILESYSTEM)
public ResourceId getDestinationFile(FileBasedSink.FilenamePolicy policy,
                                                                     ResourceId outputDirectory,
                                                                     int numShards,
                                                                     java.lang.String extension)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object