thriftlog

Documentation

Index

• type Service
  • func (s *Service) PrestoGetIndexSplits(schemaTableName *presto.PrestoThriftSchemaTableName, indexColumnNames []string, ...) (*presto.PrestoThriftSplitBatch, error)
  • func (s *Service) PrestoGetRows(splitID *presto.PrestoThriftId, columns []string, maxBytes int64, ...) (*presto.PrestoThriftPageResult, error)
  • func (s *Service) PrestoGetSplits(schemaTableName *presto.PrestoThriftSchemaTableName, ...) (*presto.PrestoThriftSplitBatch, error)
  • func (s *Service) PrestoGetTableMetadata(schemaTableName *presto.PrestoThriftSchemaTableName) (*presto.PrestoThriftNullableTableMetadata, error)
  • func (s *Service) PrestoListSchemaNames() ([]string, error)
  • func (s *Service) PrestoListTables(schemaNameOrNull *presto.PrestoThriftNullableSchemaName) ([]*presto.PrestoThriftSchemaTableName, error)

Types

type Service

type Service struct {
	Service presto.PrestoThriftService
	Monitor monitor.Monitor
}

Service represents a PrestoThriftService with logging of request/response.

func (*Service) PrestoGetIndexSplits

func (s *Service) PrestoGetIndexSplits(schemaTableName *presto.PrestoThriftSchemaTableName, indexColumnNames []string, outputColumnNames []string, keys *presto.PrestoThriftPageResult, outputConstraint *presto.PrestoThriftTupleDomain, maxSplitCount int32, nextToken *presto.PrestoThriftNullableToken) (*presto.PrestoThriftSplitBatch, error)

PrestoGetIndexSplits returns a batch of index splits for the given batch of keys.

func (*Service) PrestoGetRows

func (s *Service) PrestoGetRows(splitID *presto.PrestoThriftId, columns []string, maxBytes int64, nextToken *presto.PrestoThriftNullableToken) (*presto.PrestoThriftPageResult, error)

PrestoGetRows returns a batch of rows for the given split.

func (*Service) PrestoGetSplits

func (s *Service) PrestoGetSplits(schemaTableName *presto.PrestoThriftSchemaTableName, desiredColumns *presto.PrestoThriftNullableColumnSet, outputConstraint *presto.PrestoThriftTupleDomain, maxSplitCount int32, nextToken *presto.PrestoThriftNullableToken) (*presto.PrestoThriftSplitBatch, error)

PrestoGetSplits returns a batch of splits.

func (*Service) PrestoGetTableMetadata

func (s *Service) PrestoGetTableMetadata(schemaTableName *presto.PrestoThriftSchemaTableName) (*presto.PrestoThriftNullableTableMetadata, error)

PrestoGetTableMetadata returns metadata for a given table.

func (*Service) PrestoListSchemaNames

func (s *Service) PrestoListSchemaNames() ([]string, error)

PrestoListSchemaNames returns available schema names.

func (*Service) PrestoListTables

func (s *Service) PrestoListTables(schemaNameOrNull *presto.PrestoThriftNullableSchemaName) ([]*presto.PrestoThriftSchemaTableName, error)

PrestoListTables returns tables for the given schema name.