nsivabalan

/**
* Interface for client side UberInterceptor at mobile networking layer
* @param <ReqT> request object of generic type.
* @param <RespT> response object of generic type.
*/
public abstract class UberInterceptor<ReqT, RespT> {
/**
* Fetch MethodInfo for the call in flux.
* @param <T> type of MethodInfo
* @return the instance of MethodInfo

nsivabalan

public interface UberNetworkRequestStatus {

public int getResponseCode();

public boolean isSuccess() ;

public Throwable getThrowable();
}

nsivabalan

public interface UberCallHeaders {

String getHeaderValue(String key);

void setHeader(String key, String value);

Set<String> getAllHeaderKeys();

Map<String, String> getHeadersAsMap();

nsivabalan

public class UberCallOptions {
  
  private boolean isRetryEnabled = false;
  private int retryCount = 0;
  private long timeout = 30000;
  private String callType = "GRPC";
  .
  .
  .

nsivabalan

diff --git a/hudi-spark/src/main/java/org/apache/hudi/keygen/GlobalDeleteKeyGenerator.java b/hudi-spark/src/main/java/org/apache/hudi/keygen/GlobalDeleteKeyGenerator.java
index 315c2659..a699e0c8 100644
--- a/hudi-spark/src/main/java/org/apache/hudi/keygen/GlobalDeleteKeyGenerator.java
+++ b/hudi-spark/src/main/java/org/apache/hudi/keygen/GlobalDeleteKeyGenerator.java
@@ -25,6 +25,7 @@ import org.apache.hudi.common.model.HoodieKey;
 import org.apache.hudi.exception.HoodieKeyException;
 
 import org.apache.avro.generic.GenericRecord;
+import org.apache.spark.sql.Row;
 

nsivabalan

public class UberCallOptions {

    private boolean isRetryEnabled = false;
    private RetryPolicy retryPolicy = null;
    private long timeout = 30000;

    public void setRetryEnabled() {
        isRetryEnabled = true;
    }

nsivabalan

// HoodieSparkJoinIndex.java

/**
   * Find <HoodieKey, HoodieRecordLocation> for all incoming HoodieKeys
   */
  @VisibleForTesting
  JavaPairRDD<HoodieKey, HoodieRecordLocation> findMatchingFilesForRecordKeysLocal(JavaSparkContext jsc,
                                                                                   List<Tuple2<String, String>> partitionToFileIndexInfo,
                                                                                   JavaPairRDD<String, String> partitionRecordKeyPairRDD, HoodieTable hoodieTable) {
    // Step 1: Create JavaPairRDD< Tuple2<PartitionPath, RecordKey>, Optional<HoodieRecordLocation> > from input with  Optional<HoodieRecordLocation> as Empty.

nsivabalan

import com.github.ambry.clustermap.PartitionId;
import com.github.ambry.config.StoreConfig;
import com.github.ambry.store.BlobStore;
import com.github.ambry.utils.Time;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;

nsivabalan

/**
 * Class used for scrubbing the log for any inconsistencies
 */
public class Scrubber {

  /**
   * Used to start scrubbing the log for consistency checks
   */
  public void start();

nsivabalan

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.Arrays;

public class LuckyStrings {

	public static void main(String args[]) throws NumberFormatException, IOException
	{