We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6da89dc commit 5908cfdCopy full SHA for 5908cfd
row/row.go
@@ -342,12 +342,10 @@ func (pb *Base) Flush() error {
342
// to pb.commit, it should be written in the same order to the Sink.
343
// TODO improve Annotatable architecture.
344
func (pb *Base) Put(row Annotatable) {
345
- log.Println("append")
346
rows := pb.buf.Append(row)
347
pb.stats.Inc()
348
349
if rows != nil {
350
- log.Println("commit")
351
pb.stats.MoveToPending(len(rows))
352
// TODO consider making this asynchronous.
353
err := pb.commit(rows)
0 commit comments