spullara

{
  "vehicle": {
    "color": null,
    "display_name": null,
    "id": XXXX,
    "option_codes": "MS01,RENA,TM00,DRLH,PF01,BT85,PMTG,RFPO,WTSP,IZMB,IDCF,TR01,SU01,SC01,TP01,AU01,CH00,HP00,PA01,PS00,AD02,X024,X019,X001,X003,X007,X011,X013",
    "user_id": XXXX,
    "vehicle_id": XXXX,
    "vin": "XXXX",
    "tokens": [

spullara

      // 1) Stride through the database using KeySelectors until you pass the end of the database
      // 2) Then, back off until you find the last key
      final AtomicBoolean retry = new AtomicBoolean();
      Function<Transaction, Long> function = new Function<Transaction, Long>() {
        private long start = System.currentTimeMillis();
        private long count = 0;
        private int offset = 1000000;
        private KeySelector keySelector = KeySelector.firstGreaterOrEqual(new byte[0]);
        private boolean narrowing = false;

spullara

package spullara;

import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.InputStreamReader;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public class GCParser {
    public static void main(String[] args) throws FileNotFoundException {

spullara

package redis.netty.client;

import org.junit.Test;
import redis.netty.MultiBulkReply;
import spullara.util.functions.Block;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicBoolean;

spullara

package spullara.util.concurrent;

import org.junit.BeforeClass;
import org.junit.Test;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicBoolean;

spullara

package avrobase.fdb;

import com.foundationdb.*;
import org.junit.Test;

import static com.foundationdb.KeySelector.firstGreaterOrEqual;
import static com.foundationdb.KeySelector.lastLessThan;
import static junit.framework.Assert.assertEquals;

/**

spullara

package com.github.mustachejava;

import com.google.common.base.Function;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import org.junit.Test;

import java.io.IOException;
import java.io.Reader;

spullara

macpro:redis-protocol sam$ redis-benchmark -p 6380 -P 50 -n 10000000 set test test
====== set test test ======
  10000000 requests completed in 5.57 seconds
  50 parallel clients
  3 bytes payload
  keep alive: 1

65.80% <= 1 milliseconds
99.65% <= 2 milliseconds
99.95% <= 3 milliseconds

spullara

package collectbenchmark;

import java.util.Arrays;
import java.util.Map;
import java.util.stream.Collectors;

import static java.lang.Integer.parseInt;
import static java.lang.System.nanoTime;
import static java.util.function.Function.identity;
import static java.util.stream.Collectors.toMap;

spullara

package com.github.mustachejava;

import com.github.mustachejava.reflect.ReflectionObjectHandler;
import org.junit.Test;

import java.io.IOException;
import java.io.StringReader;
import java.io.StringWriter;
import java.lang.reflect.Array;
import java.util.AbstractMap;