apache-zeppelin

1열

1답변

Zeppelin Helium Visualization을 만들고 있는데 하나의 로컬 종속성을 추가해야합니다. 나는 Zeppelin 0.8.snapshot 버전을 작업 중입니다. 나는 그것을 할 수 없다, 나는 뒤에 오는 방법에서 추가하는 것을 시도했다. 내 모듈에 "*"을 사용해 보았습니다. 또한 성공하지 못한 채 상대 경로를 제공하려고 시도했습니다. 내 모

0열

1답변

spark에서 SQL UDF를 사용하기위한 JAR 추가

내 libaray에 정의 된 사용자 정의 UDF를 사용하고 싶습니다. 나는 그것을 위해 다음 코드를 사용했습니다 : 퍼센트 spark2에게 수입 org.apache.spark.sql.functions.year을 발는 SqlContext = 새로운 org.apache.spark.sql.hive.HiveContext (SC) sqlContext.sql (S "

0열

1답변

제플린 %의 SQL은 임시 테이블을 액세스 할 수 없습니다

나는 3 제플린 (0.6) 단락이 있습니다 para1 : val hc = new org.apache.spark.sql.hive.HiveContext(sc) val df = hc.sql("SELECT * FROM tweetsORC") z.put("wds", df) para2 : import org.apache.spark.sql.DataFrame

0열

1답변

생성 된 소스 com.trueaccord.scalapb에서 jar 파일을 만드는 방법

protobuf 스키마에 대한 소스 코드를 생성하기 위해 ScalapB를 사용하고 있습니다. 훌륭하게 작동합니다. 생성 된 소스 코드로만 구성된 병을 어떻게 생성합니까? jar 파일을 만들고 Zeppelin Spark Interpreter에 종속성으로 추가하고 싶습니다.

0열

1답변

Apache Zeppelin이 안정적으로 사용 가능합니다.

AWS EMR 클러스터를 사용하고 있습니다. 나는 스파크 드라이버와 아파치 Zeppelin Rest API를 사용해 실험을 해왔다. 나는 제플린 (Zeppelin)으로 수 백개의 임시직을 운영했지만 걱정하지 않았습니다. 사실 Zeppelin Rest API를 프로덕션에 사용하려고합니다. 나머지 API를 사용하여 작업을 제출할 것입니다. 생산에서 Zeppel

0열

1답변

Apache Zeppelin with Spark Interpreter

현재 Spark 해석기로 Zeppelin을 탐색 중입니다. 질문이있다? 일단 Spark 인터프리터를 사용하여 필요한 모든 데이터를 쿼리합니다. 그룹별로 드릴 다운, 드릴 다운 등 모든 작업은 스파크 작업을 제외하고 수행합니다.

0열

1답변

Zeppelin : Python 파일에 Python 파일을 추가하는 방법

나는 Spark with yarn을 사용하여 제플린을 실행 중입니다. 옵션 --py-files (SPARK_SUBMIT_OPTIONS)는 제플린에서 작동하지 않습니다. zeppelin에 --py-files를 대체 할 수 있습니까? 참고 : --files 옵션을 사용하여 파일을 업로드 할 수 있지만 PYTHONPATH에 파일을 추가하지 않습니다. 그러므로 나

0열

1답변

더 많은 옵션을 사용하여 Zeppelin 인터프리터 UI를 노출합니다.

AWS에서 Zeppelin 인터프리터 UI를 사용하여 일부 스파크 구성을 설정합니다. 기본적으로 그리스 사람 (그림) 만 있지만 나중에 나에게 빨간색 사람이 추가되었습니다. 이러한 인수를 기본적으로 표시되도록 설정하면 속성의 이름이 아닌 값만 재생할 수 있습니다. 나는 스파크 디폴트에 대해 알고 있지만 UI는 다른 구성을 테스트 할 때 중요합니다.

1열

2답변

Apache Zeppelin Connection refused : connect

Zeppelin의 스파크에서 데이터 세트를 시각화하려고합니다. 그러나 Hello World Zeppelin도 java.net.ConnectException: Connection refused: connect 오류가 발생합니다. 내가 윈도우 10을 사용하고 같은 내가 제대로 여기 제플린 GUI 내 스파크 인터프리터의 스크린 샷 내 zeppelin-env.cm

0열

2답변

Spark SQL의 분해 필드에서 GROUP BY를 수행하는 방법은 무엇입니까?

제플린 0.6 스파크 1.6 SQL 나는 어떤 트윗에서 상위 20 발생하는 단어를 찾기 위해 노력하고있다. filtered에는 각 짹짹에 대한 단어 배열이 들어 있습니다. 사용자가 예상하는대로 select explode(filtered) AS words from tweettable 에는 각 단어를,하지만 내가 원하는 모든 트윗을 통해 각 단어의 수를 가