executor

type BinaryFunction interface {
	Evaluate(lhs, rhs arrow.Array, lhsIsScalar, rhsIsScalar bool) (arrow.Array, error)
}

type BinaryFunctionRegistry interface {
	GetForSignature(types.BinaryOp, arrow.DataType) (BinaryFunction, error)
	// contains filtered or unexported methods
}

type BufferedPipeline struct {
	// contains filtered or unexported fields
}

type Config struct {
	BatchSize int64
	Bucket    objstore.Bucket
	Metastore metastore.Metastore

	PrefetchBytes int64

	MergePrefetchCount int

	// GetExternalInputs is an optional function called for each node in the
	// plan. If GetExternalInputs returns a non-nil slice of Pipelines, they
	// will be used as inputs to the pipeline of node.
	GetExternalInputs func(ctx context.Context, node physical.Node) []Pipeline

	// StreamFilterer is an optional filterer that can filter streams based on their labels.
	// When set, streams are filtered before scanning.
	StreamFilterer RequestStreamFilterer `yaml:"-"`
}

type Context struct {
	// contains filtered or unexported fields
}

type ContributingTimeRangeChangedHandler = func(ts time.Time, lessThan bool)

type ContributingTimeRangeChangedNotifier interface {
	// SubscribeToTimeRangeChanges adds a callback function to a list of listeners.
	SubscribeToTimeRangeChanges(callback ContributingTimeRangeChangedHandler)
}

type GenericPipeline struct {
	// contains filtered or unexported fields
}

type Merge struct {
	// contains filtered or unexported fields
}

type Pipeline interface {
	// Open initializes the pipeline resources and must be called before [Read].
	// The implementation must be safe to call multiple times.
	Open(context.Context) error
	// Read collects the next value ([arrow.RecordBatch]) from the pipeline and returns it to the caller.
	// It returns an error if reading fails or when the pipeline is exhausted. In this case, the function returns EOF.
	Read(context.Context) (arrow.RecordBatch, error)
	// Close closes the resources of the pipeline.
	// The implementation must close all the of the pipeline's inputs and must be safe to call multiple times.
	Close()
}

type RequestStreamFilterer interface {
	ForRequest(ctx context.Context) StreamFilterer
}

type StreamFilterer interface {
	// ShouldFilter returns true if the stream should be filtered out.
	ShouldFilter(labels labels.Labels) bool
}

type UnaryFunc func(arrow.Array) (arrow.Array, error)

type UnaryFunction interface {
	Evaluate(lhs arrow.Array) (arrow.Array, error)
}

type UnaryFunctionRegistry interface {
	GetForSignature(types.UnaryOp, arrow.DataType) (UnaryFunction, error)
	// contains filtered or unexported methods
}

type VariadicFunction interface {
	Evaluate(args ...arrow.Array) (arrow.Array, error)
}

type VariadicFunctionFunc func(args ...arrow.Array) (arrow.Array, error)

type VariadicFunctionRegistry interface {
	GetForSignature(types.VariadicOp) (VariadicFunction, error)
	// contains filtered or unexported methods
}

type WrappedPipeline interface {
	Pipeline

	// Unwrap returns the inner pipeline. Implementations must always return the
	// same non-nil value representing the inner pipeline.
	Unwrap() Pipeline
}