batch

Documentation

Index

• type Format
• type OutputPrinter
  • func NewOutputPrinter(source Node, keyExprs []Expression, directionMultipliers []int, limit *int64, ...) *OutputPrinter
  • func (o *OutputPrinter) Run(execCtx ExecutionContext) error

Types

type Format

type Format interface {
	SetSchema(physical.Schema)
	Write([]octosql.Value) error
	Close() error
}

type OutputPrinter

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

func NewOutputPrinter

func NewOutputPrinter(source Node, keyExprs []Expression, directionMultipliers []int, limit *int64, noRetractionsPossible bool, schema physical.Schema, format func(io.Writer) Format, live bool) *OutputPrinter

func (*OutputPrinter) Run

func (o *OutputPrinter) Run(execCtx ExecutionContext) error