idlehandler

Documentation

Index

• func PublishIdleWatermark(ctx context.Context, toBufferPartition isb.BufferWriter, ...)

Functions

func PublishIdleWatermark

func PublishIdleWatermark(ctx context.Context, toBufferPartition isb.BufferWriter, wmPublisher publish.Publisher, idleManager *wmb.IdleManager, logger *zap.SugaredLogger, vertexType dfv1.VertexType, wm wmb.Watermark)

PublishIdleWatermark publishes a ctrl message with isb.Kind set to WMB. We only send one ctrl message when we see a new WMB; later we only update the WMB without a ctrl message.