public static final class FileBasedSink.FileResult
extends java.lang.Object
Constructor and Description |
---|
FileResult(ResourceId tempFilename,
int shard,
BoundedWindow window,
PaneInfo paneInfo) |
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) |
@Experimental(value=FILESYSTEM) public FileResult(ResourceId tempFilename, int shard, BoundedWindow window, PaneInfo paneInfo)
@Experimental(value=FILESYSTEM) public ResourceId getTempFilename()
public int getShard()
public FileBasedSink.FileResult withShard(int shard)
public BoundedWindow getWindow()
public PaneInfo getPaneInfo()
@Experimental(value=FILESYSTEM) public ResourceId getDestinationFile(FileBasedSink.FilenamePolicy policy, ResourceId outputDirectory, int numShards, java.lang.String extension)
public java.lang.String toString()
toString
in class java.lang.Object