polyline

Documentation

Index

• Constants
• type RdpOpSpec
  • func (s *RdpOpSpec) Kind() flux.OperationKind
• type RdpProcedureSpec
  • func (s *RdpProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *RdpProcedureSpec) Kind() plan.ProcedureKind
  • func (s *RdpProcedureSpec) TriggerSpec() plan.TriggerSpec
• type RdpTransformation
  • func NewRdpTransformation(d execute.Dataset, cache execute.TableBuilderCache, alloc memory.Allocator, ...) *RdpTransformation
  • func (rdpt *RdpTransformation) Finish(id execute.DatasetID, err error)
  • func (rdpt *RdpTransformation) Process(id execute.DatasetID, tbl flux.Table) error
  • func (rdpt *RdpTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error
  • func (rdpt *RdpTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error
  • func (rdpt *RdpTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error

Constants

const RdpKind = "rdp"

Types

type RdpOpSpec

type RdpOpSpec struct {
	ValColumn  string  `json:"valcolumn"`
	TimeColumn string  `json:"timecolumn"`
	Epsilon    float64 `json:"epsilon"`
	Retention  float64 `json:"retentionpercent"`
}

func (*RdpOpSpec) Kind

func (s *RdpOpSpec) Kind() flux.OperationKind

type RdpProcedureSpec

type RdpProcedureSpec struct {
	plan.DefaultCost

	TimeColumn string
	Epsilon    float64
	Retention  float64
	// contains filtered or unexported fields
}

func (*RdpProcedureSpec) Copy

func (s *RdpProcedureSpec) Copy() plan.ProcedureSpec

func (*RdpProcedureSpec) Kind

func (s *RdpProcedureSpec) Kind() plan.ProcedureKind

func (*RdpProcedureSpec) TriggerSpec

func (s *RdpProcedureSpec) TriggerSpec() plan.TriggerSpec

type RdpTransformation

type RdpTransformation struct {
	execute.ExecutionNode
	// contains filtered or unexported fields
}

func NewRdpTransformation

func NewRdpTransformation(d execute.Dataset, cache execute.TableBuilderCache, alloc memory.Allocator, spec *RdpProcedureSpec) *RdpTransformation

func (*RdpTransformation) Finish

func (rdpt *RdpTransformation) Finish(id execute.DatasetID, err error)

func (*RdpTransformation) Process

func (rdpt *RdpTransformation) Process(id execute.DatasetID, tbl flux.Table) error

Transformation logic

func (*RdpTransformation) RetractTable

func (rdpt *RdpTransformation) RetractTable(id execute.DatasetID, key flux.GroupKey) error

func (*RdpTransformation) UpdateProcessingTime

func (rdpt *RdpTransformation) UpdateProcessingTime(id execute.DatasetID, pt execute.Time) error

func (*RdpTransformation) UpdateWatermark

func (rdpt *RdpTransformation) UpdateWatermark(id execute.DatasetID, mark execute.Time) error