問題タブ [apache-flink]

次のコードで Apache Flink を使用している場合:

私はこの例外を得ました

UnmodifiableCollectionFlinkを使用するにはどうすればよいですか?

列に異なるエントリを持つテーブルがあります (ただし、すべてを知っているわけではありません)。

今、最初の列のすべてのエントリがカウントされているリストまたは辞書を取得したい:

私は試した：

そして、Word-Count の例linkを使用しようとしましたが、入力として文字列の配列が必要ですか?! それで

動作しません。

私は Scala API 経由で apache flink を使用していますが、ある時点で DataSet[(Int, Int, Int)]. メソッドを使用した結果 writeAsCSV()は writeAsText()予期しないものです。ディレクトリを作成します。そのディレクトリには、メソッド呼び出しの最初のパラメーターの場所と名前があります (例: filePath .)。そのディレクトリには、"1" と "2" という名前の 2 つのファイルが出現します。これらのファイルでは、DataSets データを確認できます。DataSet のコンテンツは、これら 2 つのファイルに分割されているようです。この動作を再現して、より簡潔なコード フラグメントを表示しようとしましたが、できませんでした。つまり、予想される位置に予想される名前のファイルが 1 つ作成され、ディレクトリが作成されないことを確認しました。val mas = ma_ groupBy(0,1) sum(2) mas.writeAsCsv("c:\flink\mas.csv" )

「mas.csv」という名前のディレクトリと、その中に「1」と「2」の 2 つのファイルが作成されます。このようなことはいつ起こりますか？flink 9.1 ローカル モード、Windows 7、scala 2.10、eclipse3.0.3 を使用

Flink doc は、SVM アルゴリズムのスカラの例を示しています。

"fit" の呼び出しはどのように Java に変換されますか?

(Java 式 "svm.fit(trainingDS)" は、Java コンパイラ エラーを返します。

"型 SVM のメソッド fit(DataSet, ParameterMap, FitOperation) は、引数 (DataSet) には適用できません" )

私の現在の試み：

• Eclipse 4.4.2 Luna と scala-ide プラグイン
• scala 2.11 用に Flink を再ビルドします (デフォルトでは、maven は scala 2.10 用の公式の Flink ビルドをダウンロードします。これにより、恐ろしいマクロの非互換性など、IDE にいくつかの問題が発生します。

しかし、必要に応じてそのように作業するのはやや面倒です:

• 最新のソース コードに更新するたびに Flink for scala 2.11 を再構築するには。
• Eclipse でプロジェクトをビルドするときに、プロジェクトの依存関係が Flink 公式ビルドで上書きされないように (つまり、scala 2.11 Flink ビルドを scala 2.10 ビルドで上書きしないように) 正しい Maven 設定を使用してください。