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: [email protected]
For additional commands, e-mail: [email protected]
