distsql

Oct 16, 2017

Changes in this version

+ func ColumnsToProto(columns []*model.ColumnInfo, pkIsHandle bool) []*tipb.ColumnInfo

+ func FieldTypeFromPBColumn(col *tipb.ColumnInfo) *types.FieldType

+ func IndexToProto(t *model.TableInfo, idx *model.IndexInfo) *tipb.IndexInfo

+ type NewPartialResult interface

+ Close func() error

+ Next func() (rowData []types.Datum, err error)

+ type NewSelectResult interface

+ Close func() error

+ Fetch func(ctx goctx.Context)

+ Next func() (NewPartialResult, error)

+ NextRaw func() ([]byte, error)

+ func NewAnalyze(ctx goctx.Context, client kv.Client, kvReq *kv.Request) (NewSelectResult, error)

+ func NewSelectDAG(ctx goctx.Context, client kv.Client, kvReq *kv.Request, colLen int) (NewSelectResult, error)

+ type PartialResult interface

+ Close func() error

+ Next func() (handle int64, rowData []byte, err error)

+ type SelectResult interface

+ Close func() error

+ Fetch func(ctx goctx.Context)

+ Next func() (PartialResult, error)

+ NextRaw func() ([]byte, error)

+ func Select(client kv.Client, ctx goctx.Context, req *tipb.SelectRequest, ...) (SelectResult, error)