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.
Source Files
Click to show internal directories.
Click to hide internal directories.