bq

Documentation

Index

• func DatasetFromProject(bqConfig *config.BQConfig, project string) string
• func TableFromKafkaTopic(kafkaTopic string) string
• func TableFromObservationService(bqConfig *config.BQConfig, observationServiceName string) string

Functions

func DatasetFromProject

func DatasetFromProject(bqConfig *config.BQConfig, project string) string

DatasetFromProject create BQ dataset name from a project and prefix it with the BQConfig.BQDatasetPrefix

func TableFromKafkaTopic

func TableFromKafkaTopic(kafkaTopic string) string

TableFromKafkaTopic create BQ table name from a given kafka topic.

func TableFromObservationService

func TableFromObservationService(bqConfig *config.BQConfig, observationServiceName string) string

TableFromObservationService create BQ table name from observation service name and prefix it with BQConfig.ObservationBQTablePrefix