I hereby claim:
- I am heinrichreimer on github.
- I am heinrichreimer (https://keybase.io/heinrichreimer) on keybase.
- I have a public key ASBY23krwrFBLQ-MswPfhYQ1Gv8KMy9-fNP0dzT4wuj1cgo
To claim this, I am signing this object:
Jan Heinrich Reimer heinrichreimer
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package de.webis.webisstud.thesis.reimer | |
| /** | |
| * A generic collection of elements that supports adding elements. | |
| * | |
| * @param E the type of elements contained in the collection. | |
| * The mutable collection is invariant on its element type. | |
| */ | |
| interface AddOnlyCollection<E> : Collection<E> { |
heinrichreimer
/ EsSparkExtensions.kt
Created
April 1, 2020 22:37
Elasticsearch Spark extension functions for Kotlin.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package de.webis.webisstud.thesis.reimer.clueweb.graph | |
| import org.apache.spark.SparkConf | |
| import org.apache.spark.api.java.JavaPairRDD | |
| import org.apache.spark.api.java.JavaRDD | |
| import org.apache.spark.api.java.JavaSparkContext | |
| import org.elasticsearch.hadoop.cfg.ConfigurationOptions.* | |
| import org.elasticsearch.spark.rdd.api.java.JavaEsSpark | |
| fun JavaSparkContext.esRDD(): JavaPairRDD<String, Map<String, Any>> = |
OlderNewer