presto

package

v0.0.0-...-1d44d98 Latest Latest Go to latest Published: Apr 2, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/operator-framework/operator-metering

Documentation ¶

Index ¶

Constants
func CreateTable(queryer db.Queryer, catalog, schema, tableName string, columns []Column, ...) error
func CreateTableAs(queryer db.Queryer, catalog, schema, tableName string, columns []Column, ...) error
func CreateView(queryer db.Queryer, catalog, schema, viewName string, query string, ...) error
func DeleteFrom(queryer db.Queryer, tableName string) error
func DropTable(queryer db.Queryer, catalog, schema, tableName string, ignoreNotExists bool) error
func DropView(queryer db.Queryer, catalog, schema, viewName string, ignoreNotExists bool) error
func FormatInsertQuery(target, query string) string
func FullyQualifiedTableName(catalog, schema, tableName string) string
func GenerateGetRowsSQL(tableName string, columns []Column) string
func GenerateGetRowsSQLWithWhere(tableName string, columns []Column, whereClause string) string
func GenerateOrderBySQL(columns []Column) string
func GenerateQuotedColumnsListSQL(columns []Column) string
func InsertInto(queryer db.Queryer, tableName, query string) error
type Column
- func QueryMetadata(queryer db.Queryer, catalog, schema, tableName string) ([]Column, error)
type PartitionSpec
type Row
- func ExecuteSelect(queryer db.Queryer, query string) ([]Row, error)
- func GetRows(queryer db.Queryer, tableName string, columns []Column) ([]Row, error)
- func GetRowsWhere(queryer db.Queryer, tableName string, columns []Column, whereClause string) ([]Row, error)
type TablePartition

Constants ¶

View Source

const (
	// TimestampFormat is the time format string used to produce Presto timestamps.
	TimestampFormat = "2006-01-02 15:04:05.000"
)

Variables ¶

This section is empty.

Functions ¶

func CreateTable ¶

func CreateTable(queryer db.Queryer, catalog, schema, tableName string, columns []Column, comment string, properties map[string]string, ignoreExists bool) error

func CreateTableAs ¶

func CreateTableAs(queryer db.Queryer, catalog, schema, tableName string, columns []Column, comment string, properties map[string]string, ignoreExists bool, query string) error

func CreateView ¶

func CreateView(queryer db.Queryer, catalog, schema, viewName string, query string, replace bool) error

func DeleteFrom ¶

func DeleteFrom(queryer db.Queryer, tableName string) error

func DropTable ¶

func DropTable(queryer db.Queryer, catalog, schema, tableName string, ignoreNotExists bool) error

func DropView ¶

func DropView(queryer db.Queryer, catalog, schema, viewName string, ignoreNotExists bool) error

func FormatInsertQuery ¶

func FormatInsertQuery(target, query string) string

func FullyQualifiedTableName ¶

func FullyQualifiedTableName(catalog, schema, tableName string) string

func GenerateGetRowsSQL ¶

func GenerateGetRowsSQL(tableName string, columns []Column) string

func GenerateGetRowsSQLWithWhere ¶

func GenerateGetRowsSQLWithWhere(tableName string, columns []Column, whereClause string) string

func GenerateOrderBySQL ¶

func GenerateOrderBySQL(columns []Column) string

func GenerateQuotedColumnsListSQL ¶

func GenerateQuotedColumnsListSQL(columns []Column) string

func InsertInto ¶

func InsertInto(queryer db.Queryer, tableName, query string) error

Types ¶

type Column ¶

type Column struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

func QueryMetadata ¶

func QueryMetadata(queryer db.Queryer, catalog, schema, tableName string) ([]Column, error)

QueryMetadata executes a "DESCRIBE" Presto query against an existing, fully-qualified table name to determine that table's column information.

type PartitionSpec ¶

type PartitionSpec map[string]string

type Row ¶

type Row map[string]interface{}

func ExecuteSelect ¶

func ExecuteSelect(queryer db.Queryer, query string) ([]Row, error)

ExecuteSelectQuery performs the query on the table target. It's expected target has the correct schema.

func GetRows ¶

func GetRows(queryer db.Queryer, tableName string, columns []Column) ([]Row, error)

func GetRowsWhere ¶

func GetRowsWhere(queryer db.Queryer, tableName string, columns []Column, whereClause string) ([]Row, error)

type TablePartition ¶

type TablePartition struct {
	Location      string        `json:"location"`
	PartitionSpec PartitionSpec `json:"partitionSpec"`
}

Source Files ¶

View all Source files

util.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL