org.apache.flink.graph.generator.random

Interface RandomGenerableFactory<T extends org.apache.commons.math3.random.RandomGenerator>

Type Parameters:

T - the type of the RandomGenerator

All Known Implementing Classes:

GeneratorFactoryBase, JDKRandomGeneratorFactory, MersenneTwisterFactory

public interface RandomGenerableFactory<T extends org.apache.commons.math3.random.RandomGenerator>

A RandomGenerableFactory returns a scale-free collection of sources of pseudorandomness which can be used to perform repeatable parallel computation regardless of parallelism.

 
 RandomGenerableFactory<JDKRandomGenerator> factory = new JDKRandomGeneratorFactory()

 List<BlockInfo<T>> generatorBlocks = factory
     .getRandomGenerables(elementCount, cyclesPerElement);

 DataSet<...> generatedEdges = env
     .fromCollection(generatorBlocks)
         .name("Random generators")
     .flatMap(...
 
 

Method Summary

Modifier and Type	Method and Description
List<BlockInfo<T>>	getRandomGenerables(long elementCount, int cyclesPerElement) The amount of work (elementCount * cyclesPerElement) is used to generate a list of blocks of work of near-equal size.

Method Detail

getRandomGenerables

List<BlockInfo<T>> getRandomGenerables(long elementCount,
                                       int cyclesPerElement)

The amount of work (elementCount * cyclesPerElement) is used to generate a list of blocks of work of near-equal size.

Parameters:

elementCount - number of elements, as indexed in the BlockInfo

cyclesPerElement - number of cycles of the PRNG per element

Returns:

the list of configuration blocks