public CassandraJavaPairRDD joinWithCassandraTable()

in connector/src/main/java/com/datastax/spark/connector/japi/RDDJavaFunctions.java [120:156]

• 34 lines of code
• 1 McCabe index (conditional complexity)

    public <R> CassandraJavaPairRDD<T, R> joinWithCassandraTable(
            String keyspaceName,
            String tableName,
            ColumnSelector selectedColumns,
            ColumnSelector joinColumns,
            RowReaderFactory<R> rowReaderFactory,
            RowWriterFactory<T> rowWriterFactory
    ) {
        ClassTag<T> classTagT = rdd.toJavaRDD().classTag();
        ClassTag<R> classTagR = JavaApiHelper.getClassTag(rowReaderFactory.targetClass());

        CassandraConnector connector = defaultConnector();
        Option<ClusteringOrder> clusteringOrder = Option.empty();
        Option<CassandraLimit> limit = Option.empty();
        CqlWhereClause whereClause = CqlWhereClause.empty();
        ReadConf readConf = ReadConf.fromSparkConf(rdd.conf());

        CassandraJoinRDD<T, R> joinRDD = new CassandraJoinRDD<>(
                rdd,
                keyspaceName,
                tableName,
                connector,
                selectedColumns,
                joinColumns,
                whereClause,
                limit,
                clusteringOrder,
                readConf,
                Option.<RowReader<R>>empty(),
                Option.<RowWriter<T>>empty(),
                classTagT,
                classTagR,
                rowWriterFactory,
                rowReaderFactory);

        return new CassandraJavaPairRDD<>(joinRDD, classTagT, classTagR);
    }