3

AvroCoderに基づくカスタム コーダーAvroDeterministicCoderを作成しようとしていますが、isDeterministic に対して true を返します。

サンプルの Dataflowでは、このコーダーをすべての PCollection に登録します。ただし、テストを実行すると、例外がスローされます。 the key coder must be deterministic for grouping.

デバッガーを使用すると、コーダー AvroCoder を使用していることがわかります。

AvroDeterministicCoderでは、 AvroDeterministicCoderを AvroCoder としてではなくAvroDeterministicCoderとして逆シリアル化するコードを追加する必要があり ますか?

4

1 に答える 1

2

これは私のコードのバグでした。ofAvroDeterministicCoder 型を返すには、さまざまなメソッドをオーバーライドする必要がありました。

作業コードは次のとおりです: AvroDeterministicCoder。

于 2015-01-25T18:10:40.533 に答える