import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public Iterable<OpDistributionFactory> each()
{
    List<OpDistributionFactory> out = new ArrayList<>();
    for (final Map.Entry<T, Double> ratio : ratios.entrySet())
    {
        out.add(new OpDistributionFactory()
        {
            public OpDistribution get(Timing timing, int sampleCount)
            {
                return new FixedOpDistribution(SampledOpDistributionFactory.this.get(timing.newTimer(ratio.getKey().toString(), sampleCount), newGenerator(), ratio.getKey()));
            }

            public String desc()
            {
                return ratio.getKey().toString();
            }

            public Iterable<OpDistributionFactory> each()
            {
                return Collections.<OpDistributionFactory>singleton(this);
            }
        });
    }
    return out;
}
 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public OpDistributionFactory getFactory(final StressSettings settings)
{
    final SeedManager seeds = new SeedManager(settings);
    return new OpDistributionFactory()
    {
        public OpDistribution get(Timing timing, int sampleCount)
        {
            return new FixedOpDistribution(PredefinedOperation.operation(type, timing.newTimer(type.toString(), sampleCount),
                                           newGenerator(settings), seeds, settings, add));
        }

        public String desc()
        {
            return type.toString();
        }

        public Iterable<OpDistributionFactory> each()
        {
            return Collections.<OpDistributionFactory>singleton(this);
        }
    };
}
 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public OpDistributionFactory getFactory(final StressSettings settings)
{
    final SeedManager seeds = new SeedManager(settings);
    return new OpDistributionFactory()
    {
        public OpDistribution get(Timing timing, int sampleCount, boolean isWarmup)
        {
            return new FixedOpDistribution(PredefinedOperation.operation(type, timing.newTimer(type.toString(), sampleCount),
                                           newGenerator(settings), seeds, settings, add));
        }

        public String desc()
        {
            return type.toString();
        }

        public Iterable<OpDistributionFactory> each()
        {
            return Collections.<OpDistributionFactory>singleton(this);
        }
    };
}
 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public OpDistribution get(Timing timing, int sampleCount)
{
    PartitionGenerator generator = newGenerator();
    List<Pair<Operation, Double>> operations = new ArrayList<>();
    for (Map.Entry<T, Double> ratio : ratios.entrySet())
        operations.add(new Pair<>(get(timing.newTimer(ratio.getKey().toString(), sampleCount), generator, ratio.getKey()),
                                  ratio.getValue()));
    return new SampledOpDistribution(new EnumeratedDistribution<>(operations), clustering.get());
}
 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public OpDistribution get(Timing timing, int sampleCount, boolean isWarmup)
{
    PartitionGenerator generator = newGenerator();
    List<Pair<Operation, Double>> operations = new ArrayList<>();
    for (Map.Entry<T, Double> ratio : ratios.entrySet())
    {
        List<? extends Operation> ops = get(timing.newTimer(ratio.getKey().toString(), sampleCount),
                                            generator, ratio.getKey(), isWarmup);
        for (Operation op : ops)
            operations.add(new Pair<>(op, ratio.getValue() / ops.size()));
    }
    return new SampledOpDistribution(new EnumeratedDistribution<>(operations), clustering.get());
}
 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
private void update() throws InterruptedException
{
    Timing.TimingResult<JmxCollector.GcStats> result = timing.snap(gcStatsCollector);
    totalGcStats = JmxCollector.GcStats.aggregate(Arrays.asList(totalGcStats, result.extra));
    if (result.timing.partitionCount != 0)
        printRow("", result.timing, timing.getHistory(), result.extra, rowRateUncertainty, output);
    rowRateUncertainty.update(result.timing.adjustedRowRate());
    if (timing.done())
        stop = true;
}
 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public Timing getTiming()
{
    return timing;
}
 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public OpDistribution get(Timing timing, int sampleCount); 

import org.apache.cassandra.stress.util.Timing; //导入依赖的package包/类
public OpDistribution get(Timing timing, int sampleCount, boolean isWarmup);