Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KeyedWindow ¶
type KeyedWindow struct {
*window.IntervalWindow
Keys []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() []PartitionId
Partitions returns an array of partitions for a window
type PartitionId ¶
type PartitionId string
PartitionId uniquely identifies a partition
func Partition ¶
func Partition(window *window.IntervalWindow, key string) PartitionId
Partition returns the partitionId for a given window and a key
Source Files
Click to show internal directories.
Click to hide internal directories.