Documentation ¶
Index ¶
- type BigQueryServer
- func (s *BigQueryServer) Close() error
- func (b *BigQueryServer) Columns(table string) ([]models.Column, error)
- func (s *BigQueryServer) CreateColumns(table string, fileName string) error
- func (s *BigQueryServer) CreateEmptyTable(name string) error
- func (s *BigQueryServer) InsertFromNDJsonFile(table string, filePath string) error
- func (b *BigQueryServer) QueryCSV(query string, writer io.Writer) error
- func (b *BigQueryServer) QueryJSON(query string, writer io.Writer) error
- func (s *BigQueryServer) QueryNDJson(query string, writer io.Writer) error
- func (b *BigQueryServer) Tables() ([]string, error)
- func (s *BigQueryServer) UploadAndStream(table string, filePath string) error
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
Click to show internal directories.
Click to hide internal directories.