Skip to content


[[creating-instance]] SinkFileStatus represents the status of files of FileStreamSink (and the type of the metadata of FileStreamSinkLog):

  • [[path]] Path
  • [[size]] Size
  • [[isDir]] isDir flag
  • [[modificationTime]] Modification time
  • [[blockReplication]] Block replication
  • [[blockSize]] Block size
  • [[action]] Action (either add or delete)

=== [[toFileStatus]] toFileStatus Method

[source, scala]

toFileStatus: FileStatus

toFileStatus simply creates a new Hadoop FileStatus.

NOTE: toFileStatus is used exclusively when MetadataLogFileIndex is created.

=== [[apply]] Creating SinkFileStatus Instance

[source, scala]

apply(f: FileStatus): SinkFileStatus

apply simply creates a new <> (with add action).

apply is used when ManifestFileCommitProtocol is requested to commitTask.