batch

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

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

type RecordData struct {
	Ids                  []*execution.RecordID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	IsUndo               bool                  `protobuf:"varint,2,opt,name=isUndo,proto3" json:"isUndo,omitempty"`
	Record               *execution.Record     `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

type RecordsLister interface {
	ListRecords(ctx context.Context, tx storage.StateTransaction) ([]*execution.Record, error)
	GetWatermark(ctx context.Context, tx storage.StateTransaction) (time.Time, error)
	GetEndOfStream(ctx context.Context, tx storage.StateTransaction) (bool, error)
	GetErrorMessage(ctx context.Context, tx storage.StateTransaction) (string, error)
}

type TableFormatter func(w io.Writer, records []*execution.Record, watermark time.Time, err error) error

type TableOutput struct {
	StreamID            *execution.StreamID
	EventTimeField      octosql.VariableName
	OrderingExpressions []execution.Expression
	OrderingDirections  []execution.OrderDirection
	Limit               *int
	Offset              *int
}