hbase

0열

1답변

우리는 MySQL에서 수집 한 카프카 데이터를 스트리밍하고 있습니다. 이제 모든 분석이 완료되면 데이터를 Hbase에 직접 저장하려고합니다. 나는 스파크 구조 스트리밍 문서를 통해 가지고 있지만 Hbase와 싱크를 찾을 수 없습니다. 카프카에서 데이터를 읽는 데 사용한 코드는 다음과 같습니다. val records = spark.readStream.form

0열

1답변

다시 시작한 후 Hbase 데이터가 삭제되었습니다.

방금 hbase로 시작했습니다. 따라서 테이블을 만들고이 데이터를 테이블에 채웠습니다. 하지만 내 컴퓨터를 다시 시작한 후 모든 데이터 가 사라졌습니다. 이것은 심지어 hbase stop-hbase.sh로 중지 할 때 발생합니다. HBase를 설치 : 의사 분산 HBase를-site.xml 파일 : hbase.rootdir HDFS : // localh

0열

1답변

hbase에서 셀 병합을 수행 할 수 있습니까?

비트 올림 된 정수 플래그 또는 합계 열과 같이 덮어 쓰지 않고 점진적으로 업데이트되는 열이 있다고 가정합니다. 기존 셀 : [키 'K1', F1 : 합계 : 100] Upcomming 새로운 셀 : [키 'K1', F1 : 합계 : 200 (예를 들어, 단지 1 개의 버전을 가정) 합계 = 100 + 200 = 300 최종 기록 항복 : [키 'K1',

0열

1답변

Hadoop HBASE가있는 스프링 부트 REST

간단한 RESTFull API을 작성하여 HBase에 액세스 할 계획입니다. 내가 보았습니다 파이썬 해피베이스,하지만 내 클러스터 kerberised입니다. 이제 나는 봄입니다. 간단한 API REST를 사용하여 Solr Cloud 및 스프링 부트. Hbase에서도 동일한 작업을 수행 할 수 있습니까? 내가 봄 부팅 '원사 앱' =>https://sprin

0열

1답변

모든 데이터를 새로운 phoenix 클러스터로 전송

모든 apache phoenix 데이터를 새로운 클러스터로 이동하는 표준 방법이 있습니까? 2 테라 바이트의 피닉스 행을 이동하는 데 얼마나 걸릴까요? senario : 나는 가상 서버를 사용하여 내 플랫폼 출시 (로 그것의 싼)하지만 지금은 전용 서버로 이동할 준비가하지만 난 그렇게 새 클러스터로 데이터를 이동할 수있는 올바른 방법을 알고 싶어 내 사용자

1열

1답변

HDFS 손상 파일을 삭제할 수 없습니다.

HDFS에 손상된 파일을 삭제할 수 없습니다. 네임 노드가 안전 모드로 실행되었습니다. 총 블록 수는 980 개이며이 중 978 개가보고되었습니다. 나는 다음과 같은 명령을 실행하면 sudo -u hdfs hdfs dfsadmin -report 보고서는 IS 생성 Safe mode is ON Configured Capacity: 58531520512

1열

1답변

hbase 1.2.6에서 org.apache.hadoop.hbase.mapreduce 및 mapred 패키지를 찾을 수 없습니다.

기존 프로젝트의 hbase 버전을 이전 0.94.1로 업그레이드하려고하는데, 이제는 1.2.6으로 업그레이드 할 예정입니다. official website에서는 mapreduce 및 mapred와 같은 패키지 및 클래스를 볼 수 있지만 찾은 항아리에서는 사용할 수 없습니다. hbase-common hbase-annotations 및 hbase-client

0열

1답변

GeoMesa on HBase 빠른 가져 오기

HBase v1.2.6에서 GeoMesa v1.4.0을 사용하고 있습니다. 현재 HBaseQuickStart 클래스의 도움으로 데이터를 가져오고 색인을 생성하고 있습니다. 불행하게도 대용량 파일의 런타임은 매우 길다. 누군가 내 프로세스 속도를 높이기 위해 GeoMesa가있는 bulkLoad를 알고 있습니까? 미리 감사드립니다.

0열

1답변

rabbitmq에서 내부적으로 메시지를 저장하는 방법과 원래 형식으로 다시 검색하는 방법은 무엇입니까? 내가 파이썬을 다음과 같이 rabbitmq 메시지를 게시하려고

다음 import findspark findspark.init("/home/spark/spark-2.2.0") from pyspark.sql import SparkSession import pika connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel

0열

1답변

Hbase에있는 동일한 패밀리의 여러 열에 값을 입력하십시오.

Hbase 테이블의 동일한 행 키에 대해 동일한 열 패밀리의 여러 열에 값을 삽입 할 수있는 Hbase put 명령을 찾고 있습니다. 'hier'테이블에 'employee'라는 열 패밀리 'data'가 있습니다. 아래 명령을 적용하고 있지만 오류가 발생합니다. PUT 'employee' 'data:column1', 'column1_val', 'data:co