NiFi-1.0.0 - ExecuteSQL CrateIO

Question

テーブルを作成するSQL文（ExecuteSql proc）を実行しようとしていますが、テーブルの名前はfilename属性に基づいており、ExecuteSQlが実行されるとテーブルが作成されますファイルを任意の関係にルーティングします。

私はこれがCrateIOでテーブルを作成するためには、 ";"最後に。もし私がそれを行うならば、私もエラーが発生します。

アイデア？

Answer 1

ExecuteSQLは、ResultSetを返すクエリを対象としています。テーブル作成（と他のDDLステートメント）のようなもののためにPutSQLを試してみてください。セミコロンは必要ありませんが、どちらの方法でCrateIOが好きなものを見ることができます。

EDIT（コメントに返信）：あなたがGETFILE後と前ReplaceTextプロセッサと同様のことを行うことができます

CREATE TABLE ${filename} (myColumn1 STRING, myColumn2 INT, ...) 

：あなたはは、ExecuteSQLでクエリを指定している場合、それはおそらくのようになりますPutSQL。 ReplaceTextは、あなたのSQLクエリーにフローファイルの内容を設定します。これはPutSQLが望むものです。

EDIT 2：カスタムロジックが必要な場合は、スクリプトプロセッサとフルカスタムプロセッサを作成することが考えられます。次に、CREATE TABLEを生成してから、CSV行をINSERT文に変換します。 DBに接続したい場合は、blog postでDBCP接続プールの使用方法を確認してください。