dossier/store/elastic.py
def count_bytes(self, filter_preds):
        '''Count bytes of all feature collections whose key satisfies one of
        the predicates in ``filter_preds``. The byte counts are binned
        by filter predicate.
        '''
        num_bytes = defaultdict(int)
        for hit in self._scan():
            for filter_pred in filter_preds:
                if filter_pred(did(hit['_id'])):
                    num_bytes[filter_pred] += self.fc_bytes(
                        hit['_source']['fc'])
        return num_bytes
def count_bytes(self, filter_preds):
        '''Count bytes of all feature collections whose key satisfies one of
        the predicates in ``filter_preds``. The byte counts are binned
        by filter predicate.
        '''
        num_bytes = defaultdict(int)
        for hit in self._scan():
            for filter_pred in filter_preds:
                if filter_pred(did(hit['_id'])):
                    num_bytes[filter_pred] += self.fc_bytes(
                        hit['_source']['fc'])
        return num_bytes
def count_bytes ( self , filter_preds ) : num_bytes = defaultdict ( int ) for hit in self . _scan ( ) : for filter_pred in filter_preds : if filter_pred ( did ( hit [ '_id' ] ) ) : num_bytes [ filter_pred ] += self . fc_bytes ( hit [ '_source' ] [ 'fc' ] ) return num_bytes
Count bytes of all feature collections whose key satisfies one of
        the predicates in ``filter_preds``. The byte counts are binned
        by filter predicate.
Count bytes of all feature collections whose key satisfies one of the predicates in filter_preds . The byte counts are binned by filter predicate .