gasparms

{
	"namespace": "com.kdar",
	"name": "t_kdar_exchange_rate",
	"doc": "kdar",
	"type": "record",
	"fields":    [ {
				"name": "data_date",
				"type": "string",
				"default": ""
			}, {

gasparms

package com.sinfonier.drains;

import java.net.UnknownHostException;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;

gasparms

//Config tabla tweets
val config : IDeepJobConfig[Cells] = DeepJobConfigFactory.create().host("localhost").keyspace("twitter").table("tweets").initialize()

//RDD de la primera tabla
val rdd: CassandraRDD[Cells] = deepContext.cassandraGenericRDD(config)

//Config de la tabla tweetsTest
val config2 : IDeepJobConfig[Cells] = DeepJobConfigFactory.create().host("localhost").keyspace("twitter").table("tweetstest").initialize()

//RDD de la segunda tabla