Documentation ¶
Index ¶
- Constants
- type AssertEmptyOpSpec
- type AssertEmptyProcedureSpec
- type AssertEmptyTransformation
- func (t *AssertEmptyTransformation) Finish(id execute.DatasetID, err error)
- func (t *AssertEmptyTransformation) Process(id execute.DatasetID, tbl flux.Table) error
- func (t *AssertEmptyTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
- func (t *AssertEmptyTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error
- func (t *AssertEmptyTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error
- type AssertEqualsError
- type AssertEqualsOpSpec
- type AssertEqualsProcedureSpec
- type AssertEqualsTransformation
- func (t *AssertEqualsTransformation) Finish(id execute.DatasetID, err error)
- func (t *AssertEqualsTransformation) Process(id execute.DatasetID, tbl flux.Table) error
- func (t *AssertEqualsTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
- func (t *AssertEqualsTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error
- func (t *AssertEqualsTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error
- type DiffOpSpec
- type DiffProcedureSpec
- type DiffTransformation
- func (t *DiffTransformation) Finish(id execute.DatasetID, err error)
- func (t *DiffTransformation) Process(id execute.DatasetID, tbl flux.Table) error
- func (t *DiffTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
- func (t *DiffTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error
- func (t *DiffTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error
Constants ¶
View Source
const AssertEmptyKind = "assertEmpty"
View Source
const AssertEqualsKind = "assertEquals"
View Source
const DiffKind = "diff"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AssertEmptyOpSpec ¶
type AssertEmptyOpSpec struct{}
func (*AssertEmptyOpSpec) Kind ¶
func (s *AssertEmptyOpSpec) Kind() flux.OperationKind
type AssertEmptyProcedureSpec ¶
type AssertEmptyProcedureSpec struct {
plan.DefaultCost
}
func (*AssertEmptyProcedureSpec) Copy ¶
func (s *AssertEmptyProcedureSpec) Copy() plan.ProcedureSpec
func (*AssertEmptyProcedureSpec) Kind ¶
func (s *AssertEmptyProcedureSpec) Kind() plan.ProcedureKind
type AssertEmptyTransformation ¶
type AssertEmptyTransformation struct {
// contains filtered or unexported fields
}
func NewAssertEmptyTransformation ¶
func NewAssertEmptyTransformation(d execute.Dataset, cache execute.TableBuilderCache) *AssertEmptyTransformation
func (*AssertEmptyTransformation) Finish ¶
func (t *AssertEmptyTransformation) Finish(id execute.DatasetID, err error)
func (*AssertEmptyTransformation) RetractTable ¶
func (*AssertEmptyTransformation) UpdateProcessingTime ¶
func (*AssertEmptyTransformation) UpdateWatermark ¶
type AssertEqualsError ¶
type AssertEqualsError struct {
// contains filtered or unexported fields
}
func (*AssertEqualsError) Assertion ¶
func (e *AssertEqualsError) Assertion() bool
func (*AssertEqualsError) Error ¶
func (e *AssertEqualsError) Error() string
type AssertEqualsOpSpec ¶
type AssertEqualsOpSpec struct {
Name string `json:"name"`
}
func (*AssertEqualsOpSpec) Kind ¶
func (s *AssertEqualsOpSpec) Kind() flux.OperationKind
type AssertEqualsProcedureSpec ¶
type AssertEqualsProcedureSpec struct { plan.DefaultCost Name string }
func (*AssertEqualsProcedureSpec) Copy ¶
func (s *AssertEqualsProcedureSpec) Copy() plan.ProcedureSpec
func (*AssertEqualsProcedureSpec) Kind ¶
func (s *AssertEqualsProcedureSpec) Kind() plan.ProcedureKind
type AssertEqualsTransformation ¶
type AssertEqualsTransformation struct {
// contains filtered or unexported fields
}
func NewAssertEqualsTransformation ¶
func NewAssertEqualsTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *AssertEqualsProcedureSpec, gotID, wantID execute.DatasetID, a *memory.Allocator) *AssertEqualsTransformation
func (*AssertEqualsTransformation) Finish ¶
func (t *AssertEqualsTransformation) Finish(id execute.DatasetID, err error)
func (*AssertEqualsTransformation) RetractTable ¶
func (*AssertEqualsTransformation) UpdateProcessingTime ¶
func (*AssertEqualsTransformation) UpdateWatermark ¶
type DiffOpSpec ¶
type DiffOpSpec struct {
Verbose bool `json:"verbose,omitempty"`
}
func (*DiffOpSpec) Kind ¶
func (s *DiffOpSpec) Kind() flux.OperationKind
type DiffProcedureSpec ¶
type DiffProcedureSpec struct { plan.DefaultCost Verbose bool }
func (*DiffProcedureSpec) Copy ¶
func (s *DiffProcedureSpec) Copy() plan.ProcedureSpec
func (*DiffProcedureSpec) Kind ¶
func (s *DiffProcedureSpec) Kind() plan.ProcedureKind
type DiffTransformation ¶
type DiffTransformation struct {
// contains filtered or unexported fields
}
func NewDiffTransformation ¶
func NewDiffTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *DiffProcedureSpec, wantID, gotID execute.DatasetID, a *memory.Allocator) *DiffTransformation
func (*DiffTransformation) Finish ¶
func (t *DiffTransformation) Finish(id execute.DatasetID, err error)
func (*DiffTransformation) RetractTable ¶
func (*DiffTransformation) UpdateProcessingTime ¶
func (*DiffTransformation) UpdateWatermark ¶
Click to show internal directories.
Click to hide internal directories.