entity

Documentation

Overview

Package entity is the smallest processor entity for which the watermark will strictly monotonically increase.

Index

• type ProcessorEntitier
  • func NewProcessorEntity(name string) ProcessorEntitier

Types

type ProcessorEntitier

type ProcessorEntitier interface {
	GetName() string
}

ProcessorEntitier defines what can be a processor. The Processor is the smallest unit where the watermark will monotonically increase.

func NewProcessorEntity

func NewProcessorEntity(name string) ProcessorEntitier

NewProcessorEntity returns a new `ProcessorEntitier`.