test_class.declarator: DATA_SOURCE_URL = "jdbc:h2:mem:test_db;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MySQL"
test_class.modifier: private static final
test_class.original_string: private static final String DATA_SOURCE_URL = "jdbc:h2:mem:test_db;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MySQL";
test_class.type: String
test_class.var_name: DATA_SOURCE_URL
test_class.declarator: USERNAME = "root"
test_class.modifier: private static final
test_class.original_string: private static final String USERNAME = "root";
test_class.type: String
test_class.var_name: USERNAME
test_class.declarator: PASSWORD = "password"
test_class.modifier: private static final
test_class.original_string: private static final String PASSWORD = "password";
test_class.type: String
test_class.var_name: PASSWORD
test_class.declarator: shardingScalingJob
test_class.modifier: private
test_class.original_string: private ShardingScalingJob shardingScalingJob;
test_class.type: ShardingScalingJob
test_class.var_name: shardingScalingJob
test_class.declarator: resumeBreakPointManager
test_class.modifier: private
test_class.original_string: private ResumeBreakPointManager resumeBreakPointManager;
test_class.type: ResumeBreakPointManager
test_class.var_name: resumeBreakPointManager
test_class.declarator: syncPositionResumer
test_class.modifier: private
test_class.original_string: private SyncPositionResumer syncPositionResumer;
test_class.type: SyncPositionResumer
test_class.var_name: syncPositionResumer
test_class.file: shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/preparer/resumer/SyncPositionResumerTest.java
test_class.identifier: SyncPositionResumerTest
test_case.body: @Test
      public void assertResumePosition() {
          resumeBreakPointManager.getInventoryPositionManagerMap().put("ds0", new InventoryPositionManager<>(new PrimaryKeyPosition(0, 100)));
          resumeBreakPointManager.getIncrementalPositionManagerMap().put("ds0.t_order", new BasePositionManager<>());
          syncPositionResumer.resumePosition(shardingScalingJob, new DataSourceManager(), resumeBreakPointManager);
          assertThat(shardingScalingJob.getIncrementalDataTasks().size(), is(1));
          assertTrue(shardingScalingJob.getInventoryDataTasks().isEmpty());
      }
