Generate a list of executions from a date range
Generate a list of executions from a date range
Duration to split daterange
Function to run a execution given a date range
Sequence of Executions per Day
Split a DateRange and allow for max parallel running of executions
Split a DateRange and allow for max parallel running of executions
Duration to split daterange
How many jobs to run in parallel
Function to run a execution given a date range
Execution of Sequences
Same as runDateRangeWithParallelism, but sums the sequence of values after running.
Same as runDateRangeWithParallelism, but sums the sequence of values after running. This is useful when you want to do a calculation in parallel over many durations and join the results together.
For example, a common use case is when T is a TypedPipe[U] and you want to independently compute the pipes on each day and union them into a single TypedPipe at the end.
Another possible use case would be if the executions were created by summing intermediate monoids (e.g. T was a Map[String,HLL] since algebird supports monoids for maps and hll) and you wanted to do a final aggregation of the Monoids computed for each duration.
Split a DateRange and allow for max parallel running of executions
Split a DateRange and allow for max parallel running of executions
Duration to split daterange
How many jobs to run in parallel
Function to run a execution given a date range
Seq of Dates split by Duration with corresponding execution result