spark-cassandra-connector

1зной

1ответ

проблема с искровым коннектором cassandra в java

Я пытаюсь запросить cassandra из искры в java. Ниже приведен код для извлечения данных, но метод mapToRow принимает два параметра. сначала класс, а второй - ColumnMapper. Как получить экземпляр класса

0зной

1ответ

Метод обтекания Scala параметризованного класса (spark-cassandra-connector)

Я пишу набор методов, расширяющих API Spark RDD. Я должен реализовать общий метод для хранения RDD, и для начала я попытался обернуть коннектор искры-кассандра saveAsCassandraTable без успеха. Вот "ра

1зной

3ответ

нужна помощь в присоединении к искровым РДД-й в Java

нужно выполнить следующие операции соединения в искре JavaPairRDD<String, Tuple2<Optional<MarkToMarketPNL>, Optional<MarkToMarketPNL>>> finalMTMPNLRDD = openMTMPNL.fullOuterJoin(closedMTMPNL); Для в

2зной

1ответ

Метод `saveAsTextFile`, который не работает в искровом автономном кластере

Я использую автономный искровой кластер из 3 узлов с 1 мастером и 2 рабочими вместе с кольцом из двух узлов cassandra, вот пример кода, который я пытаюсь сделать SparkConf conf = new SparkConf(true);

1зной

1ответ

Как обращаться с соединениями cassandra в искровой работе?

Я делаю стресс-тест на моем искрообразовании, в котором используется разъем искры cassandra, а также драйвер cassandra. В моем приложении я использую драйвер cassandra для выбора самого последнего зна

1зной

1ответ

разъем искровой Cassandra: выбрать список ключей

Cassandra 2.1, 1.1 Спарк, искровая Cassandra-разъем 1,1 У меня есть очень очень высокая колонна Семейство ключевых, пар значений. И у меня также есть RDD ключей, которые я хотел бы, чтобы выбрать из э