Skip to content

Instantly share code, notes, and snippets.

View adrianva's full-sized avatar

Adrián Vázquez adrianva

View GitHub Profile
@adrianva
adrianva / pyspark_to_elasticsearch.py
Created March 19, 2017 00:04
Save RDD and/or DataFrame from Spark to Elasticsearch
# Elastic configs
es_read_conf = {
"es.nodes" : "localhost",
"es.port" : "9200",
"es.resource" : "twitter/tweet"
}
es_write_conf = {
"es.nodes" : "localhost",
"es.port" : "9200",
@adrianva
adrianva / flink_batch.scala
Last active April 1, 2017 08:03
Simple script showing some operations with Apache Flink and Scala.