bigquery

package
v1.0.18 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2024 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BigQueryServer

type BigQueryServer struct {
	CredentialsJsonString string `mapstructure:"credentials_json" schema:"credentials_json" form:"label:Credentials JSON String,type:textarea"`
	Location              string `mapstructure:"location" schema:"location" form:"label:Location,type:text"`

	// this will be implemented during runtime
	GCSBucketName string `mapstructure:"gcs_bucket_name" schema:"gcs_bucket_name" form:"label:GCS Bucket Name,type:text"`
	GCSFilePrefix string `mapstructure:"gcs_file_prefix" schema:"gcs_file_prefix" form:"label:GCS File Prefix,type:text"`

	DeleteFromGCS bool `mapstructure:"delete_from_gcs" schema:"delete_from_gcs" form:"label:Delete From GCS,type:bool"`

	Credentials *google.Credentials
	// contains filtered or unexported fields
}

func OpenServer

func OpenServer(settings map[string]interface{}) (*BigQueryServer, error)

func (*BigQueryServer) Close

func (s *BigQueryServer) Close() error

func (*BigQueryServer) Columns added in v1.0.9

func (b *BigQueryServer) Columns(table string) ([]models.Column, error)

func (*BigQueryServer) CreateColumns

func (s *BigQueryServer) CreateColumns(table string, fileName string) error

func (*BigQueryServer) CreateEmptyTable

func (s *BigQueryServer) CreateEmptyTable(name string) error

func (*BigQueryServer) InsertFromNDJsonFile

func (s *BigQueryServer) InsertFromNDJsonFile(table string, filePath string) error

func (*BigQueryServer) QueryCSV

func (b *BigQueryServer) QueryCSV(query string, writer io.Writer) error

func (*BigQueryServer) QueryJSON

func (b *BigQueryServer) QueryJSON(query string, writer io.Writer) error

func (*BigQueryServer) QueryNDJson added in v1.0.11

func (s *BigQueryServer) QueryNDJson(query string, writer io.Writer) error

func (*BigQueryServer) Tables added in v1.0.9

func (b *BigQueryServer) Tables() ([]string, error)

func (*BigQueryServer) UploadAndStream

func (s *BigQueryServer) UploadAndStream(table string, filePath string) error

Jump to

Keyboard shortcuts

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