cloudera

0열

2답변

파이썬의 불꽃 튜플 사용 - 두 개의 RDD를 결합한 후 두 튜플을 병합하는 방법

저는 Spark Environment and Development에서 좀 새로운 것 같습니다. 나는 내가 목공을 통해 병합하는 두 RDDs을 가지고, 그 목공의 결과는 다음과 같은 : 당신은 내가 두 튜플과 키가 표시되는 경우 (u'10611', ((u'Laura', u'Mcgee'), (u'66821', u'COMPLETE'))) (u'4026', ((

0열

1답변

mysql의 테이블에있는 데이터를 cloudera에로드하는 방법 (가상 박스를 사용하여 실행)

사용자에게 현재 위치를 묻고 자신의 위도와 경도를 묻는 WAMP 서버를 사용하여 웹 애플리케이션에 액세스했습니다. 위도 및 경도 값은 mysql 데이터베이스의 테이블에 저장됩니다. 이제 위도와 경도 값을 사용하여 사용자에게 가장 가까운 위치를 제공해야합니다. 그래서 위도와 경도 값을 mysql 데이터베이스에서 가져 와서 hadoop으로 가져 오려고합니다.

0열

1답변

mapreduce 코드는 빈 출력 파일을 생성합니다. 코드와 입력 값은 다음과 같습니다.

mapreduce 코드는 빈 출력 파일을 생성합니다. 코드와 입력은 아래와 같습니다. package temperature; import org.apache.hadoop.io.IntWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapreduce.Reducer; import

-3열

1답변

hdfs에서 accumulo로 데이터를 저장하는 방법은 무엇입니까?

나는 HDFS에서 데이터를 가져 와서 그것을 apache accumulo에 저장하는 하나의 POC에 관여하고있다. 나는 다양한 기사를 읽었지만 가능한 해결책을 찾지 못했습니다. 이와 관련하여 안내를 찾으십시오.

1열

1답변

cloudera 쓰레 쉬 체크 포인트 간격 구성

Cloudera에서는 fs.trash.interval을 구성 할 수 있습니다. 그러나 fs.trash.checkpoint.interval을 허용하지 않습니다. 그래서 언제 hdfs가 검사 점을 생성합니까? 비슷한 질문이 응답하지 않고 여기에 존재합니다 When does Hadoop Framework creates a checkpoint (expunge) t

0열

1답변

생성 후 하이브 외부 테이블 구분 기호가 손상됩니다.

깨진 파이프 구분 기호가있는 소스 파일이 있습니다. 내 하이브 외부 테이블도 깨진 파이프 구분 기호로 만들었습니다. 하지만 테이블을 만든 후에는 'j'와 같은 구분 기호가 표시됩니다. 테이블에서 쿼리 할 수도 없습니다. 등재 구문 : ASCII 값 시도 PARTITIONED BY ( eventdate date) ROW FORMAT DELIMITE

0열

2답변

Cloudera의 색조 - NULL 값 (파일 가져 오기)

어제 저는 Cloudera QuickStart VM 5.8을 설치했습니다. HUE에 의해 데이터베이스에서 파일을 임포트 한 후, 일부 테이블에는 NULL 값 (전체 컬럼)이 있습니다. 이전 단계에서 가져온 데이터를 올바르게 표시합니다. 당신이 명령을 실행할 수 있습니다 First Pic. Second Pic.

0열

1답변

임팔라에 배치를 너무 오래 걸립니다.

임팔라 JDBC 드라이버를 사용하여 임팔라에 배치 데이터를 일괄 적으로 삽입하고 있습니다. 현재 배치 크기가 1000이고 배치 쿼리를 실행하기 위해 PreparedStatement에 의해 INSERT INTO VALUES 절을 사용합니다. 임팔라 데몬 3 대와 임팔라 카탈로그 서버, 상태 저장소가 4 대 기계에서 실행됩니다. 임팔라에 일괄 삽입 쿼리 계획은

0열

1답변

Spark Streaming에서 일괄 처리가 완료된 것을 감지하는 방법이 있습니까?

나는 Cloudera 5.8.3과 함께 Spark 1.6.0을 사용합니다. 은 내가 DStream 객체와 그 위에 정의 된 변환의 많음, val stream = KafkaUtils.createDirectStream[...](...) val mappedStream = stream.transform { ... }.map { ... } mappedStream

-2열

2답변

는 하둡은 클라우 데라 경로에 VM웨어

안녕하세요 클라우 데라의 VM 4.2.1 페이지에 자바 내 평균 단어 수를 구현하고 난 JAR 파일로 변환 명령을 실행 한 : 하둡 항아리 averagewordlength.jar stubs.AvgWordLength 셰익스피어의 wordleng 을 다음 : 셰익스피어를 올바르게 실행했고 내 파일을 실행할 수 없습니다 (내가 작성한 파일 : newfile).