Documentation
¶
Index ¶
- Constants
- 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
Constants ¶
View Source
const AssertEqualsKind = "assertEquals"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 ¶
Source Files
Click to show internal directories.
Click to hide internal directories.