beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aromane...@apache.org
Subject [beam] branch master updated (498e9c0 -> ae5e1a3)
Date Wed, 10 Mar 2021 10:05:51 GMT
This is an automated email from the ASF dual-hosted git repository.

aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 498e9c0  Merge pull request #14170 Allow conversion of non-deferred dataframes to
PCollections.
     add 45a2193  [BEAM-11946] Use ReadFromKafkaDoFn for KafkaIO.Read by default when beam_fn_api
is enabled.
     add ae5e1a3  Merge pull request #14168: [BEAM-11946] Use ReadFromKafkaDoFn for KafkaIO.Read
by default when beam_fn_api is enabled.

No new revisions were added by this update.

Summary of changes:
 .../jenkins/job_PerformanceTests_KafkaIO_IT.groovy       |  2 +-
 .../main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java  | 16 +++++-----------
 .../apache/beam/sdk/io/kafka/KafkaIOExternalTest.java    | 12 +++++++-----
 3 files changed, 13 insertions(+), 17 deletions(-)


Mime
View raw message