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

Repository.getPartitionSchemaIDs介绍

暂无

代码示例

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

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

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

private List<PartitionSchema> pickupPartitionSchemas( TransMeta transMeta ) throws KettleException {
 if ( rep != null ) {
  ObjectId[] ids = rep.getPartitionSchemaIDs( false );
  List<PartitionSchema> result = new ArrayList<>( ids.length );
  for ( ObjectId id : ids ) {
   PartitionSchema schema = rep.loadPartitionSchema( id, null );
   result.add( schema );
  }
  return result;
 }
 return transMeta.getPartitionSchemas();
}

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

private List<PartitionSchema> pickupPartitionSchemas( TransMeta transMeta ) throws KettleException {
 Repository rep = spoon.getRepository();
 if ( rep != null ) {
  ObjectId[] ids = rep.getPartitionSchemaIDs( false );
  List<PartitionSchema> result = new ArrayList<>( ids.length );
  for ( ObjectId id : ids ) {
   PartitionSchema schema = rep.loadPartitionSchema( id, null );
   result.add( schema );
  }
  return result;
 }
 return transMeta.getPartitionSchemas();
}

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

public void refreshPartitions() {
 if ( repository != null ) {
  final List<UIPartition> tmpList = new ArrayList<UIPartition>();
  Runnable r = () -> {
   try {
    if ( repository instanceof RepositoryExtended ) {
     List<PartitionSchema> partitionSchemas = ((RepositoryExtended) repository).getPartitions( false );
     partitionSchemas.forEach( partitionSchema -> tmpList.add( new UIPartition( partitionSchema ) ) );
    } else {
     ObjectId[] partitionIdList = repository.getPartitionSchemaIDs( false );
     for ( ObjectId partitionId : partitionIdList ) {
      PartitionSchema partition = repository.loadPartitionSchema( partitionId, null );
      // Add the partition schema to the list
      tmpList.add( new UIPartition( partition ) );
     }
    }
   } catch ( KettleException e ) {
    if ( mainController == null || !mainController.handleLostRepository( e ) ) {
     // convert to runtime exception so it bubbles up through the UI
     throw new RuntimeException( e );
    }
   }
  };
  doWithBusyIndicator( r );
  partitionList.setChildren( tmpList );
 }
}

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

sharedObjects.storeObject( clusterSchema );
for ( ObjectId id : rep.getPartitionSchemaIDs( false ) ) {
 PartitionSchema partitionSchema = rep.loadPartitionSchema( id, null );
 validateImportedElement( importRules, partitionSchema );