keyed

Documentation

Overview

Package keyed .... TODO: document

Index

• type KeyedWindow
  • func NewKeyedWindow(window *window.IntervalWindow) *KeyedWindow
  • func (kw *KeyedWindow) AddKey(key string)
  • func (kw *KeyedWindow) Partitions() []partition.ID

Types

type KeyedWindow

type KeyedWindow struct {
	*window.IntervalWindow
	// TODO: can this be map[string]struct{} ?
	Keys map[string]string
	// contains filtered or unexported fields
}

KeyedWindow maintains association between keys and a window. In a keyed stream, we need to close all the partitions when the watermark is past the window.

func NewKeyedWindow

func NewKeyedWindow(window *window.IntervalWindow) *KeyedWindow

NewKeyedWindow creates a new keyed window

func (*KeyedWindow) AddKey

func (kw *KeyedWindow) AddKey(key string)

AddKey adds a key to an existing window

func (*KeyedWindow) Partitions

func (kw *KeyedWindow) Partitions() []partition.ID

Partitions returns an array of partitions for a window