HBase - это база данных Hadoop (столбчатая). Используйте его, когда вам нужен случайный доступ для чтения / записи в реальном времени к вашим большим данным. Целью этого проекта является размещение очень больших таблиц - миллиарды строк X миллионы столбцов - на кластерах обычного оборудования.
1 ответ

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

Я пытаюсь создать RDD на основе данных из HBase Таблица: val targetRDD = sparkContext.newAPIHadoopRDD(hBaseConfig, classOf[TableInputFormat], classOf[ImmutableBytesWritable], classOf[Result]) .map { case (key, row) => parse(key, row) } parse вызы…
29 окт '16 в 19:36
1 ответ

Настройка Java-приложения для работы с HBase (Hue-Cloudera)

Кто-нибудь может дать какой-нибудь совет о том, как мне следует настроить мой Java-приложение для работы с HBase? К сожалению, этот фундаментальный шаг для настройки java-приложения для связи с HBase был опущен в курсе PluralSight "Начало работы с H…
10 авг '17 в 16:05
0 ответов

Hdfs загрузить Hbase Utility

Я попробовал следующую команду, чтобы загрузить данные из hdfs в таблицу hbase. Задание загружает данные в таблицу hbase, но не в соответствующие столбцы (то есть значение col1 загружается в col2, значение col2 загружается в col5 и т. Д.). Может ли …
22 янв '18 в 16:50
0 ответов

Хранение XML в виде плоского файла в HBASE

Я новичок в HBase и хочу знать, как это можно сделать. У меня есть следующий XML-файл: <?xml version="1.0" encoding="UTF-8" standalone="yes"?> <interestRateCurve> <effectiveasof>2016-04-27</effectiveasof> <currency>JPY&…
16 май '16 в 21:42
1 ответ

Пакетная операция HBase для checkAndMutate

Я пытаюсь объединить несколько операций checkAndMutate в один пакет, но похоже, что он не поддерживается клиентом HBase. На Apache Jira я нашел этот тикет: поддержка пакетной версии checkAndPut() и checkAndDelete() Билет находится в открытом состоян…
10 июл '15 в 22:40
1 ответ

Hbase import ^A (CTRL A) файл с разделителями, используя importTsv

У меня есть простой текстовый файл, строки разделены символом "\n", а столбцы разделены символом "^A", который является непечатаемым символом. Мне нужно загрузить этот файл в HBase, и я наткнулся на инструмент importtsv, который, кажется, может дела…
12 июн '14 в 16:11
1 ответ

HBase-Мастер Сервис

Я не могу запустить службу HBase-Master, когда работает служба zookeeper. Итак, когда я получаю оболочку HBase и выполняю команду, я получаю эту ошибку: ERROR [Main] client.HConnectionManager$HConnection /hbase is not in ZooKeeper. It should have be…
07 апр '14 в 14:16
1 ответ

Titan Warn: запрос требует итерации по всем вершинам [(name <> null)]

Я использовал ниже код mgmt = g.getManagementSystem() PropertyKey name = mgmt.makePropertyKey("name").dataType(String.class).make(); mgmt.buildIndex("name",Vertex.class).addKey(name).unique().buildCompositeIndex(); при получении данных из графика я …
21 апр '16 в 15:16
1 ответ

Как добавить данные в openTSDB через Java с помощью tCollector

Моя цель - вставить данные в TSDB напрямую через код Java, для чего я попытался создать исполняемый файл jar, который печатал данные в STDOUT. Затем я написал сборщик, чтобы запустить эту банку и положить его внутрь tcollector/collectors/0, Наконец,…
28 авг '13 в 10:02
0 ответов

Как передать переменную pig в качестве параметра в операторе LOAD?

Я пытаюсь загрузить данные из Phoenix в сценарий свиньи для обработки У меня есть сценарий свиньи, как так - grain1 = LOAD 'cache' USING USING PigStorage(',') AS (partitionNumber: chararray, Id: chararray); DUMP grain1;// grain 1 dumps Id's correctl…
14 июн '18 в 17:42
1 ответ

