path

Documentation

Index

• type RenameOperator
  • func PathsRename(columnNames ...string) *RenameOperator
  • func (op *RenameOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error
  • func (op *RenameOperator) String() string
• type SetOperator
  • func Set(path object.Path, e expr.Expr) *SetOperator
  • func (op *SetOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error
  • func (op *SetOperator) String() string
• type UnsetOperator
  • func Unset(field string) *UnsetOperator
  • func (op *UnsetOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error
  • func (op *UnsetOperator) String() string

Types

type RenameOperator

type RenameOperator struct {
	stream.BaseOperator
	ColumnNames []string
}

An RenameOperator iterates over all columns of the incoming row in order and renames them.

func PathsRename

func PathsRename(columnNames ...string) *RenameOperator

PathsRename iterates over all columns of the incoming row in order and renames them. If the number of columns of the incoming row doesn't match the number of expected fields, it returns an error.

func (*RenameOperator) Iterate

func (op *RenameOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error

Iterate implements the Operator interface.

func (*RenameOperator) String

func (op *RenameOperator) String() string

type SetOperator

type SetOperator struct {
	stream.BaseOperator
	Path object.Path
	Expr expr.Expr
}

A SetOperator sets the value of a column or nested field in the current row.

func Set

func Set(path object.Path, e expr.Expr) *SetOperator

Set returns a SetOperator that sets the value of a column or nested field in the current row.

func (*SetOperator) Iterate

func (op *SetOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error

Iterate implements the Operator interface.

func (*SetOperator) String

func (op *SetOperator) String() string

type UnsetOperator

type UnsetOperator struct {
	stream.BaseOperator
	Column string
}

A UnsetOperator unsets the value of a column in the current row.

func Unset

func Unset(field string) *UnsetOperator

Unset returns a UnsetOperator that unsets the value of a column in the current row.

func (*UnsetOperator) Iterate

func (op *UnsetOperator) Iterate(in *environment.Environment, f func(out *environment.Environment) error) error

Iterate implements the Operator interface.

func (*UnsetOperator) String

func (op *UnsetOperator) String() string