client

Documentation

Index

• type Client
  • func New(conf config.Config) (*Client, error)
  • func (c *Client) GetTablePreview(_ context.Context, partitionValue string, table *odps.Table, maxRows int) (previewFields []string, previewRows *structpb.ListValue, err error)
  • func (*Client) GetTableSchema(_ context.Context, table *odps.Table) (string, *tableschema.TableSchema, error)
  • func (c *Client) ListSchema(_ context.Context) (schemas []*odps.Schema, err error)
  • func (c *Client) ListTable(_ context.Context, schemaName string) (tables []*odps.Table, err error)

Types

type Client

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

func New

func New(conf config.Config) (*Client, error)

func (*Client) GetTablePreview

func (c *Client) GetTablePreview(_ context.Context, partitionValue string, table *odps.Table, maxRows int) (
	previewFields []string, previewRows *structpb.ListValue, err error,
)

func (*Client) GetTableSchema

func (*Client) GetTableSchema(_ context.Context, table *odps.Table) (string, *tableschema.TableSchema, error)

func (*Client) ListSchema

func (c *Client) ListSchema(_ context.Context) (schemas []*odps.Schema, err error)

func (*Client) ListTable

func (c *Client) ListTable(_ context.Context, schemaName string) (tables []*odps.Table, err error)