ashajyothi828 edited a comment on issue #2208:
URL: https://github.com/apache/iceberg/issues/2208#issuecomment-776149792
@stevenzwu 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]
