MCPcopy Create free account

hub / github.com/databricks/simr / functions

Functions38 in github.com/databricks/simr

↓ 9 callersMethodcontainsCommand
(String key)
src/main/java/org/apache/spark/simr/CmdLine.java:71
↓ 6 callersMethodtoString
()
src/main/java/org/apache/spark/simr/CmdLine.java:32
↓ 5 callersMethodgetIntValue
(String key)
src/main/java/org/apache/spark/simr/CmdLine.java:58
↓ 3 callersMethodclose
()
src/main/java/org/apache/spark/simr/SimrInputFormat.java:78
↓ 3 callersMethodgetCmd
(String key)
src/main/java/org/apache/spark/simr/CmdLine.java:75
↓ 3 callersMethodgetLocalIP
@return The IP of the first network interface on this machine as a string, null in the case of an exception from the underlying network interface.
src/main/java/org/apache/spark/simr/Simr.java:73
↓ 3 callersMethodmain
(String[] args)
src/main/java/org/apache/spark/simr/SimrJob.java:346
↓ 2 callersMethodgetArgs
()
src/main/java/org/apache/spark/simr/CmdLine.java:50
↓ 2 callersMethodrun
()
src/main/java/org/apache/spark/simr/SimrJob.java:300
↓ 1 callersMethodcheckParams
()
src/main/java/org/apache/spark/simr/SimrJob.java:98
↓ 1 callersMethodgetClusterSize
()
src/main/java/org/apache/spark/simr/SimrJob.java:84
↓ 1 callersMethodgetMasterURL
()
src/main/java/org/apache/spark/simr/Simr.java:161
↓ 1 callersMethodisMaster
()
src/main/java/org/apache/spark/simr/Simr.java:196
↓ 1 callersMethodisUnique
()
src/main/java/org/apache/spark/simr/Simr.java:222
↓ 1 callersMethodparse
()
src/main/java/org/apache/spark/simr/CmdLine.java:81
↓ 1 callersMethodredirectOutput
(String filePrefix)
src/main/java/org/apache/spark/simr/Simr.java:104
↓ 1 callersMethodrun
()
src/main/java/org/apache/spark/simr/Simr.java:242
↓ 1 callersMethodsetClusterSize
(int size)
src/main/java/org/apache/spark/simr/SimrJob.java:80
↓ 1 callersMethodsetupJob
(Configuration conf)
src/main/java/org/apache/spark/simr/SimrJob.java:264
↓ 1 callersMethodstartDriver
()
src/main/java/org/apache/spark/simr/Simr.java:113
↓ 1 callersMethodstartWorker
()
src/main/java/org/apache/spark/simr/Simr.java:137
↓ 1 callersMethodupdateConfig
(Configuration conf)
src/main/java/org/apache/spark/simr/SimrJob.java:155
MethodCmd
(String key, String val)
src/main/java/org/apache/spark/simr/CmdLine.java:27
MethodCmdLine
(String[] args)
src/main/java/org/apache/spark/simr/CmdLine.java:46
MethodSimr
(Mapper.Context context)
src/main/java/org/apache/spark/simr/Simr.java:63
MethodSimrJob
(String[] args)
src/main/java/org/apache/spark/simr/SimrJob.java:56
MethodUrlCoresTuple
(String _url, int _cores)
src/main/java/org/apache/spark/simr/Simr.java:57
MethodcreateRecordReader
(InputSplit split, TaskAttemptContext context)
src/main/java/org/apache/spark/simr/SimrInputFormat.java:83
MethodgetCmds
()
src/main/java/org/apache/spark/simr/CmdLine.java:54
MethodgetCurrentKey
()
src/main/java/org/apache/spark/simr/SimrInputFormat.java:70
MethodgetCurrentValue
()
src/main/java/org/apache/spark/simr/SimrInputFormat.java:74
MethodgetProgress
()
src/main/java/org/apache/spark/simr/SimrInputFormat.java:80
MethodgetSplits
Generate the specified number of dummy splits as given by simr
src/main/java/org/apache/spark/simr/SimrInputFormat.java:38
Methodinitialize
(InputSplit split, TaskAttemptContext context)
src/main/java/org/apache/spark/simr/SimrInputFormat.java:58
Methodmap
(Object key, Text value, Context context )
src/main/java/org/apache/spark/simr/SimrJob.java:64
MethodnextKeyValue
()
src/main/java/org/apache/spark/simr/SimrInputFormat.java:62
Methodrun
()
src/main/java/org/apache/spark/simr/SimrJob.java:69
Methodrun
(String[] args)
src/main/java/org/apache/spark/simr/SimrJob.java:88