사용자 정의 코더를 만드는 방법은 무엇입니까?

Question

AvroCoder을 기반으로하는 사용자 정의 코더 AvroDeterministicCoder을 만들려고하지만 isDeterministic에 대해 true를 반환합니다.

내 example Dataflow에서 내 모든 PCollections에이 코더를 등록합니다. 그러나, 나는 실행하면 내 test 예외를 던지는 끝 : the key coder must be deterministic for grouping.

내 디버거를 사용하여, 나는 그것의 코더 AvroCoder를 사용하는 것을 알 수 있습니다.

AvroDeterministicCoderAvroDeterministicCoder을 AvroDeterministicCoder으로 역 직렬화하도록하고 AvroCoder가 아닌 코드를 추가해야합니까?

Answer 1

내 코드에 버그가있었습니다. 다양한 of 메서드를 재정 의하여 AvroDeterministicCoder 유형을 반환해야했습니다.

여기 작업 코드는 AvroDeterministicCoder입니다.