Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/bsspirit/maven_hadoop_template
/ functions
Functions
150 in github.com/bsspirit/maven_hadoop_template
⨍
Functions
150
◇
Types & classes
65
↓ 54 callers
Method
toString
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:117
↓ 15 callers
Method
rmr
(String folder)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:60
↓ 9 callers
Method
copyFile
(String local, String remote)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:105
↓ 7 callers
Method
config
()
src/main/java/org/conan/myhadoop/recommend/Recommend.java:57
↓ 7 callers
Method
mkdirs
(String folder)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:50
↓ 6 callers
Method
joinQueue
(ZooKeeper zk, int x)
src/main/java/org/conan/myzk/QueueZooKeeper.java:82
↓ 5 callers
Method
parser
(String line)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:25
↓ 4 callers
Method
connection
(String host)
src/main/java/org/conan/myzk/QueueZooKeeper.java:58
↓ 4 callers
Method
getRequest
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:166
↓ 4 callers
Method
initQueue
(ZooKeeper zk)
src/main/java/org/conan/myzk/QueueZooKeeper.java:70
↓ 4 callers
Method
isValid
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:215
↓ 4 callers
Method
setValid
(boolean valid)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:219
↓ 3 callers
Method
calcOther
(String file)
src/main/java/org/conan/myzk/hadoop/Other.java:19
↓ 3 callers
Method
config
()
src/main/java/org/conan/myhadoop/pagerank/PageRankJob.java:66
↓ 3 callers
Method
connection
(String host)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:55
↓ 3 callers
Method
initQueue
(ZooKeeper zk)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:67
↓ 3 callers
Method
isCompleted
(ZooKeeper zk)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:118
↓ 3 callers
Method
path
()
src/main/java/org/conan/myzk/hadoop/Sell.java:106
↓ 3 callers
Method
path
()
src/main/java/org/conan/myzk/hadoop/Purchase.java:106
↓ 3 callers
Method
setHttp_user_agent
(String http_user_agent)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:211
↓ 2 callers
Method
cat
(String remoteFile)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:120
↓ 2 callers
Method
config
()
src/main/java/org/conan/myhadoop/matrix/MainRun.java:53
↓ 2 callers
Method
config
()
src/main/java/org/conan/myzk/hadoop/Sell.java:97
↓ 2 callers
Method
config
()
src/main/java/org/conan/myzk/hadoop/Purchase.java:97
↓ 2 callers
Method
filterBroswer
PV按浏览器分类
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:99
↓ 2 callers
Method
getTime_local_Date
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:152
↓ 2 callers
Method
getTime_local_Date_hour
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:157
↓ 2 callers
Method
profit
()
src/main/java/org/conan/myzk/hadoop/Profit.java:13
↓ 2 callers
Method
rename
(String src, String dst)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:68
↓ 2 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myzk/hadoop/Sell.java:67
↓ 2 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myzk/hadoop/Purchase.java:67
↓ 2 callers
Method
scaleFloat
(float f)
src/main/java/org/conan/myhadoop/pagerank/PageRankJob.java:75
↓ 2 callers
Method
setBody_bytes_sent
(String body_bytes_sent)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:186
↓ 2 callers
Method
setHttp_referer
(String http_referer)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:203
↓ 2 callers
Method
setRemote_addr
(String remote_addr)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:136
↓ 2 callers
Method
setRemote_user
(String remote_user)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:144
↓ 2 callers
Method
setRequest
(String request)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:170
↓ 2 callers
Method
setStatus
(String status)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:178
↓ 2 callers
Method
setTime_local
(String time_local)
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:162
↓ 1 callers
Method
config
()
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:41
↓ 1 callers
Method
doAction
(int client)
src/main/java/org/conan/myzk/QueueZooKeeper.java:32
↓ 1 callers
Method
doAction
(int client)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:29
↓ 1 callers
Method
doOne
()
src/main/java/org/conan/myzk/QueueZooKeeper.java:22
↓ 1 callers
Method
doOther
(ZooKeeper zk)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:105
↓ 1 callers
Method
doPurchase
(ZooKeeper zk)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:79
↓ 1 callers
Method
doSell
(ZooKeeper zk)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:92
↓ 1 callers
Method
filterIPs
按page的独立ip分类
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:77
↓ 1 callers
Method
filterPVs
按page的pv分类
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:56
↓ 1 callers
Method
getHttp_referer_domain
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:194
↓ 1 callers
Method
getHttp_user_agent
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:207
↓ 1 callers
Method
getItemID2
()
src/main/java/org/conan/myhadoop/recommend/Step4.java:146
↓ 1 callers
Method
getNum
()
src/main/java/org/conan/myhadoop/recommend/Step4.java:154
↓ 1 callers
Method
getOther
()
src/main/java/org/conan/myzk/hadoop/Profit.java:31
↓ 1 callers
Method
getPurchase
()
src/main/java/org/conan/myzk/hadoop/Profit.java:21
↓ 1 callers
Method
getRemote_addr
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:132
↓ 1 callers
Method
getSell
()
src/main/java/org/conan/myzk/hadoop/Profit.java:26
↓ 1 callers
Method
getStatus
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:174
↓ 1 callers
Method
isCompleted
(ZooKeeper zk)
src/main/java/org/conan/myzk/QueueZooKeeper.java:88
↓ 1 callers
Method
peoplerank
()
src/main/java/org/conan/myhadoop/pagerank/PageRankJob.java:33
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/pagerank/PageRank.java:97
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/pagerank/Normal.java:63
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/pagerank/AdjacencyMatrix.java:67
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/recommend/Step4_Update.java:113
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/recommend/Step1.java:56
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/recommend/Step2.java:58
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/recommend/Step4_Update2.java:64
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/matrix/MartrixMultiply.java:111
↓ 1 callers
Method
run
(Map<String, String> path)
src/main/java/org/conan/myhadoop/matrix/SparseMartrixMultiply.java:113
↓ 1 callers
Method
run1
(Map<String, String> path)
src/main/java/org/conan/myhadoop/recommend/Step3.java:44
↓ 1 callers
Method
run2
(Map<String, String> path)
src/main/java/org/conan/myhadoop/recommend/Step3.java:83
↓ 1 callers
Method
sparseMartrixMultiply
()
src/main/java/org/conan/myhadoop/matrix/MainRun.java:36
Method
Cooccurrence
(int itemID1, int itemID2, int num)
src/main/java/org/conan/myhadoop/recommend/Step4.java:131
Method
HdfsDAO
(Configuration conf)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:21
Method
createFile
(String file, String content)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:90
Method
download
(String remote, String local)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:112
Method
filterDomain
PV按访问域名分类
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:113
Method
filterTime
PV按小时分类
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:106
Method
getBody_bytes_sent
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:182
Method
getHttp_referer
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:190
Method
getItemID1
()
src/main/java/org/conan/myhadoop/recommend/Step4.java:138
Method
getRemote_user
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:140
Method
getTime_local
()
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:148
Method
location
()
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:142
Method
ls
(String folder)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:77
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/hdfs/HdfsDAO.java:33
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/pagerank/PageRankJob.java:15
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/mr/WordCount.java:55
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/mr/kpi/KPIIP.java:53
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/mr/kpi/KPIPV.java:51
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/mr/kpi/KPIBrowser.java:51
Method
main
(String args[])
src/main/java/org/conan/myhadoop/mr/kpi/KPI.java:223
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/mr/kpi/KPITime.java:56
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/recommend/Recommend.java:15
Method
main
(String[] args)
src/main/java/org/conan/myhadoop/matrix/MainRun.java:14
Method
main
(String[] args)
src/main/java/org/conan/myzk/QueueZooKeeper.java:14
Method
main
(String[] args)
src/main/java/org/conan/myzk/BasicDemo1.java:14
Method
main
(String[] args)
src/main/java/org/conan/myzk/hadoop/ZooKeeperJob.java:21
Method
main
(String[] args)
src/main/java/org/conan/myzk/hadoop/Sell.java:114
Method
main
(String[] args)
src/main/java/org/conan/myzk/hadoop/Other.java:15
Method
main
(String[] args)
src/main/java/org/conan/myzk/hadoop/Profit.java:9
next →
1–100 of 150, ranked by callers