MCPcopy Create free account

hub / github.com/bigdataguide/hadooptraining / functions

Functions92 in github.com/bigdataguide/hadooptraining

⨍ Functions 92◇ Types & classes 31↳ Endpoints 1
↓ 5 callersMethod__merge_dict
合并多个字典并返回
visualization/py-echarts/models.py:247
↓ 3 callersMethodexecute
(Tuple input, BasicOutputCollector collector)
storm/storm_realtime_process/src/main/java/bigdata/storm/WebsiteBolt.java:20
↓ 3 callersMethody_axis
添加X轴
visualization/py-echarts/models.py:178
↓ 2 callersMethodingest
(String path)
hbase/hbase-ingest/src/main/java/bigdata/hbase/Ingest.java:71
↓ 2 callersMethodrun
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/Grep.java:26
↓ 2 callersMethodshutdown
()
hbase/hbase-ingest/src/main/java/bigdata/hbase/Ingest.java:47
↓ 1 callersMethodbar
添加一个柱状图 `data`: [10, 20, 30, 40] `auto_legend`: 自动生成图例
visualization/py-echarts/models.py:114
↓ 1 callersFunctioncharArrayToString
hadoop/streaming/mapper.cpp:10
↓ 1 callersMethodcreateTable
()
hbase/hbase-ingest/src/main/java/bigdata/hbase/Ingest.java:56
↓ 1 callersFunctiongenerate_brand
()
datasource/brand.py:19
↓ 1 callersFunctiongenerate_record
(total)
datasource/record.py:34
↓ 1 callersFunctiongenerate_user
(count)
datasource/user.py:18
↓ 1 callersMethodgetAgeDict
(self, tuples)
visualization/py-echarts/query_presto.py:39
↓ 1 callersMethodgetConfig
()
storm/storm_realtime_process/src/main/java/bigdata/storm/LogProcessTopology.java:65
↓ 1 callersFunctiongetCurrentYmdHM
()
etl/start_etl.py:11
↓ 1 callersMethodgetHBaseConfiguration
()
hbase/hbase-ingest/src/main/java/bigdata/hbase/Ingest.java:31
↓ 1 callersMethodgetKeys
(self,tuples)
visualization/py-echarts/query_presto.py:20
↓ 1 callersMethodgetStormTopology
()
storm/storm_realtime_process/src/main/java/bigdata/storm/LogProcessTopology.java:34
↓ 1 callersMethodgetValues
(self, tuples)
visualization/py-echarts/query_presto.py:26
↓ 1 callersFunctionget_brand_list
()
datasource/record.py:57
↓ 1 callersFunctionget_one_brand
(category_list,id)
datasource/brand.py:9
↓ 1 callersFunctionget_one_record
(fake,user_list,brand_list,id)
datasource/record.py:16
↓ 1 callersFunctionget_one_user
(fake,id)
datasource/user.py:10
↓ 1 callersMethodget_province_price
(self,dict)
visualization/py-echarts/query_redis.py:15
↓ 1 callersFunctionget_user_list
()
datasource/record.py:51
↓ 1 callersMethodinit
()
hbase/hbase-ingest/src/main/java/bigdata/hbase/Ingest.java:40
↓ 1 callersMethodloadData
(String dataDir, String date, String hour_minute)
etl/loadDataToHive/src/main/java/bigdata/etl/loadDataToHive.java:14
↓ 1 callersFunctionmain
()
visualization/py-echarts/models.py:254
↓ 1 callersMethodmap
(self,data,**kwargs)
visualization/py-echarts/models.py:191
↓ 1 callersMethodpie
添加一个饼图 `data`: {u"名称": 100}, u"名称2": 200}
visualization/py-echarts/models.py:95
↓ 1 callersMethodprocess
()
hbase/hbase-ingest/src/main/java/bigdata/hbase/Query.java:31
↓ 1 callersMethodprocess
(String line)
hbase/hbase-ingest/src/main/java/bigdata/hbase/Ingest.java:94
↓ 1 callersMethodquery_age_price
(self)
visualization/py-echarts/query_presto.py:32
↓ 1 callersMethodquery_brand_price
(self)
visualization/py-echarts/query_presto.py:13
↓ 1 callersMethodquery_province
(self)
visualization/py-echarts/query_redis.py:11
↓ 1 callersMethodrun
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/OOMTest.java:73
↓ 1 callersMethodrun
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/TaskAttemptTest.java:56
↓ 1 callersMethodrun
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/JobFailureTest.java:56
↓ 1 callersFunctionstartETL
()
etl/start_etl.py:21
↓ 1 callersMethodtestMkdirPath
(String path)
hadoop/src/main/java/cn/chinahadoop/hdfs/HdfsExample.java:9
↓ 1 callersFunctiontimestamp_datetime
(value)
etl/etl.py:7
↓ 1 callersMethodtooltip
设置提示信息
visualization/py-echarts/models.py:56
↓ 1 callersMethodx_axis
添加X轴
visualization/py-echarts/models.py:164
MethodGrep
()
hadoop/src/main/java/cn/chinahadoop/mapreduce/Grep.java:23
MethodProvinceStoreMapper
()
storm/storm_realtime_process/src/main/java/bigdata/storm/ProvinceStoreMapper.java:14
MethodWebsiteStoreMapper
()
storm/storm_realtime_process/src/main/java/bigdata/storm/WebsiteStoreMapper.java:14
Method__init__
(self)
visualization/py-echarts/models.py:9
MethoddeclareOutputFields
(OutputFieldsDeclarer declarer)
storm/storm_realtime_process/src/main/java/bigdata/storm/WebsiteBolt.java:31
MethoddeclareOutputFields
(OutputFieldsDeclarer declarer)
storm/storm_realtime_process/src/main/java/bigdata/storm/ProvinceBolt.java:32
MethoddeclareOutputFields
(OutputFieldsDeclarer outputFieldsDeclarer)
storm/storm_realtime_process/src/main/java/bigdata/storm/ExtractBolt.java:38
Methodexecute
(Tuple input, BasicOutputCollector collector)
storm/storm_realtime_process/src/main/java/bigdata/storm/ProvinceBolt.java:21
Methodexecute
(Tuple tuple, BasicOutputCollector basicOutputCollector)
storm/storm_realtime_process/src/main/java/bigdata/storm/ExtractBolt.java:19
MethodgetDataTypeDescription
()
storm/storm_realtime_process/src/main/java/bigdata/storm/ProvinceStoreMapper.java:19
MethodgetDataTypeDescription
()
storm/storm_realtime_process/src/main/java/bigdata/storm/WebsiteStoreMapper.java:19
MethodgetHBaseConfiguration
()
hbase/hbase-ingest/src/main/java/bigdata/hbase/Query.java:22
MethodgetKeyFromTuple
(ITuple iTuple)
storm/storm_realtime_process/src/main/java/bigdata/storm/ProvinceStoreMapper.java:23
MethodgetKeyFromTuple
(ITuple iTuple)
storm/storm_realtime_process/src/main/java/bigdata/storm/WebsiteStoreMapper.java:23
MethodgetValueFromTuple
(ITuple iTuple)
storm/storm_realtime_process/src/main/java/bigdata/storm/ProvinceStoreMapper.java:27
MethodgetValueFromTuple
(ITuple iTuple)
storm/storm_realtime_process/src/main/java/bigdata/storm/WebsiteStoreMapper.java:27
Functionindex
()
visualization/py-echarts/main.py:12
Methodlegend
设置图例 `data`: [u"图例1", u"图例2", u"图例3"] `orient`: "vertical"|"horizontal"
visualization/py-echarts/models.py:69
Methodline
添加一个折线图 `data`: [10, 20, 30, 40]
visualization/py-echarts/models.py:133
Functionmain
hadoop/streaming/reducer.cpp:8
Functionmain
hadoop/streaming/mapper.cpp:25
Functionmain
hadoop/streaming/mapper2.cpp:8
Methodmain
(String[] args)
storm/storm_realtime_process/src/main/java/bigdata/storm/LogProcessTopology.java:70
Methodmain
(String[] args)
etl/loadDataToHive/src/main/java/bigdata/etl/loadDataToHive.java:28
Methodmain
(String[] args)
hadoop/src/main/java/cn/chinahadoop/hdfs/HdfsExample.java:46
Methodmain
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/OOMTest.java:98
Methodmain
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/TaskAttemptTest.java:82
Methodmain
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/InvertedIndex.java:59
Methodmain
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/JobFailureTest.java:82
Methodmain
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/Grep.java:84
Methodmain
(String[] args)
hadoop/src/main/java/cn/chinahadoop/mapreduce/WordCount.java:47
Methodmain
(String[] args)
hbase/hbase-ingest/src/main/java/bigdata/hbase/RecordIngest.java:22
Methodmain
(String[] args)
hbase/hbase-ingest/src/main/java/bigdata/hbase/Query.java:50
Methodmain
(String[] args)
hbase/hbase-ingest/src/main/java/bigdata/hbase/ProfileIngest.java:29
Methodmap
(Object key, Text value, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/OOMTest.java:34
Methodmap
(Object key, Text value, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/TaskAttemptTest.java:27
Methodmap
(LongWritable key, Text value, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/InvertedIndex.java:28
Methodmap
(Object key, Text value, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/JobFailureTest.java:27
Methodmap
(Object key, Text value, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/WordCount.java:24
Methodprocess
(String line)
hbase/hbase-ingest/src/main/java/bigdata/hbase/RecordIngest.java:15
Methodprocess
(String line)
hbase/hbase-ingest/src/main/java/bigdata/hbase/ProfileIngest.java:18
Methodreduce
(Text key, Iterable<IntWritable> values, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/OOMTest.java:62
Methodreduce
(Text key, Iterable<IntWritable> values, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/TaskAttemptTest.java:45
Methodreduce
(Text key, Iterable<Text> values, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/InvertedIndex.java:42
Methodreduce
(Text key, Iterable<IntWritable> values, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/JobFailureTest.java:45
Methodreduce
(Text key, Iterable<IntWritable> values, Context context)
hadoop/src/main/java/cn/chinahadoop/mapreduce/WordCount.java:36
MethodtestDeletePath
(String path)
hadoop/src/main/java/cn/chinahadoop/hdfs/HdfsExample.java:28
Methodtitle
设置图表标题
visualization/py-echarts/models.py:46
Methodtoolbox
设置工具箱
visualization/py-echarts/models.py:84