Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Load ¶
func Load(ctx context.Context, r io.Reader, rjc pb.RoutedJournalClient, selector pb.LabelSelector, name string) error
Load a Reader of hex-encoded key/values into DeltaEvent partitions identified by |selector|. Each DeltaEvent row is sequenced under extractor |name| and written atomically with its commit acknowledgement. This ensures that multiple calls to Load with interspersed failures will not result into double-counting of rows by the VTable service, so long as each invocation uses the same |name| and reads identical input sequences from the Reader.
func Main ¶
func Main(extractFns factable.ExtractFns)
Types ¶
type JobSpec ¶
type JobSpec struct { SchemaSpec factable.SchemaSpec Inputs map[pb.Journal]pb.JournalSpec }
JobSpec defines common specifications of a backfill job.
Click to show internal directories.
Click to hide internal directories.