hbase

0зной

1ответ

Hbase использовать целое число как ключ строки и лексикографический порядок

Я разрабатываю схему Hbase, где ключ строки должен быть целым числом. Я намерен использовать API сканирования из java с помощью startrow и endrow с целыми значениями. Я думаю, я могу преобразовать сво

0зной

1ответ

HBase, кажется, пишет в один узел в кластере

У меня есть небольшой кластер из 3 узлов, с Hbase, развернутым на всех 3 узлах. Похоже, что при записи данных в кластер Hbase все изначально похоже на тот же узел. Следующий мой отношение HBase-site.x

2зной

1ответ

Создание RDD на основе части строк Hbase

Я пытаюсь создать RDD на основе данных из таблицы HBase: val targetRDD = sparkContext.newAPIHadoopRDD(hBaseConfig, classOf[TableInputFormat], classOf[ImmutableBytesWritable], classOf[Re

0зной

1ответ

SparkSQL: Я прав?

Вот как я использую Spark-SQL в небольшом приложении, с которым я работаю. У меня две таблицы Hbase говорят t1, t2. Мой ввод - это файл csv, я анализирую каждую строку и запрос (SparkSQL) таблицу t1.

0зной

1ответ

ошибка Google Cloud Bigtable StatusRuntimeException при сканировании всех строк таблицы

Я пытаюсь сканировать все строки (~ 1.3M строк) из таблицы Google BigTable, используя API Java, однако я получаю следующее сообщение об ошибке: Error while reading table 'projects/firm-link-147413/ins

0зной

1ответ

Как реализовать многоуровневое хранение в HBase?

Я пытаюсь получить информацию о реализации многоуровневого хранилища на HBase, который работает по HDFS. Я прочитал о многоуровневом хранилище на HDFS с этого link. Я также прошел через это link, но у

1зной

1ответ

Зависимости HBase от SBT в Scala

Я новичок в Scala, SBT и Intellij. Используя следующий SBT файл: name := "mycompany" version := "0.0.1-SNAPSHOT" scalaVersion := "2.11.8" libraryDependencies ++= Seq( "org.apache.spark" %% "

0зной

2ответ

Как сделать частичное сканирование HBase?

У меня есть таблица HBase, содержащая около 10 миллионов записей. У меня есть три вопроса относительно HBase Сколько времени сканирует 10 миллионов записей? Должен ли я пойти на интеграцию с HBase для

0зной

1ответ

Ошибка сериализации Flink thowing при чтении из hbase

Когда я прочитал из hbase, используя richfatMapFunction внутри карты, я получаю ошибку сериализации. То, что я пытаюсь сделать, - это если поток данных равен определенной строке, прочитанной из hbase