udf

Documentation

Index

• func GetPartitionedBufferIdx() func(toVertex string, toVertexPartitionCount int) int32
• type MapUDFProcessor
  • func (u *MapUDFProcessor) Start(ctx context.Context) error
• type ReduceUDFProcessor
  • func (u *ReduceUDFProcessor) Start(ctx context.Context) error

Functions

func GetPartitionedBufferIdx

func GetPartitionedBufferIdx() func(toVertex string, toVertexPartitionCount int) int32

GetPartitionedBufferIdx returns a function that returns a partitioned buffer index based on the toVertex name and the partition count it distributes the messages evenly to the partitions of the toVertex based on the message count(round-robin)

Types

type MapUDFProcessor

type MapUDFProcessor struct {
	ISBSvcType     dfv1.ISBSvcType
	VertexInstance *dfv1.VertexInstance
}

func (*MapUDFProcessor) Start

func (u *MapUDFProcessor) Start(ctx context.Context) error

type ReduceUDFProcessor

type ReduceUDFProcessor struct {
	ISBSvcType     dfv1.ISBSvcType
	VertexInstance *dfv1.VertexInstance
}

func (*ReduceUDFProcessor) Start

func (u *ReduceUDFProcessor) Start(ctx context.Context) error