apache-pig

    0

    2答えて

    Pls助けてください。 シナリオ:Pigを使用してHDFSからHiveにデータを保存します。 私は、4つのフィールドOrd_Id, Cust_Id, Cust_name, Ord_dateを持つmySQLから派生したファイルを持っています。 Ord_IdとCust_Idの2つのフィールドだけをHiveに保存するのが好きです。どうすればいい?アドバイスお願いします。コードの下 は実行できません。 p

    1

    1答えて

    私は入力としてdatabag(final)を渡そうとしています。 dump final; ができます: -私は私は私のUDFかどうかを確認する必要があることを行うためには、上記databagを処理し、送信元と送信先との間のミスマッチを見つけるためのUDFを書くことについてだ (4,john,john,David,Banking ,4,M,20-01-1994,78.65,345000,Arka

    0

    2答えて

    レコードを入力するたびにハイブテーブルにユニークな値を追加したい場合、その値をハイブテーブル全体で繰り返さないでください。私はこれに対する解決策や機能を見つけることができません。私の場合は、ブタラテンを使ってハイブで記録を入力したいと思います。助けてください。

    1

    1答えて

    このPIGスクリプトを実行中に次のエラーが発生しました。 ありがとうございます。 "ERROR 1000: Error during parsing. Scalars can be only used with projections" MOVIES = LOAD '/MOVIES' using PigStorage(',') as (mid:double, mn:chararray, yr:

    0

    1答えて

    PIGスクリプトの一環として、UDFを使用して生成されたXMLを取得する必要があります。そのXMLは大きすぎます(約1.5GB)。現在、私はにStringWriterは内部文字列バッファを使用しているとArrays.As配列は、インデックスのために、整数を使用し、XMLの長さはint型を超えているにそれが依存する。これは、OutOfMemoryErrorをスロー文字列 StringWriter s

    1

    2答えて

    私は豚の構文には新しいので、誰かがこのSQLのコードを豚に翻訳するヒントを提供できるかどうか疑問に思っていました。 SELECT column1, column2, SUM(column3) FROM table WHERE column5 = 100 GROUP BY column2; これまでのところ私が持っている:これは動作しません data = LOAD....etc. fil

    0

    1答えて

    このサンプルはnutch 2.3.1を使用してクロールデータを取得します。 私は豚へのHBaseからデータをインポートするには、このコマンドを使用 `data9 = load 'hbase://htest15_webpage' using org.apache.pig.backend.hadoop.hbase.HBaseStorage('f:cnt', '-loadKey true'); `

    0

    1答えて

    私はファイルを解析するために豚を使用していますが、if-else条件を適用して、文が存在するかどうかをチェックします。 statemnetが存在しない場合、私は出力ファイル名をNoとします。そうでなければ、出力ファイル名をそのままステートメントのままにします。どうやってやるの。 例: amit|COD|12543|nagpur|MH|India 今、私は私の$1は、それが空である場合、私はこの

    0

    1答えて

    HCatLoaderで豚を使用してパーティション化されたハイブテーブルに対して何らかの変換を実行しようとしています。私はハイブ1.2とブタ0.15を使用しています。ハイブテーブルのパーティション化された列のデータ型はsmallintです。それは非パーティションハイブテーブルのためにうまくいきます。以下は私が行っているステップです。私はいくつかの調査を行い、Exception stacktraceの

    1

    1答えて

    プレビューから\ Nを取り除くためにどのようなので、基本的にあれば、空の文字列 d = FOREACH result GENERATE REPLACE(REPLACE(EFF_DT,'\N',''); で()と\Nを置き換えます\Nが\Nを取り除き、()と表示されるはずですが、それは明らかにとして表示されます。。なぜこれが想定どおりに動作していないのか不思議です。私は下のものも試してみた。 d