@expose("/autocomplete/<datasource>/<column>/")
    def autocomplete(self, datasource, column):
        client = utils.get_pydruid_client()
        top = client.topn(
            datasource=datasource,
            granularity='all',
            intervals='2013-10-04/2020-10-10',
            aggregations={"count": doublesum("count")},
            dimension=column,
            metric='count',
            threshold=1000,
        )
        values = sorted([d[column] for d in top[0]['result']])
        return json.dumps(values)
Instance of the protocol to use to communicate between steps.
dataset/ETHPy150Open airbnb/caravel/caravel/views.py/Caravel.autocomplete--crossover with--dataset/ETHPy150Open Yelp/mrjob/mrjob/job.py/MRJob.internal_protocol