hive

Documentation

Index

• func ExecuteCreateDatabase(execer db.Execer, params DatabaseParameters) error
• func ExecuteCreateTable(execer db.Execer, params TableParameters, ignoreExists bool) error
• func ExecuteDropDatabase(execer db.Execer, dbName string, ignoreNotExists, cascade bool) error
• func ExecuteDropTable(execer db.Execer, dbName, tableName string, ignoreNotExists bool) error
• func S3Location(bucket, prefix string) (string, error)
• type Column
• type DatabaseParameters
• type PartitionSpec
• type SortColumn
• type TableParameters
• type TablePartition

Functions

func ExecuteCreateDatabase

func ExecuteCreateDatabase(execer db.Execer, params DatabaseParameters) error

func ExecuteCreateTable

func ExecuteCreateTable(execer db.Execer, params TableParameters, ignoreExists bool) error

func ExecuteDropDatabase

func ExecuteDropDatabase(execer db.Execer, dbName string, ignoreNotExists, cascade bool) error

func ExecuteDropTable

func ExecuteDropTable(execer db.Execer, dbName, tableName string, ignoreNotExists bool) error

func S3Location

func S3Location(bucket, prefix string) (string, error)

s3Location returns the HDFS path based on an S3 bucket and prefix.

Types

type Column

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

type DatabaseParameters

type DatabaseParameters struct {
	Name     string `json:"name"`
	Location string `json:"location"`
}

type PartitionSpec

type PartitionSpec map[string]string

type SortColumn

type SortColumn struct {
	Name      string `json:"name"`
	Decending *bool  `json:"decending,omitempty"`
}

type TableParameters

type TableParameters struct {
	Database      string       `json:"database,omitempty"`
	Name          string       `json:"name"`
	Columns       []Column     `json:"columns"`
	PartitionedBy []Column     `json:"partitionedBy,omitempty"`
	ClusteredBy   []string     `json:"clusteredBy,omitempty"`
	SortedBy      []SortColumn `json:"sortedBy,omitempty"`
	NumBuckets    int          `json:"numBuckets,omitempty"`

	Location        string            `json:"location,omitempty"`
	RowFormat       string            `json:"rowFormat,omitempty"`
	FileFormat      string            `json:"fileFormat,omitempty"`
	TableProperties map[string]string `json:"tableProperties,omitempty"`
	External        bool              `json:"external,omitempty"`
}

type TablePartition

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