Variables
string	comment = "# Params: "

int	D = 1

int	maxx = 100

int	minx = -100

int	N = 1000000

int	noise_add_sig = 10

int	noise_mu = 1

float	noise_sig = 0.1

int	param_mu = 1

float	param_sig = 0.2

list	params = [random.gauss(param_mu, param_sig) for x in range(0, D)]

int	SEED = 666

string	string = " ".join(map(str,x)) + " "

int	value = 0

list	x = [random.uniform(minx, maxx) for x in range(0,D)]

Variable Documentation

◆ comment

string comment = "# Params: "

Definition at line 32 of file gen_data.py.

◆ D

◆ maxx

int maxx = 100

Definition at line 19 of file gen_data.py.

◆ minx

int minx = -100

Definition at line 18 of file gen_data.py.

◆ N

int N = 1000000

Definition at line 15 of file gen_data.py.

Referenced by Serialization< Archive, std::array< T, N >, typename std::enable_if< !std::is_pod< std::array< T, N > >::value >::type >.Deserialize(), tlx.multisequence_partition(), tlx.multisequence_selection(), ComponentSum< std::array< Type, N >, Operation >.operator()(), and thrill::common.Put().

◆ noise_add_sig

int noise_add_sig = 10

Definition at line 27 of file gen_data.py.

◆ noise_mu

int noise_mu = 1

Definition at line 24 of file gen_data.py.

◆ noise_sig

float noise_sig = 0.1

Definition at line 25 of file gen_data.py.

◆ param_mu

int param_mu = 1

Definition at line 21 of file gen_data.py.

◆ param_sig

float param_sig = 0.2

Definition at line 22 of file gen_data.py.

◆ params

list params = [random.gauss(param_mu, param_sig) for x in range(0, D)]

Definition at line 30 of file gen_data.py.

Referenced by thrill::data.ConstructDynBlockReader(), and thrill::data.ConstructDynBlockSource().

◆ SEED

int SEED = 666

Definition at line 16 of file gen_data.py.

◆ string

string string = " ".join(map(str,x)) + " "

Definition at line 40 of file gen_data.py.

◆ value

int value = 0

Definition at line 41 of file gen_data.py.

