streaming

package

v0.5.0 Latest Latest Go to latest Published: Oct 17, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package streaming implement the flow framework to provide the sliding window, top-n aggregation, and etc.

This section is empty.

This section is empty.

func New(source flow.Source) flow.Flow

New returns a new streaming flow.

func NewTumblingTimeWindows(size time.Duration) flow.WindowAssigner

NewTumblingTimeWindows return tumbling-time windows.

type TopNOption func(aggregator *topNAggregatorGroup)

TopNOption is the option to set up a top-n aggregator group.

func OrderBy(sort TopNSort) TopNOption

OrderBy sets the sorting order.

func WithGroupKeyExtractor(groupKeyExtractor func(flow.StreamRecord) string) TopNOption

WithGroupKeyExtractor extract group key from the StreamRecord.

func WithSortKeyExtractor(sortKeyExtractor func(flow.StreamRecord) int64) TopNOption

WithSortKeyExtractor sets a closure to extract the sorting key.

type TopNSort uint8

TopNSort defines the order of sorting.

const (
	DESC TopNSort = iota
	ASC
)

The available order of sorting.

type Tuple2 struct {
	V1 interface{} `json:"v1"`
	V2 interface{} `json:"v2"`
}

Tuple2 is a tuple with 2 fields. Each field may be a separate type.

Path	Synopsis
sources Package sources implements data sources to sink data into the flow framework.	Package sources implements data sources to sink data into the flow framework.