aggregate

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Apr 1, 2026 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package aggregate 提供分组聚合处理器

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	// GroupBy 分组字段
	GroupBy []string `json:"group_by"`
	// Aggregates 聚合配置: field -> op (count, sum)
	Aggregates map[string]string `json:"aggregates"`
}

Config Processor 的配置

type Processor

type Processor struct {
	// contains filtered or unexported fields
}

Processor 对数据进行分组聚合

func New

func New() *Processor

New 创建新的 Processor

func (*Processor) ConcurrencyCap

func (p *Processor) ConcurrencyCap() dataflow.ConcurrencyCap

ConcurrencyCap 声明不支持并发(有状态)

func (*Processor) Init

func (p *Processor) Init(config []byte) error

Init 初始化 Processor

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, in <-chan types.Record, out chan<- types.Record) error

Process 处理数据,进行聚合

Jump to

Keyboard shortcuts

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