package polyline

import "github.com/influxdata/flux/stdlib/experimental/polyline"

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, spec *RdpProcedureSpec) *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

Source Files ¶

rdp.go

Directories ¶