ExAliyunOts.stream_parallel_scan
You're seeing just the function
stream_parallel_scan
, go back to ExAliyunOts module for more information.
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
.