Documentation
¶
Index ¶
- Constants
- type DedupKeyOpSpec
- type DedupKeyTransformation
- func (t *DedupKeyTransformation) Finish(id execute.DatasetID, err error)
- func (t *DedupKeyTransformation) Process(id execute.DatasetID, tbl flux.Table) error
- func (t *DedupKeyTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
- func (t *DedupKeyTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error
- func (t *DedupKeyTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error
- type DedupProcedureSpec
Constants ¶
View Source
const DedupKeyKind = "dedupKey"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DedupKeyOpSpec ¶
type DedupKeyOpSpec struct{}
func (*DedupKeyOpSpec) Kind ¶
func (s *DedupKeyOpSpec) Kind() flux.OperationKind
type DedupKeyTransformation ¶
type DedupKeyTransformation struct {
// contains filtered or unexported fields
}
func NewDedupKeyTransformation ¶
func NewDedupKeyTransformation(d execute.Dataset, cache execute.TableBuilderCache) *DedupKeyTransformation
func (*DedupKeyTransformation) Finish ¶
func (t *DedupKeyTransformation) Finish(id execute.DatasetID, err error)
func (*DedupKeyTransformation) RetractTable ¶
func (*DedupKeyTransformation) UpdateProcessingTime ¶
func (*DedupKeyTransformation) UpdateWatermark ¶
type DedupProcedureSpec ¶
type DedupProcedureSpec struct {
plan.DefaultCost
}
func (*DedupProcedureSpec) Copy ¶
func (s *DedupProcedureSpec) Copy() plan.ProcedureSpec
func (*DedupProcedureSpec) Kind ¶
func (s *DedupProcedureSpec) Kind() plan.ProcedureKind
Source Files
Click to show internal directories.
Click to hide internal directories.