Package org.apache.beam.sdk.io

Class FileBasedSink.FileResult<DestinationT>

java.lang.Object

org.apache.beam.sdk.io.FileBasedSink.FileResult<DestinationT>

Enclosing class:

FileBasedSink<UserT,DestinationT,OutputT>

public static final class FileBasedSink.FileResult<DestinationT>
extends 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	Description
FileResult(ResourceId tempFilename, int shard, BoundedWindow window, PaneInfo paneInfo, DestinationT destination)

Method Summary

Modifier and Type	Method	Description
DestinationT	getDestination()
ResourceId	getDestinationFile(boolean windowedWrites, FileBasedSink.DynamicDestinations<?,DestinationT,?> dynamicDestinations, int numShards, FileBasedSink.OutputFileHints outputFileHints)
PaneInfo	getPaneInfo()
int	getShard()
ResourceId	getTempFilename()
@Nullable BoundedWindow	getWindow()
String	toString()
FileBasedSink.FileResult<DestinationT>	withShard(int shard)

Methods inherited from class java.lang.Object

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

Constructor Details

FileResult

public FileResult(ResourceId tempFilename,
 int shard,
 BoundedWindow window,
 PaneInfo paneInfo,
 DestinationT destination)

Method Details

getTempFilename

public ResourceId getTempFilename()

getShard

public int getShard()

withShard

public FileBasedSink.FileResult<DestinationT> withShard(int shard)

getWindow

public @Nullable BoundedWindow getWindow()

getPaneInfo

public PaneInfo getPaneInfo()

getDestination

public DestinationT getDestination()

getDestinationFile

public ResourceId getDestinationFile(boolean windowedWrites,
 FileBasedSink.DynamicDestinations<?,DestinationT,?> dynamicDestinations,
 int numShards,
 FileBasedSink.OutputFileHints outputFileHints)

toString

public String toString()

Overrides:

toString in class Object