def __getitem__(self, index):
        record = self.resultset.__getitem__(index)

        array = []

        for field in self.field_names:
            value = record
            for key in field.split('.'):
                if key in value:
                    value = value[key]
                else:
                    break
            array.append(value)

        return tuple(array)
dataset/ETHPy150Open Stiivi/brewery/brewery/ds/elasticsearch_streams.py/ESRowIterator.__getitem__/original