com.yahoo.ycsb.generator.ZipfianGenerator.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(8.1k)|赞(0)|评价(0)|浏览(130)

本文整理了Java中com.yahoo.ycsb.generator.ZipfianGenerator.<init>()方法的一些代码示例，展示了ZipfianGenerator.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZipfianGenerator.<init>()方法的具体详情如下：
包路径：com.yahoo.ycsb.generator.ZipfianGenerator
类名称：ZipfianGenerator
方法名：<init>

ZipfianGenerator.<init>介绍

[英]Create a zipfian generator for the specified number of items.
[中]为指定数量的项目创建zipfian生成器。

代码示例

代码示例来源：origin: brianfrankcooper/YCSB

public static void main(String[] args) {
 new ZipfianGenerator(ScrambledZipfianGenerator.ITEM_COUNT);
}

代码示例来源：origin: brianfrankcooper/YCSB

/**
 * Create a zipfian generator for items between min and max (inclusive) for the specified zipfian constant. If you
 * use a zipfian constant other than 0.99, this will take a long time to complete because we need to recompute zeta.
 *
 * @param min             The smallest integer to generate in the sequence.
 * @param max             The largest integer to generate in the sequence.
 * @param zipfianconstant The zipfian constant to use.
 */
public ScrambledZipfianGenerator(long min, long max, double zipfianconstant) {
 this.min = min;
 this.max = max;
 itemcount = this.max - this.min + 1;
 if (zipfianconstant == USED_ZIPFIAN_CONSTANT) {
  gen = new ZipfianGenerator(0, ITEM_COUNT, zipfianconstant, ZETAN);
 } else {
  gen = new ZipfianGenerator(0, ITEM_COUNT, zipfianconstant);
 }
}

代码示例来源：origin: ben-manes/caffeine

/**
 * Returns a sequence of events where some items are more popular than others, according to a
 * zipfian distribution.
 *
 * @param items the number of items in the distribution
 * @param constant the skew factor for the distribution
 * @param events the number of events in the distribution
 */
public static LongStream zipfian(int items, double constant, int events) {
 return generate(new ZipfianGenerator(items, constant), events);
}

代码示例来源：origin: brianfrankcooper/YCSB

protected static NumberGenerator getFieldLengthGenerator(Properties p) throws WorkloadException {
 // Re-using CoreWorkload method. 
 NumberGenerator fieldLengthGenerator = CoreWorkload.getFieldLengthGenerator(p);
 String fieldlengthdistribution = p.getProperty(FIELD_LENGTH_DISTRIBUTION_PROPERTY,
   FIELD_LENGTH_DISTRIBUTION_PROPERTY_DEFAULT);
 // Needs special handling for Zipfian distribution for variable Zipf Constant.
 if (fieldlengthdistribution.compareTo("zipfian") == 0) {
  int fieldlength = Integer.parseInt(p.getProperty(FIELD_LENGTH_PROPERTY, FIELD_LENGTH_PROPERTY_DEFAULT));
  double insertsizezipfconstant = Double
    .parseDouble(p.getProperty(INSERT_SIZE_ZIPFIAN_CONSTANT, INSERT_SIZE_ZIPFIAN_CONSTANT_DEAFULT));
  fieldLengthGenerator = new ZipfianGenerator(1, fieldlength, insertsizezipfconstant);
 }
 return fieldLengthGenerator;
}

代码示例来源：origin: brianfrankcooper/YCSB

public SkewedLatestGenerator(CounterGenerator basis) {
 this.basis = basis;
 zipfian = new ZipfianGenerator(this.basis.lastValue());
 nextValue();
}

代码示例来源：origin: brianfrankcooper/YCSB

protected static NumberGenerator getFieldLengthGenerator(Properties p) throws WorkloadException {
 NumberGenerator fieldlengthgenerator;
 String fieldlengthdistribution = p.getProperty(
   FIELD_LENGTH_DISTRIBUTION_PROPERTY, FIELD_LENGTH_DISTRIBUTION_PROPERTY_DEFAULT);
 int fieldlength =
   Integer.parseInt(p.getProperty(FIELD_LENGTH_PROPERTY, FIELD_LENGTH_PROPERTY_DEFAULT));
 int minfieldlength =
   Integer.parseInt(p.getProperty(MIN_FIELD_LENGTH_PROPERTY, MIN_FIELD_LENGTH_PROPERTY_DEFAULT));
 String fieldlengthhistogram = p.getProperty(
   FIELD_LENGTH_HISTOGRAM_FILE_PROPERTY, FIELD_LENGTH_HISTOGRAM_FILE_PROPERTY_DEFAULT);
 if (fieldlengthdistribution.compareTo("constant") == 0) {
  fieldlengthgenerator = new ConstantIntegerGenerator(fieldlength);
 } else if (fieldlengthdistribution.compareTo("uniform") == 0) {
  fieldlengthgenerator = new UniformLongGenerator(minfieldlength, fieldlength);
 } else if (fieldlengthdistribution.compareTo("zipfian") == 0) {
  fieldlengthgenerator = new ZipfianGenerator(minfieldlength, fieldlength);
 } else if (fieldlengthdistribution.compareTo("histogram") == 0) {
  try {
   fieldlengthgenerator = new HistogramGenerator(fieldlengthhistogram);
  } catch (IOException e) {
   throw new WorkloadException(
     "Couldn't read field length histogram file: " + fieldlengthhistogram, e);
  }
 } else {
  throw new WorkloadException(
    "Unknown field length distribution \"" + fieldlengthdistribution + "\"");
 }
 return fieldlengthgenerator;
}

