Documentation ¶ Index ¶ type Proc func New(ctx context.Context, parents []proc.Interface, cmp expr.CompareFn) *Proc func (m *Proc) Done() func (m *Proc) Pull() (zbuf.Batch, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Proc ¶ type Proc struct { // contains filtered or unexported fields } A Merge proc merges multiple upstream inputs into one output. If the input streams are ordered according to the configured comparison, the output of Merge will have the same order. func New ¶ func New(ctx context.Context, parents []proc.Interface, cmp expr.CompareFn) *Proc func (*Proc) Done ¶ func (m *Proc) Done() func (*Proc) Pull ¶ func (m *Proc) Pull() (zbuf.Batch, error) Source Files ¶ View all Source files merge.go Click to show internal directories. Click to hide internal directories.
Documentation
¶
Source Files