batch

Documentation

Index

• type CSVFormatter
  • func (t *CSVFormatter) Close() error
  • func (t *CSVFormatter) SetSchema(schema physical.Schema)
  • func (t *CSVFormatter) Write(values []octosql.Value) error
• type Format
  • func NewCSVFormatter(w io.Writer) Format
  • func NewTableFormatter(w io.Writer) Format
• type OutputPrinter
  • func NewOutputPrinter(source Node, keyExprs []Expression, directionMultipliers []int, limit int, ...) *OutputPrinter
  • func (o *OutputPrinter) Run(execCtx ExecutionContext) error
• type TableFormatter
  • func (t *TableFormatter) Close() error
  • func (t *TableFormatter) SetSchema(schema physical.Schema)
  • func (t *TableFormatter) Write(values []octosql.Value) error

Types

type CSVFormatter

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

func (*CSVFormatter) Close

func (t *CSVFormatter) Close() error

func (*CSVFormatter) SetSchema

func (t *CSVFormatter) SetSchema(schema physical.Schema)

func (*CSVFormatter) Write

func (t *CSVFormatter) Write(values []octosql.Value) error

type Format

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

func NewCSVFormatter

func NewCSVFormatter(w io.Writer) Format

func NewTableFormatter

func NewTableFormatter(w io.Writer) Format

type OutputPrinter

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

func NewOutputPrinter

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

func (*OutputPrinter) Run

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

type TableFormatter

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

func (*TableFormatter) Close

func (t *TableFormatter) Close() error

func (*TableFormatter) SetSchema

func (t *TableFormatter) SetSchema(schema physical.Schema)

func (*TableFormatter) Write

func (t *TableFormatter) Write(values []octosql.Value) error