Method collect_query_buffer

join/LSH/datasketch/lsh.py:235–255

Execute and return buffered queries given by `add_to_query_buffer`. If multiple query MinHash were added to the query buffer, the intersection of the results of all query MinHash will be returned. Returns: `list` of unique keys.

(self)

            hashtable.add_to_select_buffer([H])

    def collect_query_buffer(self):
        '''
        Execute and return buffered queries given
        by `add_to_query_buffer`.

        If multiple query MinHash were added to the query buffer,
        the intersection of the results of all query MinHash will be returned.

        Returns:
            `list` of unique keys.
        '''
        collected_result_sets = [
            set(collected_result_lists)
            for hashtable in self.hashtables
            for collected_result_lists in hashtable.collect_select_buffer()
        ]
        if not collected_result_sets:
            return []
        if self.prepickle:
            return [pickle.loads(key) for key in set.intersection(*collected_result_sets)]
        return list(set.intersection(*collected_result_sets))

    # def __contains__(self, key):
    #     '''