This is an automated email from the ASF dual-hosted git repository.
echauchot pushed a change to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git.
from c980d4c Fix typo
new 507bbd8 Fix javadoc
new ad29daf Use beam encoders also in the output of the source translation
new ebc53fd Remove unneeded cast
new 25d0401 Fix: Remove generic hack of using object. Use actual Coder
encodedType in Encoders
new 46ed555 Remove Encoders based on kryo now that we call Beam coders in
the runner
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../batch/ReadSourceTranslatorBatch.java | 4 +-
.../translation/helpers/EncoderHelpers.java | 44 ++--------------------
.../translation/helpers/KVHelpers.java | 4 +-
.../translation/helpers/RowHelpers.java | 2 +-
.../streaming/ReadSourceTranslatorStreaming.java | 4 +-
5 files changed, 8 insertions(+), 50 deletions(-)
