This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from d9443c14277 log server in broker failure detector (#16357)
add fe1767ebdbe Avoid bytes copy in MessageDecoder (#16349)
No new revisions were added by this update.
Summary of changes:
.../pinot/integration/tests/ClusterTest.java | 7 ----
.../inputformat/avro/KafkaAvroMessageDecoder.java | 22 +++++++------
.../inputformat/avro/SimpleAvroMessageDecoder.java | 10 ++----
.../inputformat/clplog/CLPLogMessageDecoder.java | 27 ++++++++--------
...aConfluentSchemaRegistryAvroMessageDecoder.java | 8 ++++-
...aConfluentSchemaRegistryJsonMessageDecoder.java | 7 +++-
...fluentSchemaRegistryProtoBufMessageDecoder.java | 7 +++-
.../plugin/inputformat/csv/CSVMessageDecoder.java | 23 ++++++--------
.../inputformat/csv/CSVMessageDecoderTest.java | 2 +-
.../inputformat/json/JSONMessageDecoder.java | 22 +++++--------
.../protobuf/ProtoBufCodeGenMessageDecoder.java | 37 ++++++++--------------
.../protobuf/ProtoBufMessageDecoder.java | 24 +++++---------
.../segment/local/utils/TableConfigUtilsTest.java | 3 ++
.../pinot/spi/stream/StreamDataDecoderImpl.java | 22 +++++++------
.../java/org/apache/pinot/spi/utils/JsonUtils.java | 5 +++
.../spi/stream/StreamDataDecoderImplTest.java | 23 +++++---------
16 files changed, 117 insertions(+), 132 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
