Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
335 changes: 170 additions & 165 deletions composer.lock

Large diffs are not rendered by default.

4 changes: 1 addition & 3 deletions src/core/etl/src/Flow/ETL/DSL/functions.php
Original file line number Diff line number Diff line change
Expand Up @@ -223,14 +223,12 @@ function filesystem_cache(Path|string|null $cache_dir = null, Filesystem $filesy
return new FilesystemCache($filesystem, $serializer, \is_string($cache_dir) ? Path::realpath($cache_dir) : $cache_dir);
}

/**
* @param int<1, max> $chunk_size
*/
#[DocumentationDSL(module: Module::CORE, type: DSLType::EXTRACTOR)]
function chunks_from(Extractor $extractor, int $chunk_size) : Extractor\ChunkExtractor
{
return new Extractor\ChunkExtractor($extractor, $chunk_size);
}

#[DocumentationDSL(module: Module::CORE, type: DSLType::EXTRACTOR)]
function from_pipeline(Pipeline $pipeline) : Extractor\PipelineExtractor
{
Expand Down
3 changes: 0 additions & 3 deletions src/core/etl/src/Flow/ETL/Extractor/ChunkExtractor.php
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,6 @@

final class ChunkExtractor implements Extractor, OverridingExtractor
{
/**
* @param int<1, max> $chunkSize
*/
public function __construct(
private readonly Extractor $extractor,
private readonly int $chunkSize,
Expand Down
4 changes: 2 additions & 2 deletions src/lib/parquet/src/Flow/Parquet/Thrift/ColumnMetaData.php
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,7 @@ class ColumnMetaData
* This information can be used to determine if all data pages are
* dictionary encoded for example *.
*
* @var \Flow\Parquet\Thrift\PageEncodingStats[]
* @var PageEncodingStats[]
*/
public $encoding_stats;

Expand All @@ -192,7 +192,7 @@ class ColumnMetaData
/**
* Optional key/value metadata *.
*
* @var \Flow\Parquet\Thrift\KeyValue[]
* @var KeyValue[]
*/
public $key_value_metadata;

Expand Down
8 changes: 4 additions & 4 deletions src/lib/parquet/src/Flow/Parquet/Thrift/FileMetaData.php
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ class FileMetaData
* The obsolete min and max fields in the Statistics object are always sorted
* by signed comparison regardless of column_orders.
*
* @var \Flow\Parquet\Thrift\ColumnOrder[]
* @var ColumnOrder[]
*/
public $column_orders;

Expand Down Expand Up @@ -138,7 +138,7 @@ class FileMetaData
/**
* Optional key/value metadata *.
*
* @var \Flow\Parquet\Thrift\KeyValue[]
* @var KeyValue[]
*/
public $key_value_metadata;

Expand All @@ -152,7 +152,7 @@ class FileMetaData
/**
* Row groups in this file *.
*
* @var \Flow\Parquet\Thrift\RowGroup[]
* @var RowGroup[]
*/
public $row_groups;

Expand All @@ -164,7 +164,7 @@ class FileMetaData
* used to map columns to nodes in the schema.
* The first element is the root *.
*
* @var \Flow\Parquet\Thrift\SchemaElement[]
* @var SchemaElement[]
*/
public $schema;

Expand Down
2 changes: 1 addition & 1 deletion src/lib/parquet/src/Flow/Parquet/Thrift/OffsetIndex.php
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ class OffsetIndex
* PageLocations, ordered by increasing PageLocation.offset. It is required
* that page_locations[i].first_row_index < page_locations[i+1].first_row_index.
*
* @var \Flow\Parquet\Thrift\PageLocation[]
* @var PageLocation[]
*/
public $page_locations;

Expand Down
4 changes: 2 additions & 2 deletions src/lib/parquet/src/Flow/Parquet/Thrift/RowGroup.php
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ class RowGroup
* Metadata for each column chunk in this row group.
* This list must have the same order as the SchemaElement list in FileMetaData.
*
* @var \Flow\Parquet\Thrift\ColumnChunk[]
* @var ColumnChunk[]
*/
public $columns;

Expand Down Expand Up @@ -99,7 +99,7 @@ class RowGroup
* If set, specifies a sort ordering of the rows in this RowGroup.
* The sorting columns can be a subset of all the columns.
*
* @var \Flow\Parquet\Thrift\SortingColumn[]
* @var SortingColumn[]
*/
public $sorting_columns;

Expand Down
12 changes: 6 additions & 6 deletions tools/blackfire/composer.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

36 changes: 18 additions & 18 deletions tools/box/composer.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading
Loading