rowiterator

Documentation

Index

• type Iterator
  • func NewIterator(ctx context.Context, conn dbconn.Conn, table Table, rowBatchSize int) (*Iterator, error)
  • func (it *Iterator) Error() error
  • func (it *Iterator) HasNext(ctx context.Context) bool
  • func (it *Iterator) Next(ctx context.Context) tree.Datums
  • func (it *Iterator) Peek(ctx context.Context) tree.Datums
• type Table

Types

type Iterator

type Iterator struct {
	Conn dbconn.Conn
	// contains filtered or unexported fields
}

func NewIterator

func NewIterator(
	ctx context.Context, conn dbconn.Conn, table Table, rowBatchSize int,
) (*Iterator, error)

func (*Iterator) Error

func (it *Iterator) Error() error

func (*Iterator) HasNext

func (it *Iterator) HasNext(ctx context.Context) bool

func (*Iterator) Next

func (it *Iterator) Next(ctx context.Context) tree.Datums

func (*Iterator) Peek

func (it *Iterator) Peek(ctx context.Context) tree.Datums

type Table

type Table struct {
	Schema            tree.Name
	Table             tree.Name
	ColumnNames       []tree.Name
	ColumnOIDs        []oid.Oid
	PrimaryKeyColumns []tree.Name
	StartPKVals       []tree.Datum
	EndPKVals         []tree.Datum
}