Module plmbr.pipes

A collection of reusable pipes.

Classes

class append (to)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator)

class batch (batch_size=64)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, it: Iterator) -> Iterator

class catch (catch=None)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, it: Iterator) -> Iterator

class drop_fields (*fields: str)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator[Dict]) -> Iterator[Dict]

class json_dumps

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator) -> Iterator

class json_loads

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator) -> Iterator

class keep (filter)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator) -> Iterator

class log

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator) -> Iterator

class null

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator) -> Iterator

class progress (**kwargs)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, it: Iterator) -> Iterator

class sample (prob, seed=2020)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator[Dict]) -> Iterator[Dict]

class save (file)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator)

class tee (*pipes)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator) -> Iterator

class to (f: Callable)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator) -> Iterator

class unbatch

Ancestors

• Pipe
• Handler

Methods

def pipe(self, lists: Iterator) -> Iterator

class uniq (*fields: str)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, items: Iterator[Dict]) -> Iterator[Dict]

class window (size)

Ancestors

• Pipe
• Handler

Methods

def pipe(self, it: Iterator) -> Iterator[tuple]