Examples of CounterGenerator

com.oltpbenchmark.distributions.CounterGenerator
Generates a sequence of integers 0, 1, ...
com.yahoo.ycsb.generator.CounterGenerator
Generates a sequence of integers 0, 1, ...
voldemort.performance.benchmark.generator.CounterGenerator
Generates a sequence of integers 0, 1, ...

Examples of com.oltpbenchmark.distributions.CounterGenerator

   * @param transactions
   *            a list of transactions shared between threads.
   */
  public TraceTransactionGenerator(List<TwitterOperation> transactions) {
    this.transactions = transactions;
    nextInTrace= new CounterGenerator(transactions.size());
  }

View Full Code Here

Examples of com.oltpbenchmark.distributions.CounterGenerator

        randScan = new ZipfianGenerator(YCSBConstants.MAX_SCAN);
        
        synchronized (YCSBWorker.class) {
            // We must know where to start inserting
            if (insertRecord == null) {
                insertRecord = new CounterGenerator(init_record_count);
            }
        } // SYNCH
    }

View Full Code Here

Examples of com.yahoo.ycsb.generator.CounterGenerator

    else
    {
      orderedinserts=true;
    }


    keysequence=new CounterGenerator(insertstart);
    operationchooser=new DiscreteGenerator();
    if (readproportion>0)
    {
      operationchooser.addValue(readproportion,"READ");
    }


    if (updateproportion>0)
    {
      operationchooser.addValue(updateproportion,"UPDATE");
    }


    if (insertproportion>0)
    {
      operationchooser.addValue(insertproportion,"INSERT");
    }
    
    if (scanproportion>0)
    {
      operationchooser.addValue(scanproportion,"SCAN");
    }
    
    if (readmodifywriteproportion>0)
    {
      operationchooser.addValue(readmodifywriteproportion,"READMODIFYWRITE");
    }


    transactioninsertkeysequence=new CounterGenerator(recordcount);
    if (requestdistrib.compareTo("uniform")==0)
    {
      keychooser=new UniformIntegerGenerator(0,recordcount-1);
    }
    else if (requestdistrib.compareTo("zipfian")==0)

View Full Code Here

Examples of com.yahoo.ycsb.generator.CounterGenerator

      orderedinserts = false;
    } else {
      orderedinserts = true;
    }


    keysequence = new CounterGenerator(insertstart);
    operationchooser = new DiscreteGenerator();
    if (Config.getConfig().read_proportion > 0) {
      operationchooser.addValue(Config.getConfig().read_proportion, "READ");
    }


    if (Config.getConfig().update_proportion > 0) {
      operationchooser.addValue(Config.getConfig().update_proportion, "UPDATE");
    }


    if (Config.getConfig().insert_proportion > 0) {
      operationchooser.addValue(Config.getConfig().insert_proportion, "INSERT");
    }


    if (Config.getConfig().scan_proportion > 0) {
      operationchooser.addValue(Config.getConfig().scan_proportion, "SCAN");
    }


    if (Config.getConfig().read_write_modify_proportion > 0) {
      operationchooser.addValue(Config.getConfig().read_write_modify_proportion, "READMODIFYWRITE");
    }


    transactioninsertkeysequence = new CounterGenerator(recordcount);
    if (Config.getConfig().request_distribution.compareTo("uniform") == 0) {
      keychooser = new UniformIntegerGenerator(0, recordcount - 1);
    } else if (Config.getConfig().request_distribution.compareTo("zipfian") == 0) {
      // it does this by generating a random "next key" in part by taking
      // the modulus over the number of keys

View Full Code Here

Examples of com.yahoo.ycsb.generator.CounterGenerator

      orderedinserts = false;
    } else {
      orderedinserts = true;
    }


    keysequence = new CounterGenerator(insertstart);
    operationchooser = new DiscreteGenerator();
    
    if (Config.getConfig().memadd_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memadd_proportion, "ADD");
    }
    if (Config.getConfig().memappend_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memappend_proportion, "APPEND");
    }
    if (Config.getConfig().memcas_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memcas_proportion, "CAS");
    }
    if (Config.getConfig().memdecr_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memdecr_proportion, "DECR");
    }
    if (Config.getConfig().memdelete_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memdelete_proportion, "DELETE");
    }
    if (Config.getConfig().memget_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memget_proportion, "GET");
    }
    if (Config.getConfig().memgets_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memgets_proportion, "GETS");
    }
    if (Config.getConfig().memincr_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memincr_proportion, "INCR");
    }
    if (Config.getConfig().memprepend_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memprepend_proportion, "PREPEND");
    }
    if (Config.getConfig().memreplace_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memreplace_proportion, "REPLACE");
    }
    if (Config.getConfig().memset_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memset_proportion, "SET");
    }
    if (Config.getConfig().memupdate_proportion > 0) {
      operationchooser.addValue(Config.getConfig().memupdate_proportion, "UPDATE");
    }
    
    transactioninsertkeysequence = new CounterGenerator(recordcount);
    if (Config.getConfig().request_distribution.compareTo("uniform") == 0) {
      keychooser = new UniformIntegerGenerator(0, recordcount - 1);
    } else if (Config.getConfig().request_distribution.compareTo("zipfian") == 0) {
      // it does this by generating a random "next key" in part by taking
      // the modulus over the number of keys

View Full Code Here

Examples of voldemort.performance.benchmark.generator.CounterGenerator

        int opCount = props.getInt(Benchmark.OPS_COUNT);


        Class<?> keyTypeClass = getKeyTypeClass(keyType);
        int insertStart = props.getInt(Benchmark.START_KEY_INDEX, 0);


        IntegerGenerator warmUpKeySequence = new CounterGenerator(insertStart);
        this.warmUpKeyProvider = getKeyProvider(keyTypeClass, warmUpKeySequence, 0);


        this.transformsChooser = null;
        if(hasTransforms) {
            this.transformsChooser = new DiscreteGenerator();
            List<String> transforms = BenchmarkViews.getTransforms();
            for(String transform: transforms) {
                this.transformsChooser.addValue(1.0, transform);
            }
        }


        operationChooser = new DiscreteGenerator();
        if(readProportion > 0) {
            operationChooser.addValue(readProportion, Benchmark.READS);
        }
        if(mixedProportion > 0) {
            operationChooser.addValue(mixedProportion, Benchmark.MIXED);
        }
        if(writeProportion > 0) {
            operationChooser.addValue(writeProportion, Benchmark.WRITES);
        }
        if(deleteProportion > 0) {
            operationChooser.addValue(deleteProportion, Benchmark.DELETES);
        }


        CounterGenerator insertKeySequence = null;
        if(recordCount > 0) {
            insertKeySequence = new CounterGenerator(recordCount);
        } else {
            Random randomizer = new Random();
            insertKeySequence = new CounterGenerator(randomizer.nextInt(Integer.MAX_VALUE));


        }


        IntegerGenerator keyGenerator = null;
        if(recordSelection.compareTo(Benchmark.UNIFORM_RECORD_SELECTION) == 0) {

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.