polyline

package
v0.195.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 7, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const RdpKind = "rdp"

Variables

This section is empty.

Functions

This section is empty.

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 (*RdpProcedureSpec) Kind

func (*RdpProcedureSpec) TriggerSpec

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

type RdpTransformation

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL