Functions — github.com/Mydreamandreality/sparkResearch

CodeHub MCPcopy Create free account

hub / github.com/Mydreamandreality/sparkResearch / functions

Functions89 in github.com/Mydreamandreality/sparkResearch

⨍ Functions 89 ◇ Types & classes 55

↓ 11 callersMethodmap

计算RDD中各值的平方

chapter4/src/main/java/spark/Chapter4.java:27

↓ 8 callersMethodadd

chapter8/src/main/java/AttackAccumulator.java:43

↓ 8 callersMethodtextFile

(JavaSparkContext sparkContext)

chapter7/src/main/java/SaprkFile.java:24

↓ 4 callersMethodflatMap

flatMap分割字符串

chapter4/src/main/java/spark/Chapter4.java:43

↓ 4 callersMethodvalue

chapter8/src/main/java/AttackAccumulator.java:55

↓ 2 callersMethodconsoleResult

(String delimit, StringBuffer stringBuffer, Map<String, Integer> mapNode, Map<String, Integer> mapNodeTo)

chapter8/src/main/java/AttackAccumulator.java:85

↓ 2 callersMethodconsoleResult

(String delimit, StringBuffer stringBuffer, Map<String, Integer> mapNode, Map<String, Integer> mapNodeTo)

chapter8/src/main/java/TestMerge.java:41

↓ 2 callersMethodmergeData

(String data_1, String data_2, String delimit)

chapter8/src/main/java/AttackAccumulator.java:66

↓ 2 callersMethodresultKV

(String delimit, String[] infos)

chapter8/src/main/java/AttackAccumulator.java:103

↓ 2 callersMethodresultKV

(String delimit, String[] infos)

chapter8/src/main/java/TestMerge.java:59

↓ 1 callersMethodavg

chapter4/src/main/java/spark/RddAvg.java:22

↓ 1 callersMethodgetConnection

chapter19/src/main/java/tools/ConnectionPool.java:27

↓ 1 callersMethodgetConsumers

kafka-test/src/main/java/v1/KafkaConsumers.java:37

↓ 1 callersMethodmap

src/main/java/spark/Lombda.java:24

↓ 1 callersMethodmergeData

(String data_1, String data_2, String delimit)

chapter8/src/main/java/TestMerge.java:22

↓ 1 callersMethodrddAvg

(JavaSparkContext sparkContext)

chapter4/src/main/java/spark/Application.java:21

↓ 1 callersMethodreturnConnection

return push connection @param conn this connection

chapter19/src/main/java/tools/ConnectionPool.java:47

↓ 1 callersMethodreturnResult

src/main/java/spark/Lombda.java:43

↓ 1 callersMethodrun

(JavaSparkContext sparkContext)

chapter7/src/main/java/CsvFile.java:27

↓ 1 callersMethodsendProducer

kafka-test/src/main/java/v1/KafkaProducers.java:35

MethodContainsErrorDev

chapter3/src/main/java/spark/LogError.java:52

MethodKafkaConsumers

kafka-test/src/main/java/v1/KafkaConsumers.java:24

MethodKafkaProducers

kafka-test/src/main/java/v1/KafkaProducers.java:22

(String name, Integer age)

chapter10/src/main/java/dataset/Person.java:19

(Integer total, Integer num)

chapter4/src/main/java/spark/RddAvg.java:17

chapter7/src/main/java/CsvFile.java:20

(Tuple2<Text, IntWritable> textIntWritableTuple2)

chapter7/src/main/java/SequenceFile.java:29

(Iterator<String> lines)

chapter7/src/main/java/SaprkFile.java:40

(Iterator<Person> personIterator)

chapter7/src/main/java/SaprkFile.java:59

chapter7/src/main/java/SaprkFile.java:75

chapter23/src/main/java/v1/SpamEmail.java:45

chapter17/src/main/java/SparkStreamDemo.java:26

chapter19/src/main/java/ReduceByKeyAndWindow.java:43

(Long v1, Long v2)

chapter19/src/main/java/ReduceByKeyAndWindow.java:54

(Long v1, Long v2)

chapter19/src/main/java/ReduceByKeyAndWindow.java:65

chapter19/src/main/java/StateLess.java:33

