def __init__(self):
        self.anomaly_url = self.url + ANOMALY_PATH
Subclasses should return a SinkBatchFuture.
dataset/ETHPy150Open bigmlcom/python/bigml/anomalyhandler.py/AnomalyHandler.__init__--crossover with--dataset/ETHPy150Open membase/membase-cli/pump.py/Sink.consume_batch_async