@Test public void synchronizePartitionSchemas() throws Exception { final String partitionSchemaName = "SharedPartitionSchema"; TransMeta transformarion1 = createTransMeta(); PartitionSchema partitionSchema1 = createPartitionSchema( partitionSchemaName, true ); transformarion1.setPartitionSchemas( Collections.singletonList( partitionSchema1 ) ); spoonDelegates.trans.addTransformation( transformarion1 ); TransMeta transformarion2 = createTransMeta(); PartitionSchema partitionSchema2 = createPartitionSchema( partitionSchemaName, true ); transformarion2.setPartitionSchemas( Collections.singletonList( partitionSchema2 ) ); spoonDelegates.trans.addTransformation( transformarion2 ); partitionSchema2.setNumberOfPartitionsPerSlave( AFTER_SYNC_VALUE ); sharedUtil.synchronizePartitionSchemas( partitionSchema2 ); assertThat( partitionSchema1.getNumberOfPartitionsPerSlave(), equalTo( AFTER_SYNC_VALUE ) ); }
public synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ) { synchronizePartitionSchemas( partitionSchema, partitionSchema.getName() ); }
SharedObjectSyncUtil { public synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ) { synchronizePartitionSchemas( partitionSchema, partitionSchema.getName() ); } }
SharedObjectSyncUtil { public synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ) { synchronizePartitionSchemas( partitionSchema, partitionSchema.getName() ); } SharedObjectSyncUtil( Spoon spoon ); }
SharedObjectSyncUtil { public synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ) { synchronizePartitionSchemas( partitionSchema, partitionSchema.getName() ); } SharedObjectSyncUtil( Spoon spoon ); synchronized void synchronizeConnections( DatabaseMeta database ); synchronized void synchronizeConnections( DatabaseMeta database, String originalName ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer, String originalName ); synchronized void deleteSlaveServer( SlaveServer removed ); synchronized void deleteClusterSchema( ClusterSchema removed ); synchronized void deletePartitionSchema( PartitionSchema removed ); synchronized void reloadTransformationRepositoryObjects( boolean includeActive ); synchronized void reloadJobRepositoryObjects( boolean includeActive ); synchronized void reloadSharedObjects(); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema ); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema, String originalName ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema, String originalName ); synchronized void synchronizeSteps( StepMeta step ); synchronized void synchronizeSteps( StepMeta step, String originalName ); }
SharedObjectSyncUtil { public synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ) { synchronizePartitionSchemas( partitionSchema, partitionSchema.getName() ); } SharedObjectSyncUtil( Spoon spoon ); synchronized void synchronizeConnections( DatabaseMeta database ); synchronized void synchronizeConnections( DatabaseMeta database, String originalName ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer ); synchronized void synchronizeSlaveServers( SlaveServer slaveServer, String originalName ); synchronized void deleteSlaveServer( SlaveServer removed ); synchronized void deleteClusterSchema( ClusterSchema removed ); synchronized void deletePartitionSchema( PartitionSchema removed ); synchronized void reloadTransformationRepositoryObjects( boolean includeActive ); synchronized void reloadJobRepositoryObjects( boolean includeActive ); synchronized void reloadSharedObjects(); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema ); synchronized void synchronizeClusterSchemas( ClusterSchema clusterSchema, String originalName ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema ); synchronized void synchronizePartitionSchemas( PartitionSchema partitionSchema, String originalName ); synchronized void synchronizeSteps( StepMeta step ); synchronized void synchronizeSteps( StepMeta step, String originalName );  }