combine

Documentation

Overview

A combine proc merges multiple upstream inputs into one output.

Index

• type Proc
  • func New(pctx *op.Context, parents []zbuf.Puller) *Proc
  • func (p *Proc) Pull(done bool) (zbuf.Batch, error)

Types

type Proc

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

func New

func New(pctx *op.Context, parents []zbuf.Puller) *Proc

func (*Proc) Pull

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