def _get_cdc_raw_files(node_path, cdc_raw_dir_name='cdc_raw'):
    commitlog_dir = os.path.join(node_path, cdc_raw_dir_name)
    return {os.path.join(commitlog_dir, name) for name in os.listdir(commitlog_dir)}
def _get_cdc_raw_files(node_path, cdc_raw_dir_name='cdc_raw'):
    commitlog_dir = os.path.join(node_path, cdc_raw_dir_name)
    return {os.path.join(commitlog_dir, name) for name in os.listdir(commitlog_dir)}