ShardingService { public void setReshardingFlag() { jobNodeStorage.createJobNodeIfNeeded(ShardingNode.NECESSARY); } ShardingService(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); void setReshardingFlag(); boolean isNeedSharding(); void shardingIfNecessary(); List<Integer> getLocalHostShardingItems();  }
@Test public void assertSetReshardingFlag() { shardingService.setReshardingFlag(); verify(jobNodeStorage).createJobNodeIfNeeded("leader/sharding/necessary"); }