(Integer v1, Integer v2)

chapter19/src/main/java/StateLess.java:41

chatper11/src/main/java/CustomDataFrame.java:43

chatper11/src/main/java/RefiectDataFrme.java:28

chapter6/src/main/java/pair/PairRdd.java:32

chapter6/src/main/java/pair/JoinParirRDD.java:25

chapter2/src/main/java/spark/SparkApplication.java:37

(Integer value)

chapter10/src/main/java/dataset/DataSetApplication.java:37

chapter4/src/main/java/spark/Chapter4.java:32

(RddAvg v1, Integer v2)

chapter4/src/main/java/spark/RddAvg.java:27

chapter3/src/main/java/spark/LogError.java:22

chapter3/src/main/java/spark/LogError.java:40

chapter3/src/main/java/spark/LogError.java:56

Methodcomparator

src/main/java/spark/Lombda.java:20

(Integer o1, Integer o2)

chapter5/src/main/java/spark/SparkApplication.java:25

(String s1, String s2)

src/main/java/spark/Lombda.java:33

chapter8/src/main/java/AttackAccumulator.java:31

MethodcountWindow

(JavaDStream<String> javaDStream)

chapter19/src/main/java/CountByWindow.java:16

chapter8/src/main/java/AttackAccumulator.java:25

(JavaSparkContext sparkContext)

chapter7/src/main/java/SaprkFile.java:32

对日志进行转换操作和行动操作

chapter3/src/main/java/spark/LogError.java:19

(String[] args)

kafka-test/src/main/java/v1/KafkaConsumers.java:48

(String[] args)

kafka-test/src/main/java/v1/KafkaProducers.java:45

(String[] args)

chapter23/src/main/java/v1/SpamEmail.java:32

(String[] args)

chapter17/src/main/java/SparkStreamDemo.java:19

(String[] args)

chapter19/src/main/java/Join.java:15

(String[] args)

chapter19/src/main/java/ReduceByKeyAndWindow.java:20

(String[] args)

chapter19/src/main/java/StateLess.java:47

(String[] args)

chapter19/src/main/java/Window.java:17

广播变量测试 @param args

chapter8/src/main/java/BroadCastParam.java:25

(String[] args)

chapter8/src/main/java/TestMerge.java:17

(String[] args)

chapter8/src/main/java/Accumulator.java:26

(String[] args)

src/main/java/spark/Lombda.java:16

(String[] args)

src/main/java/spark/SparkApplication.java:10

(String[] args)

chatper11/src/main/java/CustomDataFrame.java:23

(String[] args)

chatper11/src/main/java/RefiectDataFrme.java:20

(String[] args)

chatper11/src/main/java/datasource/DataSources.java:22

(String[] args)

chatper11/src/main/java/datasource/Test.java:17

(String[] args)

chapter13/src/main/java/LoadJdbc.java:17

(String[] args)

chapter2/src/main/java/spark/SparkApplication.java:32

(String[] args)

chapter9/src/main/java/SparkSqlApplication.java:18

(String[] args)

chapter10/src/main/java/global.java:15

(String[] args)

chapter10/src/main/java/dataset/DataSetApplication.java:22

(String[] args)

chapter21/src/main/java/v1/KafkaStreaming.java:59

(String[] args)

chapter4/src/main/java/spark/Application.java:17

(AccumulatorV2<String, String> accumulatorV2)

chapter8/src/main/java/AttackAccumulator.java:49

MethodmergeEmptyLine

(String key, String value, String delimit)

chapter8/src/main/java/AttackAccumulator.java:61

(JavaSparkContext sparkContext)

chapter4/src/main/java/spark/Chapter4.java:58

chapter8/src/main/java/AttackAccumulator.java:37

(JavaSparkContext sparkContext)

chapter7/src/main/java/SequenceFile.java:19

(JavaSparkContext sparkContext)

chapter5/src/main/java/spark/SparkApplication.java:20

(JavaSparkContext sparkContext)

chapter6/src/main/java/pair/PairRdd.java:27

(JavaSparkContext sparkContext)

chapter6/src/main/java/pair/JoinParirRDD.java:20

(JavaSparkContext sparkContext)

chapter6/src/main/java/pair/PairRdd.java:75