gluonts.nursery.pipeline package#

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

Bases: object

apply(stream)[source]#
apply_one(data)[source]#
apply_schema(schema)[source]#
bind(schema)[source]#
requires()[source]#
class gluonts.nursery.pipeline.Copy[source]#

Bases: gluonts.nursery.pipeline.action.Map

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

Bases: gluonts.nursery.pipeline.action.Action

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

Bases: gluonts.nursery.pipeline.action.Map

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

Bases: gluonts.nursery.pipeline.action.Action

apply(stream)[source]#
class gluonts.nursery.pipeline.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.Remove(name: str)[source]#

Bases: gluonts.nursery.pipeline.action.Map

apply_schema(schema)[source]#
name: str#
class gluonts.nursery.pipeline.Schema(fields: Dict[str, Type] = <factory>)[source]#

Bases: object

add(name: str, ty: Type, force=False) → gluonts.nursery.pipeline.schema.Schema[source]#
copy()[source]#
classmethod dryrun(pipeline)[source]#
fields: Dict[str, Type]#
get(key, default)[source]#
classmethod infer(data)[source]#
pop(name: str) → gluonts.nursery.pipeline.schema.Schema[source]#
remove(name: str, ignore_missing=False) → gluonts.nursery.pipeline.schema.Schema[source]#
union(name: str, ty: Type) → gluonts.nursery.pipeline.schema.Schema[source]#
validate(entry: dict)[source]#
class gluonts.nursery.pipeline.SchemaTracker(output_schema: Dict[str, Type] = <factory>, input_schema: Dict[str, Type] = <factory>)[source]#

Bases: object

add(name: str, ty: Type, force=False) → gluonts.nursery.pipeline.schema.Schema[source]#
copy()[source]#
input_schema: Dict[str, Type]#
output_schema: Dict[str, Type]#
pop(name: str) → gluonts.nursery.pipeline.schema.Schema[source]#
remove(name: str, ignore_missing=False) → gluonts.nursery.pipeline.schema.Schema[source]#
union(name: str, ty: Type) → gluonts.nursery.pipeline.schema.Schema[source]#
class gluonts.nursery.pipeline.Set(name: str, value: Any)[source]#

Bases: gluonts.nursery.pipeline.action.Map

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

Bases: gluonts.nursery.pipeline.action.Map

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

Bases: gluonts.nursery.pipeline.action.Map

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

Bases: gluonts.nursery.pipeline.action.Map

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