1

JavaでORCファイルを作成しています。行ごとに、フィールドをカンマで区切る必要があります。ここに私のJavaコードがあります:

    ObjectInspector inspector = ObjectInspectorFactory.getReflectionObjectInspector(String.class,ObjectInspectorFactory.ObjectInspectorOptions.JAVA);
this.mWriter = OrcFile.createWriter(fs, fsPath, config, inspector, stripSize, CompressionKind.ZLIB, bufferSize,0);
this.mWriter.addRow(new Text("shekhar,saha")); 
this.mWriter.addRow(new Text("ram,shyam"));
this.mWriter.addRow(new Text("jhon,cena"));
this.mWriter.close();

これは正しい作成方法ですか?

Hive テーブルにデータをロードしようとしています。これは私がテーブルを作成した方法です:

create table demo ( name1 STRING,name2 STRING ) ROW FORMAT DELIMITED FIELDS TERMINATED BY ',' STORED AS ORC tblproperties ("orc.compress"="ZLIB");

しかし、データをロードできません。テーブルからデータを読み取っているとき、クラスカースト例外がスローされますorg.apache.hadoop.hive.ql.io.orc.OrcStruct cannot be cast to org.apache.hadoop.io.Text

4

0 に答える 0