func (p *TCPInfoParser) Committed() int {
	return p.GetStats().Committed
}
Committed returns the count of rows successfully committed to BQ.
package parser
import (
	"bytes"
	"io"
	"log"
	"strings"
	"time"
	"cloud.google.com/go/bigquery"
	"github.com/valyala/gozstd"
	v2as "github.com/m-lab/annotation-service/api/v2"
	"github.com/m-lab/tcp-info/netlink"
	"github.com/m-lab/tcp-info/snapshot"
	"github.com/m-lab/etl/etl"
	"github.com/m-lab/etl/metrics"
	"github.com/m-lab/etl/row"
	"github.com/m-lab/etl/schema"
)
type TCPInfoParser struct {
	*row.Base
	table  string
	suffix string
}
func (p *TCPInfoParser) RowsInBuffer() int {
	return p.GetStats().Pending
}