Technology•June 10, 2015
Zen and the Art of Spark Maintenance
sc.cassandraTable().filter(partitionkey in keys)
sc.cassandraTable().where(keys in veryLargeListOfKeys)
sc.parallelize(keys).joinWithCassandraTable()
JUMP TO SECTION
sc.cassandraTable().filter(partitionkey in keys)
sc.cassandraTable().where(keys in veryLargeListOfKeys)
sc.parallelize(keys).joinWithCassandraTable()