jadami10 commented on code in PR #12697:
URL: https://github.com/apache/pinot/pull/12697#discussion_r1578669371
##########
pinot-spi/src/main/java/org/apache/pinot/spi/stream/RowMetadata.java:
##########
@@ -64,24 +62,34 @@ default long getFirstStreamRecordIngestionTimeMs() {
}
/**
- * Returns the stream message headers
- *
- * @return A {@link GenericRow} that encapsulates the headers in the
ingested row
+ * Returns the stream offset of the message.
+ */
+ @Nullable
Review Comment:
that's a solid post. thank you for the reference!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]