hbase

0열

1답변

다음은 내가 작업하고있는 작은 응용 프로그램에서 Spark-SQL을 사용하는 방법입니다. 두 개의 Hbase 테이블에 t1, t2가 있습니다. 내 입력은 csv 파일이므로 각 줄마다 구문 분석하고 테이블 t1을 쿼리 (SparkSQL)합니다. 출력을 다른 파일에 씁니다. 이제 두 번째 파일을 구문 분석하고 두 번째 테이블을 쿼리하고 결과에 대해 특정 함수를

0열

1답변

일부 계산을 수행하기 위해 배열 목록에서 데이터 프레임 열 값을 수집하고 싶습니다. 가능합니까?

나는이를 통해 피닉스에서 데이터를 로딩하고 있습니다 : val tableDF = sqlContext.phoenixTableAsDataFrame("Hbtable", Array("ID", "distance"), conf = configuration) 및 열에서 다음과 같은 계산을 수행하려는 것은 distance 값 : val list=Array(10,20,

0열

1답변

Google 클라우드 Bigtable을 StatusRuntimeException 오류 테이블의 모든 행을 스캔 할 때

나는, 자바 API를 사용하여 구글 빅 테이블 테이블의 모든 행 (~ 1.3M 행)을 스캔하려고하지만 나는 다음과 같은 오류 얻을 : Error while reading table 'projects/firm-link-147413/instances/some-bigger-table/tables/media-location-demo' : Response was n

1열

1답변

스칼라에서 SBT와의 HBase 종속성

저는 Scala, SBT 및 Intellij에서 새로 왔습니다. 다음 SBT 파일 사용 : name := "mycompany" version := "0.0.1-SNAPSHOT" scalaVersion := "2.11.8" libraryDependencies ++= Seq( "org.apache.spark" %% "spark-core" %

0열

1답변

hbase에서 읽을 때 flink thowing 직렬화 오류가 발생했습니다.

지도에서 richfatMapFunction을 사용하여 hbase에서 읽을 때 직렬화 오류가 발생합니다. 내가 뭘 하려는지 datastream hbase else ignore에서 읽은 특정 문자열이 같으면입니다. 아래는 샘플 프로그램과 오류입니다. package com.abb.Flinktest import java.text.SimpleDateFormat

0열

2답변

자바 API를 통해 HBase를 연결할 수 있지만 자바 API를 사용하여 HBase와의 테이블을 만들려고하고

표 만들 수 없습니다, 나는 내가 할 수있는대로 내가 HBase를 연결할 수 있습니다 2016-11-06 15:18:36 INFO RecoverableZooKeeper:120 - Process identifier=hconnection-0x382db087 connecting to ZooKeeper ensemble=138.68.147.208:2181 2016

0열

1답변

방법 HBase를 중고품 hbase_thrift.ttypes.TIOError를 해결하려면 : TIOError (_message = "위치를 가져올 수 없습니다") 내가 파이썬 프로그램 Hbase1.1.2 및 thrift2를 사용

:이 기능을 실행 def scaner(self, numRows=2, columns=None, filterString=None): columns_list = self.create_columns(columns) scaner = TScan(columns=columns_list, filterString=filterString) scann

0열

1답변

pyspark에서 hbase로 연결하는 방법

푸른 하늘에 두 개의 클러스터가 있으며, 하나는 스파크 2.0에, 다른 하나는 hbase에 있습니다. 필자는 hbase를 완벽하게 채울 수 있습니다. 이제 hbase에 스파크를 연결하고 몇 가지 계산을 수행하려고합니다. 나는 scala를 모른다는 이유로 파이썬을 사용하고 싶다. 첫 번째 질문은 무엇입니까? 그것을 수행하는 가장 좋은 방법은 무엇입니까? 스파

0열

1답변

HBase HRegionServer를 시작할 수 없습니다.

hadoop 2.7.3 및 hbase 1.2.3이 있습니다. 공식 문서 다음에 의사 배포 모드에서 hbase를 실행하려고했습니다. 나는 단 하나의 기계를 가지고있다. HDFS가 잘 작동합니다. 그러나 문제는 start-hbase.sh, HRegionServer 시작시 자동으로 종료 될 때입니다. 나는 HMaster와 HQuorumPeer가 여전히 존재한다는

0열

1답변

피닉스 (Phoenix)를 통해 Hbase 테이블에 연결

Phoenix를 통해 (org.apache.hadoop.hbase.HBaseTestingUtility;)을 사용하여 만든 HBaseTestTable에 연결할 수 있는지 알고 싶었습니다. Hbase에 성공적으로 연결 한 다음 Test 테이블에 삽입하고 Test 테이블에서 데이터를 검색하려고합니다. HbaseTable을 만들 수있었습니다. 하지만 Phoenix