本文整理了Java中org.pentaho.di.repository.Repository.loadClusterSchema方法的一些代码示例，展示了Repository.loadClusterSchema的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Repository.loadClusterSchema方法的具体详情如下：
包路径：org.pentaho.di.repository.Repository
类名称：Repository
方法名：loadClusterSchema

Repository.loadClusterSchema介绍

暂无

代码示例

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public ClusterSchema loadClusterSchema( ObjectId objectId, List<SlaveServer> list, String s ) throws KettleException {
 return getDelegate().loadClusterSchema( objectId, list, s );
}

代码示例来源：origin: pentaho/pentaho-kettle

public void refreshClusters() {
 if ( repository != null ) {
  final List<UICluster> tmpList = new ArrayList<UICluster>();
  Runnable r = () -> {
   try {
    if ( repository instanceof RepositoryExtended ) {
     List<ClusterSchema> clusterSchemas = ((RepositoryExtended) repository).getClusters( false );
     clusterSchemas.forEach( clusterSchema -> tmpList.add( new UICluster( clusterSchema ) ) );
    } else {
     ObjectId[] clusterIdList = repository.getClusterIDs( false );
     for ( ObjectId clusterId : clusterIdList ) {
      ClusterSchema cluster = repository.loadClusterSchema( clusterId, repository.getSlaveServers(), null );
      // Add the cluster schema to the list
      tmpList.add( new UICluster( cluster ) );
     }
    }
   } catch ( KettleException e ) {
    // convert to runtime exception so it bubbles up through the UI
    throw new RuntimeException( e );
   }
  };
  doWithBusyIndicator( r );
  clusterList.setChildren( tmpList );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public void editCluster( String clusterName ) {
 try {
  ObjectId id = rep.getClusterID( clusterName );
  ClusterSchema cluster = rep.loadClusterSchema( id, rep.getSlaveServers(), null ); // Load the last version
  ClusterSchemaDialog dd = new ClusterSchemaDialog( shell, cluster, rep.getSlaveServers() );
  if ( dd.open() ) {
   rep.insertLogEntry( "Updating cluster '" + cluster.getName() + "'" );
   rep.save( cluster, Const.VERSION_COMMENT_EDIT_VERSION, null );
   if ( !clusterName.equalsIgnoreCase( cluster.getName() ) ) {
    refreshTree();
   }
  }
 } catch ( KettleException e ) {
  //CHECKSTYLE:LineLength:OFF
  new ErrorDialog( shell,
   BaseMessages.getString( PKG, "RepositoryExplorerDialog.Cluster.Edit.UnexpectedError.Title" ),
   BaseMessages.getString( PKG, "RepositoryExplorerDialog.Cluster.Edit.UnexpectedError.Message" ) + clusterName + "]", e );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

ClusterSchema clusterSchema = rep.loadClusterSchema( id, slaveServers, null );
validateImportedElement( importRules, clusterSchema );
sharedObjects.storeObject( clusterSchema );