The highest tagged major version is
README
¶
transformer
-- import "gopkg.in/Clever/optimus.v3/transformer"
Usage
type Transformer
type Transformer struct {
}
A Transformer allows you to easily chain multiple transforms on a table.
func New
func New(table optimus.Table) *Transformer
New returns a Transformer that allows you to chain transformations on a Table.
func (*Transformer) Apply
func (t *Transformer) Apply(transform optimus.TransformFunc) *Transformer
Apply applies a given TransformFunc to the Transformer.
func (*Transformer) Concat
func (t *Transformer) Concat(tables ...optimus.Table) *Transformer
Concat Applies a Concat transform.
func (*Transformer) Concurrently
func (t *Transformer) Concurrently(fn optimus.TransformFunc, concurrency int) *Transformer
Concurrently Applies a Concurrent transform.
func (*Transformer) Each
func (t *Transformer) Each(transform func(optimus.Row) error) *Transformer
Each Applies an Each transform.
func (*Transformer) Fieldmap
func (t *Transformer) Fieldmap(mappings map[string][]string) *Transformer
Fieldmap Applies a Fieldmap transform.
func (*Transformer) Map
func (t *Transformer) Map(transform func(optimus.Row) (optimus.Row, error)) *Transformer
Map Applies a Map transform.
func (*Transformer) Pair
func (t *Transformer) Pair(rightTable optimus.Table, leftID, rightID transforms.RowIdentifier,
filterFn func(optimus.Row) (bool, error)) *Transformer
Pair Applies a Pair transform.
func (*Transformer) Reduce
func (t *Transformer) Reduce(fn func(optimus.Row, optimus.Row) error) *Transformer
Reduce Applies a Reduce transform.
func (*Transformer) Select
func (t *Transformer) Select(filter func(optimus.Row) (bool, error)) *Transformer
Select Applies a Select transform.
func (*Transformer) Sink
func (t *Transformer) Sink(sink optimus.Sink) error
Sink consumes all the Rows.
func (*Transformer) Sort
func (t *Transformer) Sort(less func(i, j optimus.Row) (bool, error)) *Transformer
Sort Applies a Sort transform.
func (Transformer) Table
func (t Transformer) Table() optimus.Table
Table returns the terminating Table in a Transformer chain.
func (*Transformer) TableTransform
func (t *Transformer) TableTransform(transform func(optimus.Row, chan<- optimus.Row) error) *Transformer
TableTransform Applies a TableTransform transform.
func (*Transformer) Valuemap
func (t *Transformer) Valuemap(mappings map[string]map[interface{}]interface{}) *Transformer
Valuemap Applies a Valuemap transform.
Documentation
¶
Index ¶
- type Transformer
- func (t *Transformer) Apply(transform optimus.TransformFunc) *Transformer
- func (t *Transformer) Concat(tables ...optimus.Table) *Transformer
- func (t *Transformer) Concurrently(fn optimus.TransformFunc, concurrency int) *Transformer
- func (t *Transformer) Each(transform func(optimus.Row) error) *Transformer
- func (t *Transformer) Fieldmap(mappings map[string][]string) *Transformer
- func (t *Transformer) Map(transform func(optimus.Row) (optimus.Row, error)) *Transformer
- func (t *Transformer) Pair(rightTable optimus.Table, leftID, rightID transforms.RowIdentifier, ...) *Transformer
- func (t *Transformer) Reduce(fn func(optimus.Row, optimus.Row) error) *Transformer
- func (t *Transformer) Select(filter func(optimus.Row) (bool, error)) *Transformer
- func (t *Transformer) Sink(sink optimus.Sink) error
- func (t *Transformer) Sort(less func(i, j optimus.Row) (bool, error)) *Transformer
- func (t *Transformer) StableSort(less func(i, j optimus.Row) (bool, error)) *Transformer
- func (t Transformer) Table() optimus.Table
- func (t *Transformer) TableTransform(transform func(optimus.Row, chan<- optimus.Row) error) *Transformer
- func (t *Transformer) Valuemap(mappings map[string]map[interface{}]interface{}) *Transformer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Transformer ¶
type Transformer struct {
// contains filtered or unexported fields
}
A Transformer allows you to easily chain multiple transforms on a table.
func New ¶
func New(table optimus.Table) *Transformer
New returns a Transformer that allows you to chain transformations on a Table.
func (*Transformer) Apply ¶
func (t *Transformer) Apply(transform optimus.TransformFunc) *Transformer
Apply applies a given TransformFunc to the Transformer.
func (*Transformer) Concat ¶
func (t *Transformer) Concat(tables ...optimus.Table) *Transformer
Concat Applies a Concat transform.
func (*Transformer) Concurrently ¶
func (t *Transformer) Concurrently(fn optimus.TransformFunc, concurrency int) *Transformer
Concurrently Applies a Concurrent transform.
func (*Transformer) Each ¶
func (t *Transformer) Each(transform func(optimus.Row) error) *Transformer
Each Applies an Each transform.
func (*Transformer) Fieldmap ¶
func (t *Transformer) Fieldmap(mappings map[string][]string) *Transformer
Fieldmap Applies a Fieldmap transform.
func (*Transformer) Map ¶
func (t *Transformer) Map(transform func(optimus.Row) (optimus.Row, error)) *Transformer
Map Applies a Map transform.
func (*Transformer) Pair ¶
func (t *Transformer) Pair(rightTable optimus.Table, leftID, rightID transforms.RowIdentifier, filterFn func(optimus.Row) (bool, error)) *Transformer
Pair Applies a Pair transform.
func (*Transformer) Reduce ¶
func (t *Transformer) Reduce(fn func(optimus.Row, optimus.Row) error) *Transformer
Reduce Applies a Reduce transform.
func (*Transformer) Select ¶
func (t *Transformer) Select(filter func(optimus.Row) (bool, error)) *Transformer
Select Applies a Select transform.
func (*Transformer) Sink ¶
func (t *Transformer) Sink(sink optimus.Sink) error
Sink consumes all the Rows.
func (*Transformer) Sort ¶
func (t *Transformer) Sort(less func(i, j optimus.Row) (bool, error)) *Transformer
Sort Applies a Sort transform.
func (*Transformer) StableSort ¶
func (t *Transformer) StableSort(less func(i, j optimus.Row) (bool, error)) *Transformer
StableSort Applies a StableSort transform.
func (Transformer) Table ¶
func (t Transformer) Table() optimus.Table
Table returns the terminating Table in a Transformer chain.
func (*Transformer) TableTransform ¶
func (t *Transformer) TableTransform(transform func(optimus.Row, chan<- optimus.Row) error) *Transformer
TableTransform Applies a TableTransform transform.
func (*Transformer) Valuemap ¶
func (t *Transformer) Valuemap(mappings map[string]map[interface{}]interface{}) *Transformer
Valuemap Applies a Valuemap transform.
Source Files