struct EmptyInput

A kind of placeholder array generating an artificial input in the DAG graph, which only gets filled during the computation. Mainly used to reserve an input buffer.

Type used for dispatch to show something is done in input mode

Struct specifying the windows of a participating array along each dimension as well as the loop axes where this array participates in the loop

Type used for dispatch to show something is done in output mode

Type very similar to Iterators.product, but for indexable arrays.

Given the loop windows of an input array estimate the apparent chunks along an axis given the underlying chunks.

Compute how often a buffer needs to be passed to the computation before it can be flushed to the output array

Removes all outout buffers from an output aggregator that have been successfully put to disk

Returns the full domain that a DiskArrays.ChunkType object covers as a unit range

Extracts or creates output buffer as an ArrayBuffer

If one of the outputs is a reduction it is important not to have overlapping loop ranges for a reduction group. This will try to correct loopranges to avoid the problems mentioned above.

Creates buffers for input arrays

Creates buffers for all outputs, results in a tuple of Dicts holding the collection for each output

Create buffer for single output

Determine the needed buffer size for a given Input array and loop ranges lr

interpolate_diskarray(a, conv)

Function to interpolate a diskarray along one or more dimensions. The interpolation is specifed by the list conv consisting of pairs of dim_index => (source_axis,dest_axis) values. For example, to interpolate an input array with dimensions (x,y,t) to new coordinates (x2,y2,t2) you can do

````julia #Old coordinates a = [i+j+k for i in 1:4, j in 1:5, k in 1:6] #source coordinates x = 5.0:5.0:20.0 y = 2.0:3.0:14.0 #target coordinates x2 = 5.0:0.5:20.0 y2 = 1.5:1.0:14.5 r = interpolate_diskarray(a,(1=>(x,x2),2=>(y,y2)))

Returns the length of a dimension covered by a DiskArrays.ChunkType object

Check if maximum number of aggregations has happened for a buffer

Checks if output buffers have accumulated to the end and exports to output array

Function to finalize and remove buffers without writing to an array

Tests that a supplied list of parent chunks covers the same domain and returns this

Reads data from input array ia along domain r into buffer