Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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