FilesystemBuckets implements BucketsStorage
FinalYes
Interfaces
Methods
- __construct() : mixed
- append() : void
- SCHEMA EVOLUTION: the bucket's schema is fixed by the first batch, so a later batch carrying a column the first one lacked is rejected. Reachable from group-by and join whenever rows with different column sets hash into one bucket. Proper evolution - adding an optional column, relaxing not-null - would remove this limitation.
- get() : Generator<string|int, Rows>
- Yields the bucket back in batches - batch shape is storage-defined, consumers must not assume any particular batch size.
- remove() : void
- set() : void
Methods
__construct()
public
__construct(Filesystem $filesystem, Path $cacheDir[, int<1, max> $batchSize = 1000 ]) : mixed
Parameters
- $filesystem : Filesystem
- $cacheDir : Path
- $batchSize : int<1, max> = 1000
append()
SCHEMA EVOLUTION: the bucket's schema is fixed by the first batch, so a later batch carrying a column the first one lacked is rejected. Reachable from group-by and join whenever rows with different column sets hash into one bucket. Proper evolution - adding an optional column, relaxing not-null - would remove this limitation.
public
append(string $bucketId, Rows $rows) : void
Parameters
- $bucketId : string
- $rows : Rows
get()
Yields the bucket back in batches - batch shape is storage-defined, consumers must not assume any particular batch size.
public
get(string $bucketId) : Generator<string|int, Rows>
Parameters
- $bucketId : string
Return values
Generator<string|int, Rows>remove()
public
remove(string $bucketId) : void
Parameters
- $bucketId : string
set()
public
set(string $bucketId, Rows $rows) : void
Parameters
- $bucketId : string
- $rows : Rows