ExAliyunOts.stream_parallel_scan

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

Specs

stream_parallel_scan(instance(), table_name(), index_name(), options()) ::
  Enumerable.t()

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.

Options

Please see options of iterate_parallel_scan/5.