Referenced by AggregateMinMax< Type_ >.add(), Aggregate< Type_ >.add(), new_alloc< Type >.address(), FlowControlChannel.AllReduce(), DIA< BfsNode >.AllReduce(), DIA< BfsNode >.AllReduceFuture(), tlx.apply_tuple(), foxxll.as_signed(), foxxll.as_unsigned(), FlowControlChannel.Broadcast(), thrill::mem.by_new(), tlx.call_foreach_tuple(), tlx.call_foreach_tuple_with_index(), thrill::data::serialization_cereal.CEREAL_SAVE_FUNCTION_NAME(), CountingPtr< WriteStream >.CountingPtr(), tlx.exclusive_scan(), DIA< BfsNode >.ExPrefixSum(), FlowControlChannel.ExPrefixSumTotal(), DIA< BfsNode >.Filter(), tlx.fold_left_tuple(), tlx.fold_right_tuple(), Delegate< R(A...), Allocator >.functor_caller(), thrill::api.Generate(), MergeNode< ValueType, Comparator, kNumInputs >.GetGlobalRanks(), File.GetIndexOf(), BlockReader< CatBlockSource >.GetRaw(), DIA< BfsNode >.GroupByKey(), DIA< BfsNode >.GroupToIndex(), DAryHeap< KeyType, Arity, Compare >.heapify(), DAryAddressableIntHeap< KeyType, Arity, Compare >.heapify(), thrill::api.InnerJoin(), BTree< key_type, value_type, key_of_value, key_compare, traits, true, allocator_type >.insert_descend(), Delegate< R(A...), Allocator >.make(), DIA< BfsNode >.Map(), thrill::api.Merge(), thrill::core::hyperloglog.mergeSameIndices(), thrill::mem.mm_new(), DeltaStreamReader< StreamReader, Type, offset_ >.Next(), GolombBitStreamReader< BlockReader >.Next(), FunctionChain< Functors >.operator()(), ZipNode< ValueType, ZipFunction, Pad, UnequalCheck, NoRebalance, kNumInputs >::RegisterParent.operator()(), ZipWindowNode< ValueType, ZipFunction_, Pad_, UnequalCheck, UseStdArray, kNumInputs_ >::RegisterParent.operator()(), thrill::data.OurNewHandler(), DIA< BfsNode >.PrefixSum(), FlowControlChannel.PrefixSumBase(), Group.PrefixSumDoubling(), Group.PrefixSumHypercube(), DeltaStreamWriter< StreamWriter, Type, offset_ >.Put(), FixedBufferBuilder< Capacity >.Put(), thrill::common.Put(), BitStreamWriter< BlockWriter >.PutBits(), BlockWriter< BlockSink >.PutRaw(), ReadInputFile(), Connection.Receive(), Group.ReceiveFrom(), Connection.ReceiveN(), Connection.ReceiveSend(), FlowControlChannel.Reduce(), DIA< BfsNode >.ReduceByKey(), DIA< BfsNode >.ReducePair(), DIA< BfsNode >.ReduceToIndex(), Connection.Send(), Connection.SendN(), Connection.SendReceive(), BTree< Key, Value, KeyOfValue, Compare, Traits, Duplicates, Allocator >::LeafNode.set_slot(), DAryHeap< KeyType, Arity, Compare >.sift_down(), DAryAddressableIntHeap< KeyType, Arity, Compare >.sift_down(), DAryHeap< KeyType, Arity, Compare >.sift_up(), DAryAddressableIntHeap< KeyType, Arity, Compare >.sift_up(), DIA< BfsNode >.Sort(), DIA< BfsNode >.SortStable(), thrill::core::hyperloglog.splitSparseRegister(), DIA< BfsNode >.Sum(), DIA< BfsNode >.SumFuture(), HyperLogLogRegisters< p >.toDense(), tlx.vmap_foreach_tuple(), tlx.vmap_foreach_tuple_with_index(), DIA< BfsNode >.Window(), DIA< BfsNode >.WriteLines(), DIA< BfsNode >.WriteLinesFuture(), DIA< BfsNode >.WriteLinesOne(), DIA< BfsNode >.WriteLinesOneFuture(), thrill::api.Zip(), thrill::api.ZipWindow(), and DIA< BfsNode >.ZipWithIndex().

◆ x

list x = [random.uniform(minx, maxx) for x in range(0,D)]

Examples:: examples/tutorial/k-means_step1.cpp, examples/tutorial/k-means_step2.cpp, examples/tutorial/k-means_step3.cpp, examples/tutorial/k-means_step4.cpp, examples/tutorial/k-means_step5.cpp, and examples/tutorial/k-means_step6.cpp.

Definition at line 39 of file gen_data.py.

Referenced by ReservoirSampling< Type, RNG >.add(), ReservoirSamplingFast< ValueType, decltype(rng_)>.add(), ReservoirSamplingGrow< SampleIndexPair >.add(), AllocatorBase< char >.address(), VMapForRangeImpl< Index, Size, Functor >.call(), RadixHeap< ValueType, KeyExtract, KeyType, Radix >.clear(), tlx.clz_template(), examples::suffix_sorting.ConstructWaveletTree(), ConstructWaveletTree(), tlx.ctz_template(), stats_data.fetch_sum(), hypergeometric_distribution<>.loggam(), tlx::digest_detail.min(), tlx::multiway_merge_detail.multiway_merge_loser_tree(), maximum< T >.operator()(), minimum< T >.operator()(), TabulationHashing< size, hash_t, prng_t >.operator()(), tlx.power_to_the(), HashDataSwitch< T >.ptr(), BlockWriter< BlockSink >.Put(), BlockWriter< BlockSink >.PutNoSelfVerify(), tlx.random_bipartition_shuffle(), RadixHeap< ValueType, KeyExtract, KeyType, Radix >.reorganize_(), tlx.rol32_generic(), tlx.rol64_generic(), tlx.ror32_generic(), tlx.ror64_generic(), RunStochasticGradGenerated(), Serialization< Archive, T, typename std::enable_if< std::is_pod< T >::value &&!std::is_pointer< T >::value >::type >.Serialize(), tlx.splay_erase(), stats_data::summary< T >.summary(), tlx::meta_detail.vmap_foreach_impl(), and tlx::meta_detail.vmap_foreach_with_index_impl().

Variables