apache-zeppelin

2열

1답변

Zeppelin의 스칼라 스파크 창에 대해 CSV 헤더를 별도의 파일에서 자동로드 할 수 있습니까?

나는 많은 수의 gzip 된 csv 파일로 저장되는 데이터 소스를 가지고있다. 이 소스의 헤더 정보는 별도의 파일입니다. 이 데이터를 조작하기 위해이 데이터를로드하고 싶습니다. 스키마를 알아 내고 헤더를로드하는 간단한 방법이 있습니까? 글자 그대로 수백 개의 열이 있으며, 실행 사이에 변경 될 수 있습니다. 수동으로 수행하지 않을 것을 강력히 권합니다.

2열

1답변

Apache zeppelin 오류

구성된 포트에서 Apache zeppelin을 시작하고 성공적으로 실행했습니다. 난 그냥 내 콘솔에서 오류 출력없이 실행 버튼 근처에 "ERROR"문자열을 볼 수 있습니다 sc.version println(zeppelin) 처럼 내가 실행하고있는 동안 간단한 스파크 명령. 내 오류 로그 : ERROR [2016년 10월 21일 22 : 38 : 05,

2열

1답변

Zeppelin 및 Spark를 사용하여 대형 텍스트 파일 처리

Zeppelin (scala)을 사용하여 50GB 이상의 대형 텍스트 파일에서 일부 데이터를 분석하려고합니다. 웹의 예제는 각 열의 알려진 헤더 및 데이터 유형이있는 csv 파일을 사용합니다. 필자의 경우에는 분리 문자로 된 순수한 데이터 라인이있다. 아래 코드와 같이 데이터를 DataFrame에 저장하려면 어떻게해야합니까? : case class Reco

0열

1답변

withkeepBinary를 zeppelin의 % ignite.ignitesql 인터프리터에서 사용하는 방법

키와 값이 모두 포함 된 IgniteRDD에 BinaryObject로 저장된 일부 Spark 데이터 세트와 아래에서 % Ignite 인터프리터 샘플을 사용하여 Ignite 코드를 사용하여 다시 쿼리 할 수 있습니다. . 내가 %의 ignite.ignitesql 인터프리터와 같은 쿼리 할 때 %ignite import org.apache.ignite._

2열

2답변

Zeppelin Twitter 스트리밍 예제가 작동하지 않습니다.

Zeppelin에서 Twitter Streaming Example을 실행하려고합니다. 내가 검색 한 후에 Spark Interpreter에 "org.apache.bahir : spark-streaming-twitter_2.11 : 2.0.0"을 추가했습니다. 그래서 같이 첫 번째 부분의 작업을 할 수 있습니다 : <console>:56: error: not

3열

1답변

Zeppelin Notebook에서 전역 변수를 설정할 수 있습니까?

Zeppelin 노트북을 사용하여 여러 단락 대시 보드를 만들려고합니다. 대시 보드를 사용하는 사람들이 특정 매개 변수를 한 번만 입력하면됩니다. 예 : 다른 웹 사이트에 대한 정보가 포함 된 대시 보드를 만드는 경우 대시 보드 사용자는 정보를 한 번만 원하는 특정 웹 사이트를 선택하면 전체 다단계 대시 보드가 업데이트됩니다. 이것이 가능한가? 노트북에서

5열

2답변

Spark throw java.util.NoSuchElementException : key not found : 67

Zeppelin에서 Spark bisecting kmmeans 알고리즘을 실행 중입니다. 나는 항상 생각이 오류가 //I transform my data using the TF-IDF algorithm val idf = new IDF(minFreq).fit(data) val hashIDF_features = idf.transform(dbTF) /

0열

1답변

"500 내부 서버 오류"Apache 노트북 Zeppelin on Azure Hdinsight

정규식을 사용하여 로그 라인에서 정보를 추출하려면 Azure HDInsight에서 spark 응용 프로그램 (스칼라로)을 작성하려고합니다. 정규 표현식은 이것이다 : val patt1="""(?:(\w+) (\w+) (\d+) (\d+):(\d+):(\S+) (\w+) \[([^]]+)\] $(.*)$ - \[(\w+)\](?:\[(\w+)\])?\[(

0열

1답변

org.apache.thrift.protocol.TProtocolException : readMessageBegin의 버전이 잘못되었습니다.

제발 zeppelin으로 cassandra를 연결하려고합니다. 쿼리를 실행하려고 할 때마다 다음 오류가 발생합니다. 어떻게해야합니까? %cassandra select * from rawtweet1 org.apache.thrift.protocol.TProtocolException: Bad version in readMessageBegin at

4열

2답변

제플린 java.lang.NoClassDefFoundError가가 : $

내가의 코드 val home = "/Users/adremja/Documents/Kaggle/outbrain" val documents_categories = sc.textFile(home + "/documents_categories.csv") documents_categories take(10) foreach println 을 실행하면 org.apa