DeltaProgressReporter¶

DeltaProgressReporter is an abstraction of progress reporters (loggers).

Implementations¶

• DeltaLogging

withStatusCode¶

withStatusCode[T](
  statusCode: String,
  defaultMessage: String,
  data: Map[String, Any] = Map.empty)(body: => T): T

withStatusCode prints out the following INFO message to the logs:

[statusCode]: [defaultMessage]

withStatusCode withJobDescription with the given defaultMessage and body.

withStatusCode prints out the following INFO message to the logs:

[statusCode]: Done

withStatusCode is used when:

• PartitionFiltering is requested for the files to scan
• Snapshot is requested for the state
• DeleteCommand, MergeIntoCommand, UpdateCommand are executed
• GenerateSymlinkManifest is requested to recordManifestGeneration

withJobDescription¶

withJobDescription[U](
  jobDesc: String)(body: => U): U

withJobDescription...FIXME

Logging¶

Since DeltaProgressReporter is an abstraction, logging is configured using the logger of the implementations.