Functions — github.com/databricks/learning-spark

CodeHub MCPcopy Create free account

hub / github.com/databricks/learning-spark / functions

Functions188 in github.com/databricks/learning-spark

⨍ Functions 188◇ Types & classes 69

↓ 17 callersMethodgetInstance

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:49

↓ 6 callersMethodgetSlideInterval

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:25

↓ 5 callersMethodgetKey

src/main/java/com/oreilly/learningsparkexamples/java/BasicQueryCassandra.java:63

↓ 5 callersMethodgetWindowLength

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:21

↓ 4 callersMethodgetContentSizeStats

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogStatistics.java:32

↓ 4 callersMethodgetIpAddress

src/main/java/com/oreilly/learningsparkexamples/java/logs/ApacheAccessLog.java:41

↓ 4 callersMethodgetValue

src/main/java/com/oreilly/learningsparkexamples/java/BasicQueryCassandra.java:66

↓ 3 callersMethodresponseCodeCount

( JavaRDD<ApacheAccessLog> accessLogRDD)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Functions.java:92

↓ 2 callersMethodcontentSizeStats

( JavaRDD<ApacheAccessLog> accessLogRDD)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Functions.java:68

↓ 2 callersMethodendpointCount

( JavaRDD<ApacheAccessLog> accessLogRDD)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Functions.java:149

↓ 2 callersMethodfilterIPAddress

( JavaPairRDD<String, Long> ipAddressCount)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Functions.java:142

↓ 2 callersMethodgetContentSize

src/main/java/com/oreilly/learningsparkexamples/java/logs/ApacheAccessLog.java:73

↓ 2 callersMethodgetIpAddresses

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogStatistics.java:44

↓ 2 callersMethodgetLogStatistics

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogAnalyzerTotal.java:130

↓ 2 callersMethodgetOutputDirectory

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:41

↓ 2 callersMethodgetResponseCodeToCount

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogStatistics.java:36

↓ 2 callersMethodgetTopEndpoints

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogStatistics.java:48

↓ 2 callersMethodipAddressCount

( JavaRDD<ApacheAccessLog> accessLogRDD)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Functions.java:135

↓ 2 callersMethodrun

(String master, String csv1, String csv2)

src/main/java/com/oreilly/learningsparkexamples/java/BasicJoinCsv.java:41

↓ 1 callersMethodavg

src/main/java/com/oreilly/learningsparkexamples/java/PerKeyAvg.java:30

↓ 1 callersMethodavg

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvg.java:24

↓ 1 callersMethodavg

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvgWithKryo.java:31

↓ 1 callersMethodavg

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvgMapPartitions.java:41

↓ 1 callersFunctionbasicAvg

Compute the avg

src/python/BasicAvg.py:14

↓ 1 callersFunctionbasicAvg

Compute the avg

src/python/AvgMapPartitions.py:27

↓ 1 callersFunctionbasicKeyValueMapFilter

Construct a key/value RDD and then filter on the value

src/python/BasicKeyValueMapFilter.py:15

↓ 1 callersFunctionbasicSquare

Square the numbers

src/python/BasicMap.py:14

↓ 1 callersFunctionbasicSquareNoOnes

Square the numbers

src/python/BasicFilterMap.py:14

↓ 1 callersFunctionbasicSum

Sum the numbers

src/python/BasicSum.py:14

↓ 1 callersMethodcontentSizesTable

(LogStatistics allOfTime, LogStatistics lastWindow)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Renderer.java:46

↓ 1 callersMethodcreateMapper

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:224

↓ 1 callersMethodcreateOptions

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogAnalyzerAppMain.java:51

↓ 1 callersMethodcreateRequestForSign

(String sign, HttpClient client)

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:218

↓ 1 callersFunctionfetchCallSigns

Fetch call signs

src/python/ChapterSixExample.py:120

↓ 1 callersFunctionfetchCallSigns

Fetch call signs

src/python/BasicMapPartitions.py:23

↓ 1 callersMethodfetchResultFromRequest

