forward

Aug 2, 2023

Changes in this version

+ type VertexBuffer struct

+ ToVertexName string

+ ToVertexPartitionIdx int32

May 30, 2023

Changes in this version

type Option

+ func WithUDFStreaming(f bool) Option

Apr 3, 2023

Changes in this version

+ func DefaultOptions() *options

Mar 13, 2023

Changes in this version

type Option

+ func WithSourceWatermarkPublisher(p isb.SourceWatermarkPublisher) Option

Jan 13, 2023

Changes in this version

+ var All = GoWhere(func(string) ([]string, error) { ... })

+ var Drop = GoWhere(func(string) ([]string, error) { ... })

+ type GoWhere func(string) ([]string, error)

+ func (gw GoWhere) WhereTo(b string) ([]string, error)

+ type InterStepDataForward struct

+ FSD ToWhichStepDecider

+ UDF udfapplier.MapApplier

+ func NewInterStepDataForward(vertex *dfv1.Vertex, fromStep isb.BufferReader, ...) (*InterStepDataForward, error)

+ func (isdf *InterStepDataForward) ForceStop()

+ func (isdf *InterStepDataForward) IsShuttingDown() (bool, error)

+ func (isdf *InterStepDataForward) Start() <-chan struct{}

+ func (isdf *InterStepDataForward) Stop()

+ type Option func(*options) error

+ func WithLogger(l *zap.SugaredLogger) Option

+ func WithReadBatchSize(f int64) Option

+ func WithRetryInterval(f time.Duration) Option

+ func WithUDFConcurrency(f int) Option

+ func WithVertexType(t dfv1.VertexType) Option

+ type Shutdown struct

+ func (s *Shutdown) String() string

+ type StarterStopper interface

+ ForceStop func()

+ Start func() <-chan struct{}

+ Stop func()

+ type ToWhichStepDecider interface

+ WhereTo func(string) ([]string, error)