代码示例来源：origin: brianfrankcooper/YCSB

private static NumberGenerator getKeyChooser(String requestDistrib, int recordCount, double zipfContant,
                       Properties p) throws WorkloadException {
 NumberGenerator keychooser;
 switch (requestDistrib) {
 case "exponential":
  double percentile = Double.parseDouble(p.getProperty(ExponentialGenerator.EXPONENTIAL_PERCENTILE_PROPERTY,
    ExponentialGenerator.EXPONENTIAL_PERCENTILE_DEFAULT));
  double frac = Double.parseDouble(p.getProperty(ExponentialGenerator.EXPONENTIAL_FRAC_PROPERTY,
    ExponentialGenerator.EXPONENTIAL_FRAC_DEFAULT));
  keychooser = new ExponentialGenerator(percentile, recordCount * frac);
  break;
 case "uniform":
  keychooser = new UniformLongGenerator(0, recordCount - 1);
  break;
 case "zipfian":
  keychooser = new ZipfianGenerator(recordCount, zipfContant);
  break;
 case "latest":
  throw new WorkloadException("Latest request distribution is not supported for RestWorkload.");
 case "hotspot":
  double hotsetfraction = Double.parseDouble(p.getProperty(HOTSPOT_DATA_FRACTION, HOTSPOT_DATA_FRACTION_DEFAULT));
  double hotopnfraction = Double.parseDouble(p.getProperty(HOTSPOT_OPN_FRACTION, HOTSPOT_OPN_FRACTION_DEFAULT));
  keychooser = new HotspotIntegerGenerator(0, recordCount - 1, hotsetfraction, hotopnfraction);
  break;
 default:
  throw new WorkloadException("Unknown request distribution \"" + requestDistrib + "\"");
 }
 return keychooser;
}

代码示例来源：origin: brianfrankcooper/YCSB

scanlength = new UniformLongGenerator(minscanlength, maxscanlength);
} else if (scanlengthdistrib.compareTo("zipfian") == 0) {
 scanlength = new ZipfianGenerator(minscanlength, maxscanlength);
} else {
 throw new WorkloadException(

代码示例来源：origin: brianfrankcooper/YCSB

scanlength = new UniformLongGenerator(1, maxscanlength);
} else if (scanlengthdistrib.compareTo("zipfian") == 0) {
 scanlength = new ZipfianGenerator(1, maxscanlength);
} else {
 throw new WorkloadException(

代码示例来源：origin: com.github.ben-manes.caffeine/simulator

/**
 * Returns a sequence of events where some items are more popular than others, according to a
 * zipfian distribution.
 *
 * @param items the number of items in the distribution
 * @param events the number of events in the distribution
 */
public static LongStream zipfian(int items, int events) {
 return generate(new ZipfianGenerator(items), events);
}

代码示例来源：origin: UWSysLab/tapir

protected static IntegerGenerator getFieldLengthGenerator(Properties p)
    throws WorkloadException {
  IntegerGenerator fieldlengthgenerator;
  String fieldlengthdistribution = p.getProperty(FIELD_LENGTH_DISTRIBUTION_PROPERTY, FIELD_LENGTH_DISTRIBUTION_PROPERTY_DEFAULT);
  int num_records = Integer.parseInt(p.getProperty(Client.RECORD_COUNT_PROPERTY));
  int total_cash = Integer.parseInt(p.getProperty(TOTAL_CASH_PROPERTY, TOTAL_CASH_PROPERTY_DEFAULT));
  int fieldlength = Integer.parseInt(p.getProperty(FIELD_LENGTH_PROPERTY, FIELD_LENGTH_PROPERTY_DEFAULT));
  String fieldlengthhistogram = p.getProperty(FIELD_LENGTH_HISTOGRAM_FILE_PROPERTY, FIELD_LENGTH_HISTOGRAM_FILE_PROPERTY_DEFAULT);
  if (fieldlengthdistribution.compareTo("constant") == 0) {
    fieldlengthgenerator = new ConstantIntegerGenerator(total_cash/num_records);
  } else if (fieldlengthdistribution.compareTo("uniform") == 0) {
    fieldlengthgenerator = new UniformIntegerGenerator(1, total_cash/num_records);
  } else if (fieldlengthdistribution.compareTo("zipfian") == 0) {
    fieldlengthgenerator = new ZipfianGenerator(1, fieldlength);
  } else if (fieldlengthdistribution.compareTo("histogram") == 0) {
    try {
      fieldlengthgenerator = new HistogramGenerator(fieldlengthhistogram);
    } catch (IOException e) {
      throw new WorkloadException("Couldn't read field length histogram file: " + fieldlengthhistogram, e);
    }
  } else {
    throw new WorkloadException("Unknown field length distribution \"" + fieldlengthdistribution + "\"");
  }
  return fieldlengthgenerator;
}

代码示例来源：origin: UWSysLab/tapir

scanlength = new UniformIntegerGenerator(1, maxscanlength);
} else if (scanlengthdistrib.compareTo("zipfian") == 0) {
  scanlength = new ZipfianGenerator(1, maxscanlength);
} else {
  throw new WorkloadException("Distribution \"" + scanlengthdistrib + "\" not allowed for scan length");

内容来源于网络，如有侵权，请联系作者删除！

ZipfianGenerator

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ZipfianGenerator类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com