engine

type Aggregation string

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

type DataType interface {
	ID() arrow.Type
}

type Hook interface {
	// Execute is called at a specific point in the engine's execution.
	Execute(context.Context, interface{}) error
}

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

type Predicate interface {
	// Eval evaluates the predicate on the given record and returns a boolean array
	// indicating which rows match the condition.
	Eval(rec arrow.Record) (arrow.Array, error)
}

type Reader interface {
	Read() (arrow.Record, error)
	Release()
}

type Record struct {
	arrow.Record
}

type Stage func(ctx context.Context, in <-chan arrow.Record) <-chan arrow.Record

type Stream interface {
	Reader
	Writer
}

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

type Writer interface {
	Write(arrow.Record) error
	Close() error
}