誰もこのコードを試したことがありますか?GCSバケットに格納されたXMLファイルを読み込むためにXmlSourceを使用できません
XmlSource<String> source = XmlSource.<String>from("gs://balajee_test/sample_3.xml")
.withRootElement("book")
.withRecordElement("author")
.withRecordElement("title")
.withRecordElement("genre")
.withRecordElement("price")
.withRecordElement("description")
.withRecordClass(XMLFormatter.class);
PCollection<String> output = p.apply(Read.from(source));
https://beam.apache.org/documentation/sdks/javadoc/0.4.0/org/apache/beam/sdk/io/XmlSource.html
org.apache.beam.sdk.io.xml.XmlSource
私は正しい 'XmlSource' クラスを使用したが、まだ解決できていないよ希望メソッドの依存関係をfrom( "gs://balajee_test/sample_3.xml") 'に変更し、コンパイルエラーを取得しました。エラーメッセージは次のとおりです。
(文字列)からメソッドの型がXmlSource
のためにこの質問はあまりにも愚かに行くかもしれませんが、私は本当にそれを読むことができるようにするために解決を取得する必要が定義されていませんXMLファイルはGCSバケットに格納されています。
beam.apache.org/documentation/sdks/javadoc/2.0.0あなたはSDKのバージョンは何を使用していますか?これらのドキュメントは非常に古いバージョン用です(.4)。現在のバージョンは2.1です。新しいバージョンのSDKを使用している場合は、次のようにします:https://beam.apache.org/documentation/sdks/javadoc/2.1.0/ また、2つの 'froms'よくそれは意図されていますか?古いSDKを使用している場合は問題になる可能性があります。 –
すみません。それらの2つの 'froms'は意図されていませんでした。誤ってこのクエリを投稿しているときに、同じ 'from'ステートメントを2回コピーしました。私は2.0バージョンを使用しています。これは問題ですか? –
XMLソースのAPIが2.0バージョンで変更されました。私はその特定のバージョンの新しいドキュメントを使用しようとします。 https://beam.apache.org/documentation/sdks/javadoc/2.0.0/ org.apache.beam.sdk.io.xmlを探してXMLソースを見ることができます –