garvitlnmiit

DataStream stream = ...; // Kafka stream consumer08 (version)
stream.keyBy("personId");    
stream.process(new ProcessAlerts());    

/**
 * The data type stored in the state
 */
public class PersonDetail {
    public int personId;

garvitlnmiit

#include <bits/stdc++.h>
using namespace std;

bool ispalindrome(int W[], int low, int high)
{
    if (low == high)
        return 1;
    int mid = (high - low) / 2;
    for (int i = 0; i <= mid; i++)
    {

garvitlnmiit

// Garvit Sharma <garvits45@gmail.com> <garvitlnmiit> <garvitsharma.in>
// Codechef ZCO, problem 1

#include <bits/stdc++.h>
using namespace std;

const int MAX_SIZE = 500000;
typedef long long ll;
ll data[MAX_SIZE];