public final class SparkMongos extends Object
Modifier and Type | Method and Description |
---|---|
static org.apache.spark.api.java.JavaPairRDD<Object,org.bson.BSONObject> |
mongoRdd(org.apache.spark.api.java.JavaSparkContext sparkContext,
String mongoHost,
long mongoPort,
String db,
String collection) |
Apache Camel