test_case.class_method_signature: SyncPositionResumerTest.assertResumePosition()
test_case.full_signature: @Test public void assertResumePosition()
test_case.identifier: assertResumePosition
test_case.invocations: put getInventoryPositionManagerMap put getIncrementalPositionManagerMap resumePosition assertThat size getIncrementalDataTasks is assertTrue isEmpty getInventoryDataTasks
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void assertResumePosition()
focal_class.declarator: syncTaskFactory = new DefaultSyncTaskFactory()
focal_class.modifier: private final
focal_class.original_string: private final SyncTaskFactory syncTaskFactory = new DefaultSyncTaskFactory();
focal_class.type: SyncTaskFactory
focal_class.var_name: syncTaskFactory
focal_class.file: shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/preparer/resumer/SyncPositionResumer.java
focal_class.identifier: SyncPositionResumer
focal_class.class_method_signature: SyncPositionResumer.resumePosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: public void resumePosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: resumePosition
focal_class.modifiers: public
focal_class.parameters: (final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: void
focal_class.signature: void resumePosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.resumeInventoryPosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: private void resumeInventoryPosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: resumeInventoryPosition
focal_class.modifiers: private
focal_class.parameters: (final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: void
focal_class.signature: void resumeInventoryPosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.getAllInventoryDataTasks(final ShardingScalingJob shardingScalingJob, 
                                                                            final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: private List<ScalingTask<InventoryPosition>> getAllInventoryDataTasks(final ShardingScalingJob shardingScalingJob, 
                                                                            final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: getAllInventoryDataTasks
focal_class.modifiers: private
focal_class.parameters: (final ShardingScalingJob shardingScalingJob, 
                                                                            final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: List<ScalingTask<InventoryPosition>>
focal_class.signature: List<ScalingTask<InventoryPosition>> getAllInventoryDataTasks(final ShardingScalingJob shardingScalingJob, 
                                                                            final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.newInventoryDumperConfiguration(final DumperConfiguration dumperConfig, 
                                                                           final MetaDataManager metaDataManager, final Entry<String, PositionManager<InventoryPosition>> entry)
focal_class.full_signature: private InventoryDumperConfiguration newInventoryDumperConfiguration(final DumperConfiguration dumperConfig, 
                                                                           final MetaDataManager metaDataManager, final Entry<String, PositionManager<InventoryPosition>> entry)
focal_class.identifier: newInventoryDumperConfiguration
focal_class.modifiers: private
focal_class.parameters: (final DumperConfiguration dumperConfig, 
                                                                           final MetaDataManager metaDataManager, final Entry<String, PositionManager<InventoryPosition>> entry)
focal_class.return: InventoryDumperConfiguration
focal_class.signature: InventoryDumperConfiguration newInventoryDumperConfiguration(final DumperConfiguration dumperConfig, 
                                                                           final MetaDataManager metaDataManager, final Entry<String, PositionManager<InventoryPosition>> entry)
focal_class.class_method_signature: SyncPositionResumer.getInventoryPositionMap(final DumperConfiguration dumperConfig, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: private Map<String, PositionManager<InventoryPosition>> getInventoryPositionMap(final DumperConfiguration dumperConfig, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: getInventoryPositionMap
focal_class.modifiers: private
focal_class.parameters: (final DumperConfiguration dumperConfig, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: Map<String, PositionManager<InventoryPosition>>
focal_class.signature: Map<String, PositionManager<InventoryPosition>> getInventoryPositionMap(final DumperConfiguration dumperConfig, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.resumeIncrementalPosition(final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: private void resumeIncrementalPosition(final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: resumeIncrementalPosition
focal_class.modifiers: private
focal_class.parameters: (final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: void
focal_class.signature: void resumeIncrementalPosition(final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.persistPosition(final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: public void persistPosition(final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: persistPosition
focal_class.modifiers: public
focal_class.parameters: (final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: void
focal_class.signature: void persistPosition(final ShardingScalingJob shardingScalingJob, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.persistInventoryPosition(final List<ScalingTask<InventoryPosition>> inventoryDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: private void persistInventoryPosition(final List<ScalingTask<InventoryPosition>> inventoryDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: persistInventoryPosition
focal_class.modifiers: private
focal_class.parameters: (final List<ScalingTask<InventoryPosition>> inventoryDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: void
focal_class.signature: void persistInventoryPosition(final List<ScalingTask<InventoryPosition>> inventoryDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.putInventoryDataScalingTask(final Collection<ScalingTask<InventoryPosition>> scalingTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: private void putInventoryDataScalingTask(final Collection<ScalingTask<InventoryPosition>> scalingTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: putInventoryDataScalingTask
focal_class.modifiers: private
focal_class.parameters: (final Collection<ScalingTask<InventoryPosition>> scalingTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: void
focal_class.signature: void putInventoryDataScalingTask(final Collection<ScalingTask<InventoryPosition>> scalingTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.class_method_signature: SyncPositionResumer.persistIncrementalPosition(final List<ScalingTask<IncrementalPosition>> incrementalDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.full_signature: private void persistIncrementalPosition(final List<ScalingTask<IncrementalPosition>> incrementalDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.identifier: persistIncrementalPosition
focal_class.modifiers: private
focal_class.parameters: (final List<ScalingTask<IncrementalPosition>> incrementalDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_class.return: void
focal_class.signature: void persistIncrementalPosition(final List<ScalingTask<IncrementalPosition>> incrementalDataTasks, final ResumeBreakPointManager resumeBreakPointManager)
focal_method.body: public void resumePosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager) {
          resumeInventoryPosition(shardingScalingJob, dataSourceManager, resumeBreakPointManager);
          resumeIncrementalPosition(shardingScalingJob, resumeBreakPointManager);
      }
focal_method.class_method_signature: SyncPositionResumer.resumePosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_method.full_signature: public void resumePosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_method.identifier: resumePosition
focal_method.invocations: resumeInventoryPosition resumeIncrementalPosition
focal_method.modifiers: public
focal_method.parameters: (final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)
focal_method.return: void
focal_method.signature: void resumePosition(final ShardingScalingJob shardingScalingJob, final DataSourceManager dataSourceManager, final ResumeBreakPointManager resumeBreakPointManager)