Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchWriter ¶
type BatchWriter struct { Writer *Writer Serializer *RowSerializer FlushEnabled bool }
func NewBatchWriter ¶
func NewBatchWriter(w *Writer, s *RowSerializer, flushEnabled bool) *BatchWriter
func (*BatchWriter) Flush ¶
func (w *BatchWriter) Flush() (rows int)
type BigQueryConn ¶
type BigQueryConn struct { ProjectId string WriterClient *managedwriter.Client QueryClient *bigquery.Client }
type RowSerializer ¶
type RowSerializer struct {
// contains filtered or unexported fields
}
func NewRowSerializer ¶
func NewRowSerializer(buffers int) *RowSerializer
func (*RowSerializer) Rows ¶
func (s *RowSerializer) Rows(fn func(rows [][]byte)) (nrRows int)
Rows is used by another routine than Serialize.
func (*RowSerializer) Serialize ¶
func (s *RowSerializer) Serialize(row *v1.Row)
Serialize is used by the same routine that does Append (the cmdhandler routine).
Click to show internal directories.
Click to hide internal directories.