Class WriteOneFilePerWindow.PerWindowFiles

  • All Implemented Interfaces:
    Enclosing class:

    public static final class WriteOneFilePerWindow.PerWindowFiles
    A FileBasedSink.FilenamePolicy produces a base file name for a write based on metadata about the data being written. This always includes the shard number and the total number of shards. For windowed writes, it also includes the window and pane index (a sequence number assigned to each trigger firing).
    See Also:
    Serialized Form
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description unwindowedFilename​(int shardNumber, int numShards, outputFileHints) windowedFilename​(int shardNumber, int numShards, org.apache.beam.sdk.transforms.windowing.BoundedWindow window, org.apache.beam.sdk.transforms.windowing.PaneInfo paneInfo, outputFileHints)  
      • Methods inherited from class

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • windowedFilename

        public windowedFilename​(int shardNumber,
                                                                     int numShards,
                                                                     org.apache.beam.sdk.transforms.windowing.BoundedWindow window,
                                                                     org.apache.beam.sdk.transforms.windowing.PaneInfo paneInfo,
        Specified by:
        windowedFilename in class
      • unwindowedFilename

        public unwindowedFilename​(int shardNumber,
                                                                       int numShards,
        Specified by:
        unwindowedFilename in class