(ObjectMapper mapper, Tuple2<String, ContentEx

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:212

↓ 1 callersMethodfrequentIpAddressTable

( LogStatistics allOfTime, LogStatistics lastWindow)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Renderer.java:79

↓ 1 callersMethodgetCheckpointDirectory

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:37

↓ 1 callersMethodgetEndpoint

src/main/java/com/oreilly/learningsparkexamples/java/logs/ApacheAccessLog.java:61

↓ 1 callersMethodgetIndexHtmlTemplate

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:45

↓ 1 callersMethodgetLogsDirectory

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:29

↓ 1 callersMethodgetName

src/main/java/com/oreilly/learningsparkexamples/java/HappyPerson.java:12

↓ 1 callersMethodgetOutputHtmlFile

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:33

↓ 1 callersMethodgetResponseCode

src/main/java/com/oreilly/learningsparkexamples/java/logs/ApacheAccessLog.java:69

↓ 1 callersFunctionintersectByKey

Intersect two RDDs by key

src/python/IntersectByKey.py:31

↓ 1 callersMethodintersectByKey

(JavaPairRDD<K, V> rdd1, JavaPairRDD<K, V> rdd2)

src/main/java/com/oreilly/learningsparkexamples/java/IntersectByKey.java:26

↓ 1 callersFunctionloadCallSignTable

src/python/ChapterSixExample.py:82

↓ 1 callersMethodloadCallSignTable

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:230

↓ 1 callersMethodlogLinesTable

(LogStatistics allOfTime, LogStatistics lastWindow)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Renderer.java:37

↓ 1 callersFunctionlookupCountry

(sign, prefixes)

src/python/ChapterSixExample.py:77

↓ 1 callersMethodlookupCountry

(String callSign, String[] table)

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:239

↓ 1 callersMethodnewInstance

(String k, Integer v)

src/main/java/com/oreilly/learningsparkexamples/java/BasicQueryCassandra.java:57

↓ 1 callersMethodparseFromLogLine

(String logline)

src/main/java/com/oreilly/learningsparkexamples/java/logs/ApacheAccessLog.java:120

↓ 1 callersFunctionperKeyAvg

Compute the avg

src/python/PerKeyAvg.py:15

↓ 1 callersMethodprocessAccessLogs

(String outDir, JavaDStream<ApacheAccessLog> accessLogsDStream)

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogAnalyzerTotal.java:35

↓ 1 callersMethodprocessAccessLogs

(String outDir, JavaDStream<ApacheAccessLog> accessLogsDStream)

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogAnalyzerWindowed.java:21

↓ 1 callersFunctionprocessCallSigns

Lookup call signs using a connection pool

src/python/ChapterSixExample.py:106

↓ 1 callersFunctionprocessCallSigns

Process call signs

src/python/BasicMapPartitions.py:15

↓ 1 callersFunctionprocessSignCount

(sign_count, signPrefixes)

src/python/ChapterSixExample.py:92

↓ 1 callersMethodreadExchangeCallLog

(ObjectMapper mapper, ContentExchange exchange)

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:202

↓ 1 callersFunctionremoveOutliers

Remove the outliers

src/python/RemoveOutliers.py:15

↓ 1 callersMethodremoveOutliers

(JavaDoubleRDD rdd)

src/main/java/com/oreilly/learningsparkexamples/java/RemoveOutliers.java:31

↓ 1 callersMethodrender

(LogStatistics allOfTime, LogStatistics lastWindow)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Renderer.java:15

↓ 1 callersMethodresponseCodeTable

( LogStatistics allOfTime, LogStatistics lastWindow)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Renderer.java:65

↓ 1 callersMethodrun

(String master)

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvgMapPartitions.java:57

↓ 1 callersMethodsetFromCommandLineArgs

(Options options, String[] args)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:56

↓ 1 callersMethodsetKey

src/main/java/com/oreilly/learningsparkexamples/java/BasicQueryCassandra.java:69

↓ 1 callersMethodsetValue

src/main/java/com/oreilly/learningsparkexamples/java/BasicQueryCassandra.java:72

↓ 1 callersMethodtopEndpointsTable

( LogStatistics allOfTime, LogStatistics lastWindow)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Renderer.java:95

MethodApacheAccessLog

(String ipAddress, String clientIdentd, String userID, String dateTime, String metho

src/main/java/com/oreilly/learningsparkexamples/java/logs/ApacheAccessLog.java:26

(int total, int num)

src/main/java/com/oreilly/learningsparkexamples/java/PerKeyAvg.java:24

(int total, int num)

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvg.java:18

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvgWithKryo.java:23

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvgMapPartitions.java:24

src/main/java/com/oreilly/learningsparkexamples/java/logs/Flags.java:19

MethodHappyPerson

src/main/java/com/oreilly/learningsparkexamples/java/HappyPerson.java:8

src/main/java/com/oreilly/learningsparkexamples/java/BasicQueryCassandra.java:55

MethodLogStatistics

(Tuple4<Long, Long, Long, Long> contentSizeStats, List<Tuple2<Integer, Long>> responseC

src/main/java/com/oreilly/learningsparkexamples/java/logs/LogStatistics.java:22

MethodValueComparator

(Comparator<V> comparator)

src/main/java/com/oreilly/learningsparkexamples/java/logs/Functions.java:40

(Tuple2<String, String> file)

src/main/java/com/oreilly/learningsparkexamples/java/BasicLoadWholeCsv.java:24

(String[] input)

src/main/java/com/oreilly/learningsparkexamples/java/BasicLoadWholeCsv.java:45

src/main/java/com/oreilly/learningsparkexamples/java/BasicFlatMap.java:30

(Integer x, Integer y)

src/main/java/com/oreilly/learningsparkexamples/java/BasicSum.java:27

(Integer x, Integer y)

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:46

(CallLog[] input)

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:52

src/main/java/com/oreilly/learningsparkexamples/java/ChapterSixExample.java:81

src/main/java/com/oreilly/learningsparkexamples/java/BasicMapToDouble.java:29

src/main/java/com/oreilly/learningsparkexamples/java/BasicJoinCsv.java:22

src/main/java/com/oreilly/learningsparkexamples/java/BasicMap.java:27

(CassandraRow row)

src/main/java/com/oreilly/learningsparkexamples/java/BasicQueryCassandra.java:43

src/main/java/com/oreilly/learningsparkexamples/java/LoadHive.java:27

src/main/java/com/oreilly/learningsparkexamples/java/PerKeyAvg.java:50

src/main/java/com/oreilly/learningsparkexamples/java/RemoveOutliers.java:34

src/main/java/com/oreilly/learningsparkexamples/java/MLlib.java:50

(AvgCount a, Integer x)

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvg.java:41

src/main/java/com/oreilly/learningsparkexamples/java/StreamingLogInput.java:28

(Tuple2<Text, IntWritable> record)

src/main/java/com/oreilly/learningsparkexamples/java/BasicLoadSequenceFile.java:18

src/main/java/com/oreilly/learningsparkexamples/java/KeyValueMapFilter.java:35

src/main/java/com/oreilly/learningsparkexamples/java/BasicMapThenFilter.java:27

(AvgCount a, Integer x)

src/main/java/com/oreilly/learningsparkexamples/java/BasicAvgWithKryo.java:58

next →1–100 of 188, ranked by callers