Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RenameIterator ¶ added in v0.17.0
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 columns, it returns an error.
func (*RenameOperator) Columns ¶ added in v0.17.0
func (op *RenameOperator) Columns(env *environment.Environment) ([]string, error)
func (*RenameOperator) Iterator ¶ added in v0.17.0
func (op *RenameOperator) Iterator(in *environment.Environment) (stream.Iterator, error)
Iterate implements the Operator interface.
func (*RenameOperator) String ¶
func (op *RenameOperator) String() string
type SetIterator ¶ added in v0.17.0
type SetOperator ¶
type SetOperator struct {
stream.BaseOperator
Column string
Expr expr.Expr
}
A SetOperator sets the value of a column in the current row.
func Set ¶
func Set(column string, e expr.Expr) *SetOperator
Set returns a SetOperator that sets the value of a column in the current row.
func (*SetOperator) Iterator ¶ added in v0.17.0
func (op *SetOperator) Iterator(in *environment.Environment) (stream.Iterator, error)
Iterate implements the Operator interface.
func (*SetOperator) String ¶
func (op *SetOperator) String() string
Source Files
Click to show internal directories.
Click to hide internal directories.