apache-zeppelin

0熱

1答えて

ZeppelinでPythonインタプリタのPythonインストール場所を変更するにはどうすればよいですか？

ZeppelinのPythonインタプリタ用に指定されたPythonのインストール場所はどこですか？ Zeppelinの新しいpythonインストールディレクトリでPythonインタプリタのpythonインストール場所を変更するにはどうすればよいですか？助けていただければ幸いです。ありがとうございました。

5熱

1答えて

許可が拒否されました：ユーザー=ツェッペリンをAWS EMRクラスタで

を％のspark.pysparkインタプリタを使用している間、私はpyspark構造化されたストリーミングプログラムを作成し、ツェッペリンのノートブックで実行しようとしています %spark.pyspark query_window = windowedCounts \ .writeStream \ .outputMode("complete") \

0熱

1答えて

Flink linearRegression：データを読み込む方法（Scala）

私はFlinkで複数線形回帰アルゴリズムを訓練し始めています。私は素晴らしいですofficial documentationと次のとおりです。私はこのコードを開発するためにZeppelinを使用しています。私はCSVファイルからデータをロードする場合：私はLIBSVMファイルからデータをロードする場合 //Read the file: val data = benv.readCsvFile[

0熱

1答えて

ZeppelinとSparkの設定

私はlocalhostのSpark（2.1.1）でZeppelin（0.7.1）を使っていて、実行しているジョブにいくつかの設定値を追加しようとしています。具体的には、elasticsearch-hadoopのes.nodes値を設定しようとしています。インタプリタの設定にキーと値を追加しようとしましたが、それはsc.getConfに表示されませんでした。インタプリタの "args"設定キーに

1熱

1答えて

ZeppelinのElasticsearchインタプリタが要求に応答しない

私は実行中のElasticsearchノードをマシンに持っています。それは健康で、うまく動作します。私は問題なしにブラウザ上で任意の要求を実行することができます。私は弾性インタプリタを設置したゼペリンノートを持っています。通訳の仕方は次のとおりです。 elasticsearch.basicauth.password elasticsearch.basicauth.username el

1熱

1答えて

zeppelin％sqlにフル・カラム・サイズを表示

私は単に配列を切り捨てずに列を表示したいと思います。私は一時テーブルとしてDFレジスタを照会するツェッペリンを使用します。 %livy.sql select * from maTable 私はConsommeur列の全長を持ちたい私のようなものを得る：をあなたが持っています何か案が？

0熱

1答えて

Zeppelin Oracle SQLクエリーが実行されます

私はZeppelin（Windows 10ではv 0.7.0 Java 1.8、docker v .0.7.1と同じ）を使用しようとしています。これまでのところ、exampleのような論文が見つかりました。私は、JDBCインタプリタを使用しよう： common.max_count=100 default.driver=oracle.jdbc.pool.OracleDataSource def

1熱

1答えて

は、VectorAssembler.transfromの後にZeppelinの他の段落を実行できません

私はZeppelin 0.7.1とspark 2.1.0を使用しています。私はデータフレーム「データセット」の一部のデータだVEの： +-------+-------+-------+-------+ | index |var 1 |var 2 |var 3 | +-------+-------+-------+-------+ | 0 | 0 | 1 | 0 | +------

1熱

2答えて

Apache Zeppelin Python UDFをSQL

私はPythonでSQLテーブルに新しい列を追加するために書いた関数を取得しようとしています。私はその関数からSQLテーブルにUDFを渡す方法を理解できません。私はこれを行う方法はの列と信じて、私はちょうど方法を知らない。目的は、SQLテーブルから日/週/年を取得し、与えられたデータから月を計算することです。日/週/年を値に設定すると、下の関数が機能します。ここでが機能である： def get

2熱

2答えて

リモートサーバー上で実行されているApache ZeppelinからHDFSにファイルを転送する

リモートサーバー上でApache Zeppelinのインスタンスが実行されていますが、Spalaインタプリタを介して通信するためにScalaを使用しています。そのサーバーのディレクトリに保存されているcsvファイルを、リモートサーバー上にあるHDFS（Hadoop）に転送したいとします。私はサーバ上の設定ファイルにアクセスできません。何もインストールできません。私はZeppelin内でのみコマ