stream

Documentation

Index

• type Format
• type InternallyConsistentOutputStreamWrapper
  • func (node *InternallyConsistentOutputStreamWrapper) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error
• type NativeFormat
  • func NewNativeFormat(schema physical.Schema) *NativeFormat
  • func (n *NativeFormat) Close() error
  • func (n *NativeFormat) SetSchema(schema physical.Schema)
  • func (n *NativeFormat) WriteMeta(message MetadataMessage) error
  • func (n *NativeFormat) WriteRecord(record Record) error
• type OutputPrinter
  • func NewOutputPrinter(source Node, format Format) *OutputPrinter
  • func (o *OutputPrinter) Run(execCtx ExecutionContext) error

Types

type Format

type Format interface {
	SetSchema(physical.Schema)
	WriteRecord(Record) error
	WriteMeta(MetadataMessage) error
	Close() error
}

type InternallyConsistentOutputStreamWrapper

type InternallyConsistentOutputStreamWrapper struct {
	Source Node
}

func (*InternallyConsistentOutputStreamWrapper) Run

func (node *InternallyConsistentOutputStreamWrapper) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

type NativeFormat

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

func NewNativeFormat

func NewNativeFormat(schema physical.Schema) *NativeFormat

func (*NativeFormat) Close

func (n *NativeFormat) Close() error

func (*NativeFormat) SetSchema

func (n *NativeFormat) SetSchema(schema physical.Schema)

func (*NativeFormat) WriteMeta

func (n *NativeFormat) WriteMeta(message MetadataMessage) error

func (*NativeFormat) WriteRecord

func (n *NativeFormat) WriteRecord(record Record) error

type OutputPrinter

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

func NewOutputPrinter

func NewOutputPrinter(source Node, format Format) *OutputPrinter

func (*OutputPrinter) Run

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