попробуй запихнуть опцию про крио в создание сессии - не думаю что его на лету можно менять

Если хадуп керберезированный, то надо смотреть на настройки провизии пользаков.

Может забирать с хоста, может работать через LDAP.
В первом случае может хост быть впилен в домен через SSSD -  вот в этом, а также в случае LDAP, пользак должен быть известен каталогу (и быть в KDC).

кто нибудь  объединял spark_cassandra_connector с scylla-driver?

не очень ясен вопрос, но что мешает просто кассанда корректорши пользоваться?

Привет, нубский вопрос по BigQuery. Есть таблица T с около 50 полями.

select * from T where a3 > timestamp_sub(current_timestamp(), INTERVAL 15 MINUTE). Кластеризация по полям a1, a2.

Почему он вычитал не FULL SCAN таблицу по прайсингу.
При этом в детализации запроса не все поля указаны в stage0 из таблицы.

Он типа пробежался фильтром по одной колонке и потом вывел строки по ID. От этого процессинг сильно меньше по цене?

Коллеги, как в Hive вывести значение запроса не в виде столбцов, а в виде строки? Подскажите, плиз

scylla-driver более оптимизирован для scylla

ну форкни проект заиспользуй сцилла драйвер
не уверен что это даст тебе преимуществ ведь сцилла драйвер это форк кассандра датастакс драйвера

а будет использоваться пересекающийся функционал который работать будет одинаково

наверное вся разница в разных конфиуграциях соединения и если тебе это важно оне вижу причин почему идея с форком не сработает

задам очередной глупый вопрос

есть какой-нить штатный способ залезть в даг окромя rdd.toDebugString()?

а то чего-то оч. хочется научиться расставлять по дагу rdd.persist() автоматически

вопрос каким макаром такой трюк проделать, чтобы не было мучительно больно

Лучше писать запросы так, чтобы персист не требовался)

Так как он чаще всего только замедляет чаще всего

не про spark sql речь

...а про выполнение кусков дага в цикле, например

> дага в цикле
Хм

или если мне надо сплитнуть рдд на кучку меньших по значениям в поле каком-нить