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 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	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()
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

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

Method Detail

getTempFilename

@Experimental(FILESYSTEM)
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

@Experimental(FILESYSTEM)
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