hudi-client/src/main/java/org/apache/hudi/index/bloom/HoodieBloomIndex.java
/**
   * Tag the <rowKey, filename> back to the original HoodieRecord RDD.
   */
Tag the  back to the original HoodieRecord RDD.
Tag the back to the original HoodieRecord RDD .
protected JavaRDD<HoodieRecord<T>> tagLocationBacktoRecords(
      JavaPairRDD<HoodieKey, HoodieRecordLocation> keyFilenamePairRDD, JavaRDD<HoodieRecord<T>> recordRDD) {
    JavaPairRDD<HoodieKey, HoodieRecord<T>> keyRecordPairRDD =
        recordRDD.mapToPair(record -> new Tuple2<>(record.getKey(), record));
    return keyRecordPairRDD.leftOuterJoin(keyFilenamePairRDD).values()
        .map(v1 -> HoodieIndexUtils.getTaggedRecord(v1._1, Option.ofNullable(v1._2.orNull())));
  }
protected JavaRDD < HoodieRecord < T > > tagLocationBacktoRecords ( JavaPairRDD < HoodieKey , HoodieRecordLocation > keyFilenamePairRDD , JavaRDD < HoodieRecord < T > > recordRDD ) { JavaPairRDD < HoodieKey , HoodieRecord < T > > keyRecordPairRDD = recordRDD . mapToPair ( record -> new Tuple2 < > ( record . getKey ( ) , record ) ) ; return keyRecordPairRDD . leftOuterJoin ( keyFilenamePairRDD ) . values ( ) . map ( v1 -> HoodieIndexUtils . getTaggedRecord ( v1 . _1 , Option . ofNullable ( v1 . _2 . orNull ( ) ) ) ) ; }
Tag the <rowKey, filename> back to the original HoodieRecord RDD.
Tag the <rowKey filename > back to the original HoodieRecord RDD .
// Here as the recordRDD might have more data than rowKeyRDD (some rowKeys' fileId is null), // so we do left outer join.