nishantrayan

if (!serializedPartialEvent.equals("null")) {

nishantrayan

package com.amplitude.gigatron.taxonomy;

import static com.amplitude.gigatron.model.OmniDataV2.getOmniDataV2ForKey;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;

nishantrayan

package com.amplitude.taxonomy;

import java.util.*;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

nishantrayan

 if (stats == null) {
            MetricsWrapper.incrementCounter("cargo.scheduler.validate_batch_consistency.ignore",
                    "type:stats_null");
            return;
        }