array

Documentation

Index

• Constants
• func New(nodeExecutor interfaces.Node, eventConfig *config.EventConfig, ...) (interfaces.NodeHandler, error)

Constants

const (
	FlyteK8sArrayIndexVarName string = "FLYTE_K8S_ARRAY_INDEX"
	JobIndexVarName           string = "BATCH_JOB_ARRAY_INDEX_VAR_NAME"
)

const (
	// value is 3 days of seconds which is covered by 18 bits (262144)
	MAX_DELTA_TIMESTAMP = 259200
)

Functions

func New

func New(nodeExecutor interfaces.Node, eventConfig *config.EventConfig, literalOffloadingConfig config.LiteralOffloadingConfig, scope promutils.Scope) (interfaces.NodeHandler, error)

New initializes a new arrayNodeHandler