def consume_batch_async(self, batch):
        assert False, "unimplemented"
Create an instance of RowFieldFilter. `indexes` is a list of indexes that are passed
dataset/ETHPy150Open membase/membase-cli/pump.py/Sink.consume_batch_async--crossover with--dataset/ETHPy150Open Stiivi/brewery/brewery/metadata.py/RowFieldFilter.__init__