uniq

package

v0.31.0 Latest Latest Go to latest Published: Oct 4, 2021 License: BSD-3-Clause Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Proc struct {
	// contains filtered or unexported fields
}

func New(pctx *proc.Context, parent proc.Interface, cflag bool) *Proc

func (p *Proc) Done()

func (p *Proc) Pull() (zbuf.Batch, error)

uniq is a little bit complicated because we have to check uniqueness across records between calls to Pull.