2016-03-22 15 views

答えて

1

は、あなたがそれをGoogleで検索して...私は任意のスパーク、カフカを使用していないに注意してください?

たとえば、thisを試してください。

+0

こんにちは、私はこれを行って、例7から、私は同様のもの(http://www.programcreek.com/java-api-examples/index.php?source_dir=pbase-master)を実装したいと思います/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/pbase/util/GenerateParquetFile.java)、 –

+0

しかし、すべての依存関係のコードを追加した後に、私はParquetWriterの近くに問題を出しています writer = new ParquetWriter (initFile(fileName)、新しいGoupWriteSupport(metas)、CompressionCodecName.SNAPPY、1024,1024,512、true、false、ParquetProperties.WriterVersion.PARQUET_1_0、conf); コンストラクタGroupWriteSupport(Map )は定義されていません。 –

+0

で助けてください。未定義ではありません。コンストラクターはGroupWriteSupport(MessageTypeスキーマ、Map extraMetaData)です。スキーマを追加する –

4

前のリンクには主にAvroスキーマの例が含まれています(私は疑問に思っています。私は今までのところ信頼できる例を見つけることはできませんでした。あなたが使用できるのはschema filethis articleです。また、repo with moreの例があります。

関連する問題