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: syncConfig
test_class.modifier: private
test_class.original_string: private SyncConfiguration syncConfig;
test_class.type: SyncConfiguration
test_class.var_name: syncConfig
test_class.declarator: dataSourceManager
test_class.modifier: private
test_class.original_string: private DataSourceManager dataSourceManager;
test_class.type: DataSourceManager
test_class.var_name: dataSourceManager
test_class.declarator: inventoryDataTaskSplitter
test_class.modifier: private
test_class.original_string: private InventoryDataTaskSplitter inventoryDataTaskSplitter;
test_class.type: InventoryDataTaskSplitter
test_class.var_name: inventoryDataTaskSplitter
test_class.file: shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/job/preparer/splitter/InventoryDataTaskSplitterTest.java
test_class.identifier: InventoryDataTaskSplitterTest
test_case.body: @Test
      public void assertSplitInventoryDataWithIntPrimary() throws SQLException {
          initIntPrimaryEnvironment(syncConfig.getDumperConfiguration());
          Collection<ScalingTask<InventoryPosition>> actual = inventoryDataTaskSplitter.splitInventoryData(syncConfig, dataSourceManager);
          assertNotNull(actual);
          assertThat(actual.size(), is(3));
      }
test_case.class_method_signature: InventoryDataTaskSplitterTest.assertSplitInventoryDataWithIntPrimary()
test_case.full_signature: @Test public void assertSplitInventoryDataWithIntPrimary()
test_case.identifier: assertSplitInventoryDataWithIntPrimary
test_case.invocations: initIntPrimaryEnvironment getDumperConfiguration splitInventoryData assertNotNull assertThat size is
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void assertSplitInventoryDataWithIntPrimary()
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/splitter/InventoryDataTaskSplitter.java
focal_class.identifier: InventoryDataTaskSplitter
focal_class.class_method_signature: InventoryDataTaskSplitter.splitInventoryData(final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)
focal_class.full_signature: public Collection<ScalingTask<InventoryPosition>> splitInventoryData(final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)
focal_class.identifier: splitInventoryData
focal_class.modifiers: public
focal_class.parameters: (final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)
focal_class.return: Collection<ScalingTask<InventoryPosition>>
focal_class.signature: Collection<ScalingTask<InventoryPosition>> splitInventoryData(final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)
focal_class.class_method_signature: InventoryDataTaskSplitter.splitDumperConfiguration(final int concurrency, final DumperConfiguration dumperConfig, final DataSourceManager dataSourceManager)
focal_class.full_signature: private Collection<InventoryDumperConfiguration> splitDumperConfiguration(final int concurrency, final DumperConfiguration dumperConfig, final DataSourceManager dataSourceManager)
focal_class.identifier: splitDumperConfiguration
focal_class.modifiers: private
focal_class.parameters: (final int concurrency, final DumperConfiguration dumperConfig, final DataSourceManager dataSourceManager)
focal_class.return: Collection<InventoryDumperConfiguration>
focal_class.signature: Collection<InventoryDumperConfiguration> splitDumperConfiguration(final int concurrency, final DumperConfiguration dumperConfig, final DataSourceManager dataSourceManager)
focal_class.class_method_signature: InventoryDataTaskSplitter.splitByTable(final DumperConfiguration dumperConfig)
focal_class.full_signature: private Collection<InventoryDumperConfiguration> splitByTable(final DumperConfiguration dumperConfig)
focal_class.identifier: splitByTable
focal_class.modifiers: private
focal_class.parameters: (final DumperConfiguration dumperConfig)
focal_class.return: Collection<InventoryDumperConfiguration>
focal_class.signature: Collection<InventoryDumperConfiguration> splitByTable(final DumperConfiguration dumperConfig)
focal_class.class_method_signature: InventoryDataTaskSplitter.isSpiltByPrimaryKeyRange(final InventoryDumperConfiguration inventoryDumperConfig, final MetaDataManager metaDataManager)
focal_class.full_signature: private boolean isSpiltByPrimaryKeyRange(final InventoryDumperConfiguration inventoryDumperConfig, final MetaDataManager metaDataManager)
focal_class.identifier: isSpiltByPrimaryKeyRange
focal_class.modifiers: private
focal_class.parameters: (final InventoryDumperConfiguration inventoryDumperConfig, final MetaDataManager metaDataManager)
focal_class.return: boolean
focal_class.signature: boolean isSpiltByPrimaryKeyRange(final InventoryDumperConfiguration inventoryDumperConfig, final MetaDataManager metaDataManager)
focal_class.class_method_signature: InventoryDataTaskSplitter.isNotIntegerPrimary(final int columnType)
focal_class.full_signature: private boolean isNotIntegerPrimary(final int columnType)
focal_class.identifier: isNotIntegerPrimary
focal_class.modifiers: private
focal_class.parameters: (final int columnType)
focal_class.return: boolean
focal_class.signature: boolean isNotIntegerPrimary(final int columnType)
focal_class.class_method_signature: InventoryDataTaskSplitter.splitByPrimaryKeyRange(final int concurrency, final InventoryDumperConfiguration inventoryDumperConfig, 
                                                                              final MetaDataManager metaDataManager, final DataSource dataSource)
focal_class.full_signature: private Collection<InventoryDumperConfiguration> splitByPrimaryKeyRange(final int concurrency, final InventoryDumperConfiguration inventoryDumperConfig, 
                                                                              final MetaDataManager metaDataManager, final DataSource dataSource)
focal_class.identifier: splitByPrimaryKeyRange
focal_class.modifiers: private
focal_class.parameters: (final int concurrency, final InventoryDumperConfiguration inventoryDumperConfig, 
                                                                              final MetaDataManager metaDataManager, final DataSource dataSource)
focal_class.return: Collection<InventoryDumperConfiguration>
focal_class.signature: Collection<InventoryDumperConfiguration> splitByPrimaryKeyRange(final int concurrency, final InventoryDumperConfiguration inventoryDumperConfig, 
                                                                              final MetaDataManager metaDataManager, final DataSource dataSource)
focal_method.body: public Collection<ScalingTask<InventoryPosition>> splitInventoryData(final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager) {
          Collection<ScalingTask<InventoryPosition>> result = new LinkedList<>();
          for (InventoryDumperConfiguration each : splitDumperConfiguration(syncConfig.getConcurrency(), syncConfig.getDumperConfiguration(), dataSourceManager)) {
              result.add(syncTaskFactory.createInventoryDataSyncTask(each, syncConfig.getImporterConfiguration()));
          }
          return result;
      }
focal_method.class_method_signature: InventoryDataTaskSplitter.splitInventoryData(final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)
focal_method.full_signature: public Collection<ScalingTask<InventoryPosition>> splitInventoryData(final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)
focal_method.identifier: splitInventoryData
focal_method.invocations: splitDumperConfiguration getConcurrency getDumperConfiguration add createInventoryDataSyncTask getImporterConfiguration
focal_method.modifiers: public
focal_method.parameters: (final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)
focal_method.return: Collection<ScalingTask<InventoryPosition>>
focal_method.signature: Collection<ScalingTask<InventoryPosition>> splitInventoryData(final SyncConfiguration syncConfig, final DataSourceManager dataSourceManager)