Functions — github.com/MrChrisJohnson/CollabStream

hub / github.com/MrChrisJohnson/CollabStream / functions

Functions148 in github.com/MrChrisJohnson/CollabStream

⨍ Functions 148◇ Types & classes 44

↓ 45 callersMethodset

(int r, int c, double v, String m)

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

↓ 40 callersMethodgetValue

()

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

↓ 23 callersMethodtoString

()

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

↓ 18 callersMethodwrite

(DataOutput arg0)

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

↓ 15 callersMethodgetColumn

()

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

↓ 15 callersMethodgetRow

()

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

↓ 12 callersMethodequals

(Object obj)

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

↓ 10 callersMethodgetMatrixType

()

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

↓ 7 callersMethodclose

()

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

↓ 6 callersMethodgetWorkingBlock

(BlockPair bp)

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

↓ 4 callersMethodgetBlockColumn

(int column, int numItems, int numReducers)

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

↓ 3 callersMethodack

(Object msgId)

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

↓ 3 callersMethodack

(Object msgId)

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

↓ 3 callersMethoddistributeWork

()

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

↓ 3 callersMethodisFactorItem

()

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

↓ 3 callersMethodisRatingsItem

()

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

↓ 2 callersMethoddotProduct

(double[] v1, double[] v2)

src/main/java/comparison/dsgd/MatrixUtils.java:5

↓ 2 callersMethodendOutput

()

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

↓ 2 callersMethodgenerateRandomMatrix

(int numRows, int numCols)

src/main/java/collabstream/streaming/MatrixUtils.java:35

↓ 2 callersMethodgetItemBlockIdx

(int itemId)

src/main/java/collabstream/streaming/Configuration.java:66

↓ 2 callersMethodgetItemBlockStart

(int itemBlockIdx)

src/main/java/collabstream/streaming/Configuration.java:90

↓ 2 callersMethodgetLatestExample

()

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

↓ 2 callersMethodgetMatItem

()

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

↓ 2 callersMethodgetNumWorkers

()

src/main/java/collabstream/streaming/Configuration.java:49

↓ 2 callersMethodgetUserBlockIdx

(int userId)

src/main/java/collabstream/streaming/Configuration.java:58

↓ 2 callersMethodgetUserBlockStart

(int userBlockIdx)

src/main/java/collabstream/streaming/Configuration.java:82

↓ 2 callersMethodrequestNextItemBlock

()

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

↓ 2 callersMethodrequestNextUserBlock

()

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

↓ 2 callersMethodtoString

(float[][] matrix)

src/main/java/collabstream/streaming/MatrixUtils.java:10

↓ 2 callersMethodupdate

(BlockPair bp, WorkingBlock workingBlock)

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

↓ 1 callersMethodequals

(Object obj)

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

↓ 1 callersMethodfree

(int userBlockIdx, int itemBlockIdx)

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

↓ 1 callersMethodgetItemBlockLength

(int itemBlockIdx)

src/main/java/collabstream/streaming/Configuration.java:78

↓ 1 callersMethodgetNumProcesses

()

src/main/java/collabstream/streaming/Configuration.java:53

↓ 1 callersMethodgetUserBlockLength

(int userBlockIdx)

src/main/java/collabstream/streaming/Configuration.java:74

↓ 1 callersMethodlock

(int userBlockIdx, int itemBlockIdx)

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

↓ 1 callersMethodpermute

(T[] arr)

src/main/java/collabstream/streaming/PermutationUtils.java:13

↓ 1 callersMethodsetColumn

(IntWritable column)

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

↓ 1 callersMethodsetMatrixType

(Text matrixType)

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

↓ 1 callersMethodsetRow

(IntWritable row)

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

↓ 1 callersMethodsetValue

(DoubleWritable value)

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

↓ 1 callersMethodstartOutput

()

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

↓ 1 callersMethodwriteItemBlock

(int itemBlockIdx, float[][] itemBlock)

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

↓ 1 callersMethodwriteUserBlock

(int userBlockIdx, float[][] userBlock)

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

MethodAppTest

Create the test case @param testName name of the test case

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

MethodBlockPair

(int userBlockIdx, int itemBlockIdx)

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

MethodConfiguration

(int numUsers, int numItems, int numLatent, int numUserBlocks, int numItemBlocks, float userPenalty, f

src/main/java/collabstream/streaming/Configuration.java:19

MethodFileReaderSpout

(String fileName)

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

MethodIntMatrixItemPair

()

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

MethodLongPair

(long first, long second)

src/main/java/comparison/dsgd/LongPair.java:8

MethodMaster

(Configuration config)

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

MethodMatrixStore

(Configuration config)

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

MethodMsgForwarder

(int fileReaderId, int counterId)

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

MethodMsgTracker

(int fileReaderId, int counterId)

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

MethodRatingsSource

(Configuration config)

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

MethodRecord

()

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

MethodTrainingExample

(int timestamp, int userId, int itemId, float rating)

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

MethodWorker

(Configuration config)

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

Methodaccept

(Class c)

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

Methodaccept

(Class c)

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

Methodaccept

(Class c)

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

Methodcleanup

(Context context)

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

Methodcleanup

Output factor matrices on cleanup

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

Methodcleanup

(Context context)

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

Methodcleanup

()

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

Methodcleanup

()

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

Methodcleanup

()

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

Methodcleanup

()

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

Methodcleanup

()

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

Methodcleanup

()

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

Methodclone

()

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

Methodclose

()

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

MethodcompareTo

(MatrixItem o)

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

MethodcompareTo

(IntMatrixItemPair o)

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

MethodcompareTo

(LongPair o)

src/main/java/comparison/dsgd/LongPair.java:13

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

MethoddeclareOutputFields

(OutputFieldsDeclarer declarer)

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

Methoddeserialize

(DataInputStream in)

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

Methoddeserialize

(DataInputStream in)

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

Methoddeserialize

(DataInputStream in)

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

Methodexecute

(Tuple tuple)

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

Methodexecute

(Tuple tuple)

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

Methodexecute

(Tuple tuple)

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

Methodexecute

(Tuple tuple)

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

Methodexecute

(Tuple tuple)

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

Methodexecute

(Tuple tuple)

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

Methodfail

(Object msgId)

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

Methodfail

(Object msgId)

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

MethodgetBlockRow

(int row, int numUsers, int numReducers)

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

MethodgetReducerNum

()

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

MethodhashCode

()

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

MethodhashCode

()

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

MethodinitialValue

()

src/main/java/collabstream/streaming/PermutationUtils.java:10

MethodinitialValue

()

src/main/java/collabstream/streaming/MatrixUtils.java:7

next →1–100 of 148, ranked by callers