Заказ по запросу не работает для больших записей для Pheniox

Версия феникса:-4.4я выполняю запрос феникса с помощью кода Java, в котором я использовал порядок, когда я запускаю этот запрос, но после каждых 2 и 3 успешных выполнений он показывает следующую ошибку: - java.lang.RuntimeException: `enter code here…
23 июн '16 в 09:49
0 ответов

Быстрое чтение из HBase: пользовательский объект содержит несериализуемое поле

Я пытаюсь прочитать данные из таблицы HBase в среду выполнения Flink. Ниже приведен пример: https://github.com/apache/flink/blob/master/flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseReadExample.java Я попыталс…
03 июл '18 в 15:08
2 ответа

Java-клиент HBase - неизвестный хост: localhost.localdomain

Версии: Hadoop: 2.0.0-cdh4.3.1 HBase: 0.94.6-cdh4.3.1 Я использую Cloudera Quick Start VM (все работает на 172.16.144.150), вот мой маленький клиент HBase Java (HbaseClient.java), клиент HBase работает на удаленной машине, все, что он делает: public…
25 авг '13 в 11:57
1 ответ

Сбой HBaseTestingUtility в Windows 10 с UnsatisfiedLinkError

Я пытаюсь получить HBaseTestingUtility работает на Windows 10. я использую hbase-client а также hbase-testing-util с версией 1.4.2, Когда работает: HBaseTestingUtility hbaseUtility = new HBaseTestingUtility(); hbaseUtility.startMiniCluster(); //&lt;…
08 мар '18 в 11:10
1 ответ

Что находится в записи индекса блока HBase?

Что находится в записи индекса блока HBase? Я думаю, что это один из них: все ключевые компоненты: ключ строки + семейство столбцов + квалификатор столбца + метка времени все ключевые компоненты, кроме семейства столбцов (поскольку индекс находится …
05 авг '14 в 02:09
2 ответа

Использование ElasticSearch в качестве постоянного хранилища

В последнее время я работаю над проектом, который ежедневно генерирует огромное количество данных. В этом проекте есть две функциональные возможности: одна хранит данные в Hbase для будущего анализа, а вторая отправляет данные в ElasticSearch для мо…
09 авг '18 в 05:24
1 ответ

HBase-indexer & Solr: НЕ найдены данные

В настоящее время я использую hbase-indexer для индексации hbase в solr. Когда я выполняю команду foolowing, чтобы проверить индексатор, hbase-indexer$ bin/hbase-indexer list-indexers --zookeeper 127.0.0.1:2181 В результате сказано, что: myindexer +…
24 янв '17 в 09:25
2 ответа

HBase Row Key Design

Я создал следующую схему в Hbase, create 'test','lg' put 'test','row1','lg:htype','get' put 'test','row1','lg:ip','192.168.12.123' put 'test','row1','lg:stat','success' Для этой схемы я хочу создать ключ строки. Мой вопрос заключается в том, как соз…
23 апр '13 в 20:33
1 ответ

Перенос снимка с hbase с 0,94 до 0,98

Я пытаюсь перенести снимок hbase из hbase версии 0.94 в 0.98. шаги: Создать снимок на старой базе hbase 0.94 снимок "test_event_raw_data", "test_event_raw_data" экспорт в базу 0,98 hbase org.apache.hadoop.hbase.snapshot.ExportSnapshot -snapshot test…
12 июн '14 в 15:44
1 ответ

Класс не найден в Cloud Bigtable SDK

Я установил Google Cloud Bigtable Java SDK, и он не может найти следующий класс: TableName is not a member of package org.apache.hadoop.hbase, Я использовал ссылку на версию, как описано на GitHub: &lt;dependency&gt; &lt;groupId&gt;com.google.cloud.…
16 фев '16 в 16:00