(self, src_curs, dst_curs)
return w
Prepare the where condition for copy and replay filtering
Prepare the where condition for copy and replay filtering
Prepare the where condition for copy and replay filtering
def get_copy_condition(self, src_curs, dst_curs):
        """Prepare the where condition for copy and replay filtering"""
        if self.hash_key is None:
            return TableHandler.get_copy_condition(self, src_curs, dst_curs)
        self.load_shard_info(dst_curs)
        w = "(%s & %d) = %d" % (self.hashexpr, self.hash_mask, self.shard_nr)
        self.log.debug('shard: copy_condition=%r', w)
        return w
def get_copy_condition ( self , src_curs , dst_curs ) : if self . hash_key is None : return TableHandler . get_copy_condition ( self , src_curs , dst_curs ) self . load_shard_info ( dst_curs ) w = "(%s & %d) = %d" % ( self . hashexpr , self . hash_mask , self . shard_nr ) self . log . debug ( 'shard: copy_condition=%r' , w ) return w