reportingutil

Documentation

Index

• Variables
• func AWSBillingPeriodTimestamp(date time.Time) string
• func ConvertInputDefinitionsIntoInputList(defs []metering.ReportQueryInputDefinition) (required []string)
• func DataSourceTableName(namespace, dataSourceName string) string
• func FullyQualifiedTableName(prestoTable *metering.PrestoTable) (string, error)
• func GenerateHiveColumns(query *metering.ReportQuery) []hive.Column
• func GeneratePrestoColumns(query *metering.ReportQuery) []presto.Column
• func HiveColumnToPrestoColumn(column hive.Column) (presto.Column, error)
• func HiveColumnsToPrestoColumns(columns []hive.Column) ([]presto.Column, error)
• func IsValidSQLIdentifier(id string) bool
• func PrestoColumnToHiveColumn(column presto.Column) (hive.Column, error)
• func PrestoColumnsToHiveColumns(columns []presto.Column) ([]hive.Column, error)
• func ReportTableName(namespace, reportName string) string
• func SimpleHiveColumnTypeToPrestoColumnType(colType string) string
• func SimplePrestoColumnTypeToHiveColumnType(colType string) string
• func TableResourceNameFromKind(kind, namespace, name string) string
• func TruncateToMinute(t time.Time) time.Time

Variables

var (

	// AWSUsagePartitionDateStringLayout is the format used to partition
	// AWSUsage partition key
	AWSUsagePartitionDateStringLayout = "20060102"
)

Functions

func AWSBillingPeriodTimestamp

func AWSBillingPeriodTimestamp(date time.Time) string

func ConvertInputDefinitionsIntoInputList

func ConvertInputDefinitionsIntoInputList(defs []metering.ReportQueryInputDefinition) (required []string)

func DataSourceTableName

func DataSourceTableName(namespace, dataSourceName string) string

func FullyQualifiedTableName

func FullyQualifiedTableName(prestoTable *metering.PrestoTable) (string, error)

func GenerateHiveColumns

func GenerateHiveColumns(query *metering.ReportQuery) []hive.Column

func GeneratePrestoColumns

func GeneratePrestoColumns(query *metering.ReportQuery) []presto.Column

func HiveColumnToPrestoColumn

func HiveColumnToPrestoColumn(column hive.Column) (presto.Column, error)

func HiveColumnsToPrestoColumns

func HiveColumnsToPrestoColumns(columns []hive.Column) ([]presto.Column, error)

func IsValidSQLIdentifier

func IsValidSQLIdentifier(id string) bool

func PrestoColumnToHiveColumn

func PrestoColumnToHiveColumn(column presto.Column) (hive.Column, error)

func PrestoColumnsToHiveColumns

func PrestoColumnsToHiveColumns(columns []presto.Column) ([]hive.Column, error)

func ReportTableName

func ReportTableName(namespace, reportName string) string

func SimpleHiveColumnTypeToPrestoColumnType

func SimpleHiveColumnTypeToPrestoColumnType(colType string) string

func SimplePrestoColumnTypeToHiveColumnType

func SimplePrestoColumnTypeToHiveColumnType(colType string) string

func TableResourceNameFromKind

func TableResourceNameFromKind(kind, namespace, name string) string

func TruncateToMinute

func TruncateToMinute(t time.Time) time.Time