Documentation
¶
Index ¶
- Constants
- type RdpOpSpec
- type RdpProcedureSpec
- type 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 ¶
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 (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) RetractTable ¶
func (*RdpTransformation) UpdateProcessingTime ¶
func (*RdpTransformation) UpdateWatermark ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.