Thrill  0.1
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
gen_data Namespace Reference

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 = " "
 
int value = 0
 
list x = [random.uniform(minx, maxx) for x in range(0,D)]
 

Variable Documentation

string comment = "# Params: "

Definition at line 32 of file gen_data.py.

int maxx = 100

Definition at line 19 of file gen_data.py.

int minx = -100

Definition at line 18 of file gen_data.py.

int noise_add_sig = 10

Definition at line 27 of file gen_data.py.

int noise_mu = 1

Definition at line 24 of file gen_data.py.

float noise_sig = 0.1

Definition at line 25 of file gen_data.py.

int param_mu = 1

Definition at line 21 of file gen_data.py.

float param_sig = 0.2

Definition at line 22 of file gen_data.py.

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

Definition at line 16 of file gen_data.py.

string string = " "

Definition at line 40 of file gen_data.py.

int value = 0

Definition at line 41 of file gen_data.py.

Referenced by Aggregate< Type_ >.Add(), FlowControlChannel.AllReduce(), DIA< ValueType_, Stack_ >.AllReduce(), DIA< ValueType_, Stack_ >.AllReduceFuture(), tlx.apply_tuple(), FlowControlChannel.Broadcast(), thrill::mem.by_new(), tlx.call_foreach_tuple(), tlx.call_foreach_tuple_with_index(), Group.ExPrefixSumPlusInt(), Group.ExPrefixSumPlusLong(), Group.ExPrefixSumPlusLongLong(), Group.ExPrefixSumPlusUnsignedInt(), Group.ExPrefixSumPlusUnsignedLong(), Group.ExPrefixSumPlusUnsignedLongLong(), FlowControlChannel.ExPrefixSumTotal(), DIA< ValueType_, Stack_ >.Filter(), thrill::api.Generate(), MergeNode< ValueType, Comparator, kNumInputs >.GetGlobalRanks(), File.GetIndexOf(), BlockReader< CatBlockSource >.GetRaw(), DIA< ValueType_, Stack_ >.GroupByKey(), DIA< ValueType_, Stack_ >.GroupToIndex(), thrill::api.InnerJoin(), DIA< ValueType_, Stack_ >.Map(), thrill::api.Merge(), 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()(), FlowControlChannel.PrefixSum(), DIA< ValueType_, Stack_ >.PrefixSum(), Group.PrefixSumDoubling(), Group.PrefixSumHypercube(), DeltaStreamWriter< StreamWriter, Type, offset_ >.Put(), FixedBufferBuilder< Capacity >.Put(), thrill::common.Put(), BitStreamWriter< BlockWriter >.PutBits(), BlockWriter< BlockSink >.PutRaw(), ReadInputFile(), FlowControlChannel.Reduce(), DIA< ValueType_, Stack_ >.ReduceByKey(), DIA< ValueType_, Stack_ >.ReducePair(), DIA< ValueType_, Stack_ >.ReduceToIndex(), DIA< ValueType_, Stack_ >.Sort(), thrill::core::hyperloglog.splitSparseRegister(), DIA< ValueType_, Stack_ >.Sum(), DIA< ValueType_, Stack_ >.SumFuture(), HyperLogLogRegisters< p >.toDense(), DIA< ValueType_, Stack_ >.Window(), DIA< ValueType_, Stack_ >.WriteLines(), DIA< ValueType_, Stack_ >.WriteLinesFuture(), DIA< ValueType_, Stack_ >.WriteLinesOne(), DIA< ValueType_, Stack_ >.WriteLinesOneFuture(), thrill::api.Zip(), thrill::api.ZipWindow(), and DIA< ValueType_, Stack_ >.ZipWithIndex().