hudi-client/src/main/java/org/apache/hudi/index/bloom/HoodieGlobalBloomIndex.java
/**
   * Load all involved files as <Partition, filename> pair RDD from all partitions in the table.
   */
Load all involved files as  pair RDD from all partitions in the table.
Load all involved files as pair RDD from all partitions in the table .
@Override
  List<Tuple2<String, BloomIndexFileInfo>> loadInvolvedFiles(List<String> partitions, final JavaSparkContext jsc,
                                                             final HoodieTable hoodieTable) {
    HoodieTableMetaClient metaClient = hoodieTable.getMetaClient();
    try {
      List<String> allPartitionPaths = FSUtils.getAllPartitionPaths(metaClient.getFs(), metaClient.getBasePath(),
          config.shouldAssumeDatePartitioning());
      return super.loadInvolvedFiles(allPartitionPaths, jsc, hoodieTable);
    } catch (IOException e) {
      throw new HoodieIOException("Failed to load all partitions", e);
    }
  }
@ Override List < Tuple2 < String , BloomIndexFileInfo > > loadInvolvedFiles ( List < String > partitions , final JavaSparkContext jsc , final HoodieTable hoodieTable ) { HoodieTableMetaClient metaClient = hoodieTable . getMetaClient ( ) ; try { List < String > allPartitionPaths = FSUtils . getAllPartitionPaths ( metaClient . getFs ( ) , metaClient . getBasePath ( ) , config . shouldAssumeDatePartitioning ( ) ) ; return super . loadInvolvedFiles ( allPartitionPaths , jsc , hoodieTable ) ; } catch ( IOException e ) { throw new HoodieIOException ( "Failed to load all partitions" , e ) ; } }
Load all involved files as <Partition, filename> pair RDD from all partitions in the table.
Load all involved files as <Partition filename > pair RDD from all partitions in the table .