Module plmbr.pipe
Functions
def set_handler(*hs: Handler)
Classes
class Handler-
Subclasses
Class variables
var catch : Union[NoneType, Callable]
Methods
def throw(self, e: Exception)
class Pipe-
Ancestors
Subclasses
- pipe
- append
- batch
- catch
- drop_fields
- json_dumps
- json_loads
- keep
- log
- null
- progress
- sample
- save
- tee
- to
- unbatch
- uniq
- window
Methods
def pipe(self, it: Iterator) -> Iterator
class Tap (it)-
Ancestors
class pipe (action)-
Ancestors
Methods
def pipe(self, it)