Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BigQueryReadCallOptions ¶
type BigQueryReadCallOptions struct {
CreateReadSession []gax.CallOption
ReadRows []gax.CallOption
}
type BigQueryReadClient ¶
type BigQueryReadClient struct {
// contains filtered or unexported fields
}
func NewBigQueryReadClient ¶
func NewBigQueryReadClient(ctx context.Context, opts ...option.ClientOption) (*BigQueryReadClient, error)
func (*BigQueryReadClient) NewBigQueryReader ¶
func (bq *BigQueryReadClient) NewBigQueryReader(ctx context.Context, projectID, datasetID, tableID string) (*BigQueryReader, error)
NewBigQueryReader creates a new BigQueryReader for the specified table
type BigQueryReader ¶
type BigQueryReader struct {
// contains filtered or unexported fields
}
func (*BigQueryReader) Close ¶
func (r *BigQueryReader) Close() error
Close closes the BigQueryReader and releases resources
type BigQueryRecordWriter ¶
type BigQueryRecordWriter struct {
// contains filtered or unexported fields
}
func NewBigQueryRecordWriter ¶
func NewBigQueryRecordWriter(ctx context.Context, client *BigQueryWriteClient, projectID, datasetID, tableID string, opts *BigQueryWriteOptions) (*BigQueryRecordWriter, error)
func (*BigQueryRecordWriter) Close ¶
func (w *BigQueryRecordWriter) Close() error
type BigQueryWriteClient ¶
type BigQueryWriteClient struct {
// contains filtered or unexported fields
}
func NewBigQueryWriteClient ¶
type BigQueryWriteOptions ¶
type BigQueryWriteOptions struct {
WriteStreamType storagepb.WriteStream_Type
Allocator memory.Allocator
}
func NewDefaultBigQueryWriteOptions ¶
func NewDefaultBigQueryWriteOptions() *BigQueryWriteOptions
Source Files
Click to show internal directories.
Click to hide internal directories.