risingwave_connector::source::filesystem

Module nd_streaming

source

Functions§

  • need_nd_streaming
  • split_stream
    This function splits a byte stream by the newline separator “(\r)\n” into a message stream. It can be difficult to split and compute offsets correctly when the bytes are received in chunks. There are two cases to consider: