gluonts.nursery.pipeline.action module#

class gluonts.nursery.pipeline.action.Action[source]#

Bases: object

apply(stream)[source]#
apply_one(data)[source]#
apply_schema(schema)[source]#
bind(schema)[source]#
requires()[source]#
class gluonts.nursery.pipeline.action.Bind(action: gluonts.nursery.pipeline.action.Action, input_schema: 'Schema', output_schema: 'Schema')[source]#

Bases: gluonts.nursery.pipeline.action.Action

action: gluonts.nursery.pipeline.action.Action#
apply(stream)[source]#
input_schema: Schema#
output_schema: Schema#
class gluonts.nursery.pipeline.action.Copy[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
class gluonts.nursery.pipeline.action.Filter[source]#

Bases: gluonts.nursery.pipeline.action.Action

apply(data)[source]#
apply_schema(schema)[source]#
filter(data)[source]#
class gluonts.nursery.pipeline.action.Identity[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
class gluonts.nursery.pipeline.action.Map[source]#

Bases: gluonts.nursery.pipeline.action.Action

apply(stream)[source]#
class gluonts.nursery.pipeline.action.MapPipeline(actions: List[gluonts.nursery.pipeline.action.Action])[source]#

Bases: gluonts.nursery.pipeline.action.Pipeline, gluonts.nursery.pipeline.action.Map

actions: List[gluonts.nursery.pipeline.action.Action]#
class gluonts.nursery.pipeline.action.Move(source: str, target: str)[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
source: str#
target: str#
class gluonts.nursery.pipeline.action.Pipeline(actions: List[gluonts.nursery.pipeline.action.Action])[source]#

Bases: gluonts.nursery.pipeline.action.Action

actions: List[gluonts.nursery.pipeline.action.Action]#
apply(stream)[source]#
apply_schema(schema)[source]#
class gluonts.nursery.pipeline.action.Remove(name: str)[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
name: str#
class gluonts.nursery.pipeline.action.Set(name: str, value: Any)[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
name: str#
value: Any#
class gluonts.nursery.pipeline.action.SetDefault(name: str, value: Any)[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
name: str#
value: Any#
class gluonts.nursery.pipeline.action.Update(fields: Dict[str, Type])[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
fields: Dict[str, Type]#
class gluonts.nursery.pipeline.action.UpdateDefault(fields: Dict[str, Type])[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
fields: Dict[str, Type]#