`artemis.algorithms.filteralgo`¶

Efficient filtering algorithm to slim columns from input record batches and materialize new record batches.

Module Contents¶

class artemis.algorithms.filteralgo.FilterAlgo(name, **kwargs)¶

Bases: artemis.core.algo.AlgoBase

initialize(self)¶

book(self)¶

rebook(self)¶

filter_columns(self, record_batch)¶

execute(self, element)¶

finalize(self)¶