BranchingPipeline(branches[, merger])
|
|
CachablePipeline(cache_dir, no_cache_pipe, ...)
|
|
Constant(value)
|
Constant. |
Contains(item[, negate])
|
Check if an item is in a collection. |
ContainsAll(items[, negate])
|
Check if a subset of items in a collection. |
DataPrinter([silent])
|
|
EmptyRemover()
|
|
EmptySkipper([step])
|
|
EnsureIterable([step])
|
|
Eval(expr[, imports])
|
Evaluate string. |
EvalFromImport(import_)
|
Evaluate imported function. |
ExceptionToWarning(step[, warn])
|
|
Filter(func[, collection_type, to_iter])
|
|
FunctionCaller(func, **kwargs)
|
Calls a function with preset kwargs. |
IdentityStep()
|
|
IfCondition(step, else_step, condition)
|
|
IfEmpty(step, else_step)
|
|
IndexMap(step[, index])
|
|
IndexSelector([index, repeat, step])
|
|
Lambda(args, expr[, imports])
|
Evaluate lambda function. |
ListSqueeze([raise_])
|
|
Listify()
|
|
Map(step[, n_jobs, verbose, force_iter])
|
|
MethodApplier(*args, method, **kwargs)
|
Applies a named method with preset args and kwargs. |
NestingSwapper()
|
|
NoneRemover()
|
|
NoneSkipper([step])
|
|
ParMap(step[, n_jobs, verbose])
|
|
PartiallyInitializedStep(Step[, pass_data])
|
Instantiate a step based on data. |
Pipeline(steps[, data])
|
|
Prefix(prefix)
|
|
PreprocessingStep()
|
Preprocessing step. |
RemoveIndex([index, inplace])
|
|
SerialMap(step[, pbar])
|
|
Sorter([key])
|
|
StepWithLogging(step, msg)
|
|
StepWrappingPreprocessingStep([step])
|
|
Truncater(value)
|
|
TupleWith(step[, incoming_first])
|
|
TupleWithIncoming(step)
|
|
Unnest()
|
|
WrapInList()
|
|