def _assert_cdc_data_readable_on_round_trip(self, start_with_cdc_enabled):
    '\n        Parameterized test asserting that data written to a table is still\n        readable after flipping the CDC flag on that table, then flipping it\n        again. Starts with CDC enabled if start_with_cdc_enabled, otherwise\n        starts with it disabled.\n        '
    (ks_name, table_name) = ('ks', 'tab')
    sequence = ([True, False, True] if start_with_cdc_enabled else [False, True, False])
    (start_enabled, alter_path) = (sequence[0], list(sequence[1:]))
    (node, session) = self.prepare(ks_name=ks_name, table_name=table_name, cdc_enabled_table=start_enabled, column_spec='a int PRIMARY KEY, b int')
    set_cdc = _get_set_cdc_func(session=session, ks_name=ks_name, table_name=table_name)
    insert_stmt = session.prepare((('INSERT INTO ' + table_name) + ' (a, b) VALUES (?, ?)'))
    start = 0
    stop = 1000
    step = 1
    data = [(n, min((n + step), stop)) for n in range(start, stop, step)]
    execute_concurrent_with_args(session, insert_stmt, data)
    assert ([] == list(node.get_sstables(ks_name, table_name)))
    for enable in alter_path:
        set_cdc(enable)
        assert_resultset_contains(session.execute(('SELECT * FROM ' + table_name)), data)
Parameterized test asserting that data written to a table is still
readable after flipping the CDC flag on that table, then flipping it
again. Starts with CDC enabled if start_with_cdc_enabled, otherwise
starts with it disabled.
def _assert_cdc_data_readable_on_round_trip(self, start_with_cdc_enabled):
    '\n        Parameterized test asserting that data written to a table is still\n        readable after flipping the CDC flag on that table, then flipping it\n        again. Starts with CDC enabled if start_with_cdc_enabled, otherwise\n        starts with it disabled.\n        '
    (ks_name, table_name) = ('ks', 'tab')
    sequence = ([True, False, True] if start_with_cdc_enabled else [False, True, False])
    (start_enabled, alter_path) = (sequence[0], list(sequence[1:]))
    (node, session) = self.prepare(ks_name=ks_name, table_name=table_name, cdc_enabled_table=start_enabled, column_spec='a int PRIMARY KEY, b int')
    set_cdc = _get_set_cdc_func(session=session, ks_name=ks_name, table_name=table_name)
    insert_stmt = session.prepare((('INSERT INTO ' + table_name) + ' (a, b) VALUES (?, ?)'))
    start = 0
    stop = 1000
    step = 1
    data = [(n, min((n + step), stop)) for n in range(start, stop, step)]
    execute_concurrent_with_args(session, insert_stmt, data)
    assert ([] == list(node.get_sstables(ks_name, table_name)))
    for enable in alter_path:
        set_cdc(enable)
        assert_resultset_contains(session.execute(('SELECT * FROM ' + table_name)), data)