SpillingRowsStorage implements RowsStorage
FinalYes
Past the memory limit, every frame on $disk holds exactly $batchSize rows.
Interfaces
Properties
Methods
- __construct() : mixed
- append() : void
- An empty batch still makes has() answer true for the key.
- close() : void
- Finishes the key's pending writes so another process can read it; a no-op for a key with none.
- get() : Generator<string|int, Rows>
- Yields the key's rows back in batches - batch shape is storage-defined, consumers must not assume any particular batch size.
- has() : bool
- remove() : void
- rows() : Cardinality
- schema() : Schema|null
- The schema every batch of the key fits; null for a missing key.
- writeFullBatches() : void
Properties
$disk read-only
public
RowsStorage
$disk
$memoryLimit read-only
public
Unit
$memoryLimit
Methods
__construct()
public
__construct(RowsStorage $disk, Unit $memoryLimit, Backend $backend[, BatchSize $batchSize = new BatchSize(1000) ]) : mixed
Parameters
- $disk : RowsStorage
- $memoryLimit : Unit
- $backend : Backend
- $batchSize : BatchSize = new BatchSize(1000)
append()
An empty batch still makes has() answer true for the key.
public
append(string $key, Rows $rows) : void
Parameters
- $key : string
- $rows : Rows
close()
Finishes the key's pending writes so another process can read it; a no-op for a key with none.
public
close(string $key) : void
Parameters
- $key : string
get()
Yields the key's rows back in batches - batch shape is storage-defined, consumers must not assume any particular batch size.
public
get(string $key) : Generator<string|int, Rows>
Parameters
- $key : string
Return values
Generator<string|int, Rows>has()
public
has(string $key) : bool
Parameters
- $key : string
Return values
boolremove()
public
remove(string $key) : void
Parameters
- $key : string
rows()
public
rows(string $key) : Cardinality
Parameters
- $key : string
Return values
Cardinalityschema()
The schema every batch of the key fits; null for a missing key.
public
schema(string $key) : Schema|null
Parameters
- $key : string
Return values
Schema|nullwriteFullBatches()
public
writeFullBatches(string $key) : void
Parameters
- $key : string