types

Documentation

Index

• type GetQueryResultsResponse
• type QueryResponse
• type TableCell
  • func (c *TableCell) AVROValue(schema *types.AVROFieldSchema) (interface{}, error)
  • func (c *TableCell) AppendValueToARROWBuilder(builder array.Builder) error
  • func (c *TableCell) Data() (interface{}, error)
• type TableDataList
• type TableRow
  • func Format(schema *bigqueryv2.TableSchema, rows []*TableRow, useInt64Timestamp bool) []*TableRow
  • func (r *TableRow) AVROValue(fields []*types.AVROFieldSchema) (map[string]interface{}, error)
  • func (r *TableRow) AppendValueToARROWBuilder(builder *array.RecordBuilder) error
  • func (r *TableRow) Data() (map[string]interface{}, error)

Types

type GetQueryResultsResponse

type GetQueryResultsResponse struct {
	JobReference *bigqueryv2.JobReference `json:"jobReference"`
	Schema       *bigqueryv2.TableSchema  `json:"schema"`
	Rows         []*TableRow              `json:"rows"`
	TotalRows    uint64                   `json:"totalRows,string"`
	JobComplete  bool                     `json:"jobComplete"`
	TotalBytes   uint64                   `json:"-"`
}

type QueryResponse

type QueryResponse struct {
	JobReference   *bigqueryv2.JobReference   `json:"jobReference"`
	Schema         *bigqueryv2.TableSchema    `json:"schema"`
	Rows           []*TableRow                `json:"rows"`
	TotalRows      uint64                     `json:"totalRows,string"`
	JobComplete    bool                       `json:"jobComplete"`
	TotalBytes     int64                      `json:"-"`
	ChangedCatalog *zetasqlite.ChangedCatalog `json:"-"`
}

type TableCell

type TableCell struct {
	V     interface{} `json:"v"`
	Bytes int64       `json:"-"`
	Name  string      `json:"-"`
}

Redefines the TableCell type to return null explicitly because TableCell for bigqueryv2 is omitted if V is nil,

func (*TableCell) AVROValue

func (c *TableCell) AVROValue(schema *types.AVROFieldSchema) (interface{}, error)

func (*TableCell) AppendValueToARROWBuilder

func (c *TableCell) AppendValueToARROWBuilder(builder array.Builder) error

func (*TableCell) Data

func (c *TableCell) Data() (interface{}, error)

type TableDataList

type TableDataList struct {
	Rows      []*TableRow `json:"rows"`
	TotalRows uint64      `json:"totalRows,string"`
}

type TableRow

type TableRow struct {
	F []*TableCell `json:"f,omitempty"`
}

func Format

func Format(schema *bigqueryv2.TableSchema, rows []*TableRow, useInt64Timestamp bool) []*TableRow

func (*TableRow) AVROValue

func (r *TableRow) AVROValue(fields []*types.AVROFieldSchema) (map[string]interface{}, error)

func (*TableRow) AppendValueToARROWBuilder

func (r *TableRow) AppendValueToARROWBuilder(builder *array.RecordBuilder) error

func (*TableRow) Data

func (r *TableRow) Data() (map[string]interface{}, error)