hudi-client/src/main/java/org/apache/hudi/index/simple/HoodieGlobalSimpleIndex.java
/**
   * Tags records location for incoming records.
   *
   * @param inputRecordRDD   {@link JavaRDD} of incoming records
   * @param jsc         instance of {@link JavaSparkContext} to use
   * @param hoodieTable instance of {@link HoodieTable} to use
   * @return {@link JavaRDD} of records with record locations set
   */
Tags records location for incoming records.
@param inputRecordRDD    JavaRDD of incoming records
@param jsc         instance of  JavaSparkContext to use
@param hoodieTable instance of  HoodieTable to use
@return  JavaRDD of records with record locations set
Tags records location for incoming records . @param inputRecordRDD JavaRDD of incoming records @param jsc instance of JavaSparkContext to use @param hoodieTable instance of HoodieTable to use @return JavaRDD of records with record locations set
protected JavaRDD<HoodieRecord<T>> tagLocationInternal(JavaRDD<HoodieRecord<T>> inputRecordRDD, JavaSparkContext jsc,
                                                         HoodieTable<T> hoodieTable) {
    JavaPairRDD<String, HoodieRecord<T>> keyedInputRecordRDD = inputRecordRDD.mapToPair(entry -> new Tuple2<>(entry.getRecordKey(), entry));
    JavaPairRDD<HoodieKey, HoodieRecordLocation> allRecordLocationsInTable = fetchAllRecordLocations(jsc, hoodieTable,
        config.getGlobalSimpleIndexParallelism());
    return getTaggedRecords(keyedInputRecordRDD, allRecordLocationsInTable);
  }
protected JavaRDD < HoodieRecord < T > > tagLocationInternal ( JavaRDD < HoodieRecord < T > > inputRecordRDD , JavaSparkContext jsc , HoodieTable < T > hoodieTable ) { JavaPairRDD < String , HoodieRecord < T > > keyedInputRecordRDD = inputRecordRDD . mapToPair ( entry -> new Tuple2 < > ( entry . getRecordKey ( ) , entry ) ) ; JavaPairRDD < HoodieKey , HoodieRecordLocation > allRecordLocationsInTable = fetchAllRecordLocations ( jsc , hoodieTable , config . getGlobalSimpleIndexParallelism ( ) ) ; return getTaggedRecords ( keyedInputRecordRDD , allRecordLocationsInTable ) ; }
Tags records location for incoming records.
Tags records location for incoming records .