Trellis.CorrectingNode (Trellis v0.1.0-alpha)

Copy Markdown View Source

A partition of a partitioned source a transform is being corrected for, as Trellis.status/2 reports it: the schema-qualified node, when the staging worker queued its correction (since), and the keys still to re-derive (keys_remaining, nil until the correction has counted them; an estimate while it reads the node's own rows).

Summary

Types

t()

@type t() :: %Trellis.CorrectingNode{
  keys_remaining: non_neg_integer() | nil,
  node: String.t(),
  since: DateTime.t()
}