org.pentaho.di.repository.Repository.getClusterIDs()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(1.5k)|赞(0)|评价(0)|浏览(101)

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

Repository.getClusterIDs介绍

暂无

代码示例

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

@Override
public ObjectId[] getClusterIDs( boolean b ) throws KettleException {
 return getDelegate().getClusterIDs( b );
}

代码示例来源: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

for ( ObjectId id : rep.getClusterIDs( false ) ) {
 ClusterSchema clusterSchema = rep.loadClusterSchema( id, slaveServers, null );
 validateImportedElement( importRules, clusterSchema );

相关文章

Repository类方法