(self, name, log)
Init TableState for one table.
Init TableState for one table.
Init TableState for one table .
def __init__(self, name, log):
        """Init TableState for one table."""
        self.name = name
        self.dest_table = name
        self.log = log
        # same as forget:
        self.state = TABLE_MISSING
        self.last_snapshot_tick = None
        self.str_snapshot = None
        self.from_snapshot = None
        self.sync_tick_id = None
        self.ok_batch_count = 0
        self.last_tick = 0
        self.table_attrs = {}
        self.copy_role = None
        self.dropped_ddl = None
        self.plugin = None
        # except this
        self.changed = 0
        # position in parallel copy work order
        self.copy_pos = 0
        # max number of parallel copy processes allowed
        self.max_parallel_copy = MAX_PARALLEL_COPY
def __init__ ( self , name , log ) : self . name = name self . dest_table = name self . log = log # same as forget: self . state = TABLE_MISSING self . last_snapshot_tick = None self . str_snapshot = None self . from_snapshot = None self . sync_tick_id = None self . ok_batch_count = 0 self . last_tick = 0 self . table_attrs = { } self . copy_role = None self . dropped_ddl = None self . plugin = None # except this self . changed = 0 # position in parallel copy work order self . copy_pos = 0 # max number of parallel copy processes allowed self . max_parallel_copy = MAX_PARALLEL_COPY