Functions — github.com/MrChrisJohnson/CollabStream

hub / github.com/MrChrisJohnson/CollabStream / functions

Functions148 in github.com/MrChrisJohnson/CollabStream

⨍ Functions 148◇ Types & classes 44

MethodisDistributed

()

src/main/java/collabstream/streaming/RatingsSource.java:32

MethodisDistributed

()

src/main/java/collabstream/lc/FileReaderSpout.java:25

Methodmain

(String[] args)

src/main/java/comparison/dsgd/DSGDMain.java:47

Methodmain

( String[] args )

src/main/java/collabstream/App.java:9

Methodmain

(String[] args)

src/main/java/collabstream/streaming/TestPredictions.java:12

Methodmain

(String[] args)

src/main/java/collabstream/streaming/StreamingDSGD.java:14

Methodmain

(String[] args)

src/main/java/collabstream/lc/LineCountTopology.java:17

Methodmap

(LongWritable key, Text value, Context context)

src/main/java/comparison/dsgd/mapper/DSGDPreprocRatingsMapper.java:20

Methodmap

(MatrixItem key, NullWritable value, Context context)

src/main/java/comparison/dsgd/mapper/DSGDIntermediateMapper.java:42

Methodmap

(MatrixItem key, NullWritable value, Context context)

src/main/java/comparison/dsgd/mapper/DSGDOutputFactorsMapper.java:13

Methodmap

(LongWritable key, Text value, Context context)

src/main/java/comparison/dsgd/mapper/DSGDPreprocMapper.java:18

Methodmap

(MatrixItem key, NullWritable value, Context context)

src/main/java/comparison/dsgd/mapper/DSGDRmseMapper.java:14

Methodmap

(LongWritable key, Text value, Context context)

src/main/java/comparison/dsgd/mapper/DSGDPreprocFactorMapper.java:26

MethodnextTuple

()

src/main/java/collabstream/streaming/RatingsSource.java:65

MethodnextTuple

()

src/main/java/collabstream/lc/FileReaderSpout.java:55

Methodopen

(Map stormConfig, TopologyContext context, SpoutOutputCollector collector)

src/main/java/collabstream/streaming/RatingsSource.java:36

Methodopen

(Map config, TopologyContext context, SpoutOutputCollector collector)

src/main/java/collabstream/lc/FileReaderSpout.java:29

Methodprepare

(Map stormConfig, TopologyContext context, OutputCollector collector)

src/main/java/collabstream/streaming/MatrixStore.java:26

Methodprepare

(Map stormConfig, TopologyContext context, OutputCollector collector)

src/main/java/collabstream/streaming/Master.java:47

Methodprepare

(Map stormConfig, TopologyContext context, OutputCollector collector)

src/main/java/collabstream/streaming/Worker.java:29

Methodprepare

(Map config, TopologyContext context, OutputCollector collector)

src/main/java/collabstream/lc/CounterBolt.java:19

Methodprepare

(Map config, TopologyContext context, OutputCollector collector)

src/main/java/collabstream/lc/MsgTracker.java:35

Methodprepare

(Map config, TopologyContext context, OutputCollector collector)

src/main/java/collabstream/lc/MsgForwarder.java:21

MethodreadFields

(DataInput arg0)

src/main/java/comparison/dsgd/MatrixItem.java:38

MethodreadFields

(DataInput arg0)

src/main/java/comparison/dsgd/IntMatrixItemPair.java:32

Methodreduce

(MatrixItem key, Iterable<NullWritable> values, Context context)

src/main/java/comparison/dsgd/reducer/DSGDPreprocFactorReducer.java:40

Methodreduce

(MatrixItem key, Iterable<NullWritable> values, Context context)

src/main/java/comparison/dsgd/reducer/DSGDPreprocRatingsReducer.java:14

Methodreduce

(IntMatrixItemPair key, Iterable<NullWritable> values, Context context)

src/main/java/comparison/dsgd/reducer/DSGDIntermediateReducer.java:80

Methodreduce

(MatrixItem key, Iterable<NullWritable> values, Context context)

src/main/java/comparison/dsgd/reducer/DSGDOutputFactorsReducer.java:75

Methodreduce

(MatrixItem key, Iterable<NullWritable> values, Context context)

src/main/java/comparison/dsgd/reducer/DSGDRmseReducer.java:51

Methodserialize

(BlockPair bp, DataOutputStream out)

src/main/java/collabstream/streaming/BlockPair.java:45

Methodserialize

(TrainingExample ex, DataOutputStream out)

src/main/java/collabstream/streaming/TrainingExample.java:52

Methodserialize

(float[][] matrix, DataOutputStream out)

src/main/java/collabstream/streaming/MatrixSerialization.java:16

Methodset

(IntWritable r, MatrixItem m)

src/main/java/comparison/dsgd/IntMatrixItemPair.java:26

MethodsetMatItem

(MatrixItem matItem)

src/main/java/comparison/dsgd/IntMatrixItemPair.java:62

MethodsetReducerNum

(IntWritable reducerNum)

src/main/java/comparison/dsgd/IntMatrixItemPair.java:58

Methodsetup

(Context context)

src/main/java/comparison/dsgd/reducer/DSGDPreprocFactorReducer.java:15

Methodsetup

(Context context)

src/main/java/comparison/dsgd/reducer/DSGDIntermediateReducer.java:63

Methodsetup

(Context context)

src/main/java/comparison/dsgd/reducer/DSGDOutputFactorsReducer.java:61

Methodsetup

(Context context)

src/main/java/comparison/dsgd/reducer/DSGDRmseReducer.java:35

Methodsetup

(Context context)

src/main/java/comparison/dsgd/mapper/DSGDIntermediateMapper.java:26

Methodsetup

(Context context)

src/main/java/comparison/dsgd/mapper/DSGDPreprocFactorMapper.java:19

Methodsuite

@return the suite of tests being tested

src/test/java/collabstream/AppTest.java:26

MethodtestApp

Rigourous Test :-)

src/test/java/collabstream/AppTest.java:34

MethodtoString

()

src/main/java/collabstream/streaming/WorkingBlock.java:14

MethodtoString

()

src/main/java/collabstream/streaming/TrainingExample.java:25

MethodtoString

()

src/main/java/collabstream/lc/MsgTracker.java:25

Methodwrite

(DataOutput arg0)

src/main/java/comparison/dsgd/IntMatrixItemPair.java:37

← previous101–148 of 148, ranked by callers