You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pinot.apache.org by ki...@apache.org on 2022/07/27 02:30:07 UTC

[pinot] branch message-header updated (f89cc3b53c -> b52d0659b6)

This is an automated email from the ASF dual-hosted git repository.

kishoreg pushed a change to branch message-header
in repository https://gitbox.apache.org/repos/asf/pinot.git


    from f89cc3b53c Adding support to extract values from message header.. initial support for kafka headers
     add b52d0659b6 Adding few udf to convert byte[] to string and also prefixing the header fields with header$ prefix to seperate them from the keys in message payload

No new revisions were added by this update.

Summary of changes:
 .../common/function/scalar/StringFunctions.java    | 41 +++++++++++++++++++++-
 .../realtime/LLRealtimeSegmentDataManager.java     |  2 +-
 .../tests/BaseClusterIntegrationTest.java          |  5 ++-
 .../tests/ClusterIntegrationTestUtils.java         |  7 +++-
 .../tests/RealtimeClusterIntegrationTest.java      | 12 +++++++
 .../stream/kafka20/RowMetadataExtractor.java       |  2 +-
 .../stream/kafka20/server/KafkaDataProducer.java   | 20 +++++++++++
 .../pinot/spi/stream/StreamDataProducer.java       |  9 +++--
 8 files changed, 91 insertions(+), 7 deletions(-)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org