ashajyothi828 commented on issue #2208:
URL: https://github.com/apache/iceberg/issues/2208#issuecomment-776149792
Cant get the key from a record in the stream, the sink takes the stream as
input and couldnt figure out how to get the key that applies to that stream.
Basically tried to implement the below method in the sink and was not able to
get the key value present in RowData.
public DataStreamSink<?> consumeDataStream(DataStream<RowData> dataStream) {}
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
