MrLolthe1st commented on issue #37429: URL: https://github.com/apache/arrow/issues/37429#issuecomment-1696943683
> How about adding `arrow::ipc::StreamDecoder::Reset()` instead of exporting `StreamDecoderImpl`? It's just one approach. In addition to `arrow::ipc::StreamDecoder::Reset()` must be added `arrow::ipc::StreamDecoder::OnMessageDecoded(...)`, because ` arrow::ipc::StreamDecoder::Consume(...)` doesn't returns amount of readed bytes, so anyway hight-level control of messages must be provided to feed `StreamDecoder` messages one-by-one. For example, I'm trying to feed `StreamDecoder` with payload looks like that: ``` <RECORD BATCH n - 1> <EOS> <SCHEMA> <DICTIONARY 0> ``` In that way I'm must determine where message with schema is located (to feed resetted `StreamDecoder` with new messages, starting with schema message). Another approach is to make `Consume()` return not just status, but amount of bytes readed before EOS. -- 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]
