(self, table_name, args, dest_table)
Init per-batch table data cache.
Init per-batch table data cache.
Init per - batch table data cache .
def __init__(self, table_name, args, dest_table):
        """Init per-batch table data cache."""

        BaseHandler.__init__(self, table_name, args, dest_table)

        self.pkey_list = None
        self.dist_fields = None
        self.col_list = None

        self.pkey_ev_map = {}
        self.method = int(args.get('method', DEFAULT_METHOD))
        if not self.method in (0,1,2):
            raise Exception('unknown method: %s' % self.method)

        self.log.debug('bulk_init(%r), method=%d', args, self.method)
def __init__ ( self , table_name , args , dest_table ) : BaseHandler . __init__ ( self , table_name , args , dest_table ) self . pkey_list = None self . dist_fields = None self . col_list = None self . pkey_ev_map = { } self . method = int ( args . get ( 'method' , DEFAULT_METHOD ) ) if not self . method in ( 0 , 1 , 2 ) : raise Exception ( 'unknown method: %s' % self . method ) self . log . debug ( 'bulk_init(%r), method=%d' , args , self . method )