You're seeing just the function stream_parallel_scan, go back to ExAliyunOts module for more information.
Link to this function

stream_parallel_scan(instance, table_name, index_name, options)

View Source


stream_parallel_scan(instance(), table_name(), index_name(), options()) ::

Integrate parallel_scan/4 with compute_splits/3 as a complete use, base on the response of compute_splits/3 to create the corresponding number of concurrency task(s), use Task.async_stream/3 to make parallel scan as a stream which properly process token in every request of the internal, when use this function need to consider the possibility of the OTSSessionExpired error in the external.


Please see options of iterate_parallel_scan/5.