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 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, DestinationT destination)

Method Summary

Modifier and Type	Method and 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()
java.lang.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 Detail

FileResult

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

Method Detail

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 java.lang.String toString()

Overrides:

toString in class java.lang.Object