testing

Documentation

Index

• Constants
• type AssertEmptyOpSpec
  • func (s *AssertEmptyOpSpec) Kind() flux.OperationKind
• type AssertEmptyProcedureSpec
  • func (s *AssertEmptyProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *AssertEmptyProcedureSpec) Kind() plan.ProcedureKind
• type AssertEmptyTransformation
  • func NewAssertEmptyTransformation(d execute.Dataset, cache execute.TableBuilderCache) *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
  • func (e *AssertEqualsError) Assertion() bool
  • func (e *AssertEqualsError) Error() string
• type AssertEqualsOpSpec
  • func (s *AssertEqualsOpSpec) Kind() flux.OperationKind
• type AssertEqualsProcedureSpec
  • func (s *AssertEqualsProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *AssertEqualsProcedureSpec) Kind() plan.ProcedureKind
• type AssertEqualsTransformation
  • func NewAssertEqualsTransformation(d execute.Dataset, cache execute.TableBuilderCache, ...) *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
  • func (s *DiffOpSpec) Kind() flux.OperationKind
• type DiffProcedureSpec
  • func (s *DiffProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *DiffProcedureSpec) Kind() plan.ProcedureKind
• type DiffTransformation
  • func NewDiffTransformation(d execute.Dataset, cache execute.TableBuilderCache, spec *DiffProcedureSpec, ...) *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

const AssertEmptyKind = "assertEmpty"

const AssertEqualsKind = "assertEquals"

const DiffKind = "diff"

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) Process

func (t *AssertEmptyTransformation) Process(id execute.DatasetID, tbl flux.Table) error

func (*AssertEmptyTransformation) RetractTable

func (t *AssertEmptyTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

func (*AssertEmptyTransformation) UpdateProcessingTime

func (t *AssertEmptyTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error

func (*AssertEmptyTransformation) UpdateWatermark

func (t *AssertEmptyTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

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) Process

func (t *AssertEqualsTransformation) Process(id execute.DatasetID, tbl flux.Table) error

func (*AssertEqualsTransformation) RetractTable

func (t *AssertEqualsTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

func (*AssertEqualsTransformation) UpdateProcessingTime

func (t *AssertEqualsTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

func (*AssertEqualsTransformation) UpdateWatermark

func (t *AssertEqualsTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

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) Process

func (t *DiffTransformation) Process(id execute.DatasetID, tbl flux.Table) error

func (*DiffTransformation) RetractTable

func (t *DiffTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

func (*DiffTransformation) UpdateProcessingTime

func (t *DiffTransformation) UpdateProcessingTime(id execute.DatasetID, mark execute.Time) error

func (*DiffTransformation) UpdateWatermark

func (t *DiffTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error