Functions — github.com/databricks/learning-spark

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

Functions188 in github.com/databricks/learning-spark

⨍ Functions 188◇ Types & classes 69

Methodcall

(Iterator<String> lines)

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

Methodcall

(Person person)

src/main/java/com/oreilly/learningsparkexamples/java/BasicLoadJson.java:47

Methodcall

(Iterator<Person> people)

src/main/java/com/oreilly/learningsparkexamples/java/BasicLoadJson.java:54

Methodcall

(Row row)

src/main/java/com/oreilly/learningsparkexamples/java/SparkSQLTwitter.java:40

Methodcall

(Iterator<String> input)

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

Methodcall

(Tuple2<String, Integer> record)

src/main/java/com/oreilly/learningsparkexamples/java/BasicSaveSequenceFile.java:20

Methodcall

(String x)

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

Methodcall

(Tuple2<Iterable<V>, Iterable<V>> input)

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

Methodcall

(Iterator<Integer> input)

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

Methodcall

(Tuple2<LongWritable, Text> input)

src/main/java/com/oreilly/learningsparkexamples/java/logs/ReadTransferStats.java:31

Methodcall

(JavaRDD<ApacheAccessLog> accessLogs)

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

Methodcall

(JavaRDD<ApacheAccessLog> rdd)

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

Methodcall

(ApacheAccessLog entry)

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

Methodcall

(Long a, Long b)

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

Methodcall

(Double a, Double b)

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

Methodcall

(List<Long> nums, Optional<Long> current)

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

Methodcall

(ApacheAccessLog log)

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

Methodcall

(ApacheAccessLog log)

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

Methodcall

(ApacheAccessLog log)

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

Methodcall

(ApacheAccessLog log)

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

Methodcall

(ApacheAccessLog log)

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

Methodcall

(Tuple2<String, Long> e)

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

Methodcall

(String line)

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

Methodcall

(Integer x)

mini-complete-example/src/main/java/com/oreilly/learningsparkexamples/mini/java/BasicMap.java:27

Methodcall

(String x)

mini-complete-example/src/main/java/com/oreilly/learningsparkexamples/mini/java/WordCount.java:35

FunctioncombineCtrs

(c1, c2)

src/python/AvgMapPartitions.py:23

FunctioncombineIfBothPresent

Return an iterable of the elements from both itr1 and itr2 if there are elements in both itr1 and itr2 otherwise return an empty itrable

src/python/IntersectByKey.py:17

Methodcompare

(Tuple2<K, V> o1, Tuple2<K, V> o2)

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

FunctionextractCallSigns

(line)

src/python/ChapterSixExample.py:39

FunctionformatCall

Format a call so that it can be parsed by our R program

src/python/ChapterSixExample.py:138

MethodgetClientIdentd

()

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

MethodgetDateTimeString

()

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

MethodgetFavouriteBeverage

()

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

MethodgetLogStatistics

()

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

MethodgetMethod

()

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

MethodgetProtocol

()

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

MethodgetUserID

()

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

FunctionhasDistInfo

Verify that a call has the fields required to compute the distance

src/python/ChapterSixExample.py:132

FunctionincrementCounter

(line)

src/python/ChapterSixExample.py:25

FunctionloadRecord

Parse a CSV line

src/python/LoadCsv.py:7

FunctionloadRecords

Load all the records in a given file

src/python/LoadCsv.py:14

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

src/main/java/com/oreilly/learningsparkexamples/java/BasicLoadJson.java:65

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

src/main/java/com/oreilly/learningsparkexamples/java/BasicSaveSequenceFile.java:25

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

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

Methodmain

(String[] args)

mini-complete-example/src/main/java/com/oreilly/learningsparkexamples/mini/java/BasicMap.java:16

Methodmain

(String[] args)

mini-complete-example/src/main/java/com/oreilly/learningsparkexamples/mini/java/WordCount.java:24

Methodmerge

(Iterable<Integer> input)

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

FunctionpartitionCtr

Compute sumCounter for partition

src/python/AvgMapPartitions.py:14

MethodreadStats

(JavaStreamingContext jssc, String inputDirectory)

src/main/java/com/oreilly/learningsparkexamples/java/logs/ReadTransferStats.java:24

MethodregisterClasses

(Kryo kryo)

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

MethodsetClientIdentd

(String clientIdentd)

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

MethodsetContentSize

(long contentSize)

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

MethodsetDateTimeString

(String dateTimeString)

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

MethodsetEndpoint

(String endpoint)

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

MethodsetFavouriteBeverage

(String b)

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

MethodsetIpAddress

(String ipAddress)

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

MethodsetMethod

(String method)

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

MethodsetName

(String n)

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

MethodsetProtocol

(String protocol)

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

MethodsetResponseCode

(int responseCode)

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

MethodsetUserID

(String userID)

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

FunctionvalidateSign

(sign)

src/python/ChapterSixExample.py:54

FunctionwriteRecords

Write out CSV lines

src/python/LoadCsv.py:21

← previous101–188 of 188, ranked by callers