Commit dd9e5bb
authored
File tree
- .github
- actions/setup-php-env
- workflows
- bin
- documentation
- components/libs/types
- contributing
- src
- adapter
- etl-adapter-avro
- src/Flow/ETL/Adapter/Avro
- FlixTech
- tests/Flow/ETL/Adapter/Avro/Tests/Integration
- etl-adapter-chartjs
- src/Flow/ETL/Adapter/ChartJS
- Chart
- tests/Flow/ETL/Adapter/ChartJS/Tests
- Integration
- Unit/Chart
- etl-adapter-csv
- src/Flow/ETL/Adapter/CSV
- Detector
- Exception
- RowsNormalizer
- tests/Flow/ETL/Adapter/CSV/Tests
- Integration
- Unit
- Detector
- etl-adapter-doctrine
- src/Flow/ETL/Adapter/Doctrine
- Pagination
- tests/Flow/ETL/Adapter/Doctrine/Tests
- Context
- Integration
- Dialects
- Unit
- etl-adapter-elasticsearch
- src/Flow/ETL/Adapter/Elasticsearch
- ElasticsearchPHP
- EntryIdFactory
- tests/Flow/ETL/Adapter/Elasticsearch/Tests
- Context
- Doubles/Spy
- Integration
- ElasticsearchPHP
- Unit
- etl-adapter-excel
- src/Flow/ETL/Adapter/Excel
- DSL
- Function
- RowsNormalizer
- Sheet
- tests/Flow/ETL/Adapter/Excel/Tests
- Integration
- Unit
- Function
- RowsNormalizer
- Sheet
- etl-adapter-google-sheet
- src/Flow/ETL/Adapter/GoogleSheet
- tests/Flow/ETL/Adapter/GoogleSheet/Tests
- Integration
- Unit
- etl-adapter-http
- src/Flow/ETL/Adapter/Http
- DSL
- DynamicExtractor
- tests/Flow/ETL/Adapter/HTTP/Tests
- Integration
- Unit
- etl-adapter-json
- src/Flow/ETL/Adapter/JSON
- JSONMachine
- RowsNormalizer
- tests/Flow/ETL/Adapter/JSON/Tests
- Integration
- JSONMachine
- Unit
- etl-adapter-logger
- src/Flow/ETL/Adapter/Logger
- Logger
- tests/Flow/ETL/Adapter/Logger/Tests/Unit
- Logger
- etl-adapter-parquet
- src/Flow/ETL/Adapter/Parquet
- tests/Flow/ETL/Adapter/Parquet/Tests
- Integration
- Unit
- etl-adapter-postgresql
- src/Flow/ETL/Adapter/PostgreSql
- Exception
- LoaderOptions
- Pagination
- QueryBuilder
- ValueConverter
- tests/Flow/ETL/Adapter/PostgreSql/Tests
- Fixtures/Enum
- Integration
- Unit
- QueryBuilder
- ValueConverter
- etl-adapter-text
- src/Flow/ETL/Adapter/Text
- tests/Flow/ETL/Adapter/Text/Tests/Integration
- etl-adapter-xml
- src/Flow/ETL/Adapter/XML
- Abstraction
- Loader
- RowsNormalizer
- EntryNormalizer
- XMLWriter
- tests/Flow/ETL/Adapter/XML/Tests
- Integration
- Loader
- Unit
- RowsNormalizer
- EntryNormalizer
- PHPValueNormalizer
- XMLWriter
- bridge
- filesystem
- async-aws
- src/Flow/Filesystem/Bridge/AsyncAWS
- AsyncAWSS3DesintationStream
- AsyncAWSS3SourceStream
- DSL
- tests/Flow/Filesystem/Bridge/AsyncAWS/Tests
- Double
- Integration
- Unit
- azure
- src/Flow/Filesystem/Bridge/Azure
- AzureBlobDestinationStream
- DSL
- tests/Flow/Filesystem/Bridge/Azure/Tests
- Double
- Integration
- Unit
- monolog
- http
- src/Flow/Bridge/Monolog/Http
- Config
- DSL
- Exception
- Sanitization
- tests/Flow/Bridge/Monolog/Http/Tests/Unit
- Config
- Sanitization
- telemetry
- src/Flow/Bridge/Monolog/Telemetry
- DSL
- Exception
- tests/Flow/Bridge/Monolog/Telemetry/Tests
- Integration
- Unit
- openapi/specification
- src/Flow/Bridge/OpenAPI/Specification
- DSL
- Exception
- tests/Flow/Bridge/OpenAPI/Specification/Tests/Unit
- phpunit
- postgresql
- src/Flow/Bridge/PHPUnit/PostgreSQL
- DSL
- Subscriber
- tests/Flow/Bridge/PHPUnit/PostgreSQL/Tests
- Context
- Double
- Integration
- Unit
- Fixture
- telemetry
- src/Flow/Bridge/PHPUnit/Telemetry
- Subscriber
- tests/Flow/Bridge/PHPUnit/Telemetry/Tests
- Context
- Mother
- Unit
- Subscriber
- postgresql/valinor
- src/Flow/PostgreSql/Bridge/Valinor
- DSL
- tests/Flow/PostgreSql/Bridge/Valinor/Tests/Unit
- Fixture
- psr18/telemetry
- src/Flow/Bridge/Psr18/Telemetry
- DSL
- Exception
- tests/Flow/Bridge/Psr18/Telemetry/Tests
- Integration
- Unit
- psr3/telemetry
- src/Flow/Bridge/Psr3/Telemetry
- DSL
- Exception
- tests/Flow/Bridge/Psr3/Telemetry/Tests
- Integration
- Unit
- psr7/telemetry
- src/Flow/Bridge/Psr7/Telemetry
- DSL
- Exception
- tests/Flow/Bridge/Psr7/Telemetry/Tests
- Integration
- Unit
- symfony
- filesystem-bundle
- src/Flow/Bridge/Symfony/FilesystemBundle
- Attribute
- Command
- DependencyInjection/Compiler
- Exception
- Filesystem
- Factory
- Resources/config
- tests/Flow/Bridge/Symfony/FilesystemBundle/Tests
- Context
- Double
- Fixtures
- Integration
- Command
- Unit
- Attribute
- Command
- DependencyInjection/Compiler
- Filesystem
- Factory
- filesystem-cache
- src/Flow/Bridge/Symfony/FilesystemCache
- Exception
- tests/Flow/Bridge/Symfony/FilesystemCache/Tests
- Context
- Integration
- Unit
- Double
- http-foundation-telemetry
- src/Flow/Bridge/Symfony/HttpFoundationTelemetry
- DSL
- Exception
- tests/Flow/Bridge/Symfony/HttpFoundationTelemetry/Tests
- Integration
- Unit
- http-foundation
- src/Flow/Bridge/Symfony/HttpFoundation
- Output
- Response
- tests/Flow/Bridge/Symfony/HttpFoundation/Tests
- Integration
- Unit
- Output
- Response
- postgresql-bundle
- src/Flow/Bridge/Symfony/PostgreSqlBundle
- Attribute
- CatalogProvider
- Command
- DependencyInjection/Compiler
- Generator
- Messenger
- Repository
- Resources/config
- Sql
- tests/Flow/Bridge/Symfony/PostgreSqlBundle/Tests
- Context
- Double
- Fixtures
- Fixture/migrations
- 20260401120000_create_users
- 20260402100000_seed_data
- 20260403090000_add_column
- Integration
- Command
- Sql
- Unit
- CatalogProvider
- Command
- DependencyInjection
- Generator
- Messenger
- Repository
- postgresql-cache
- src/Flow/Bridge/Symfony/PostgreSQLCache
- Exception
- tests/Flow/Bridge/Symfony/PostgreSQLCache/Tests
- Context
- Integration
- Unit
- Double
- postgresql-messenger
- src/Flow/Bridge/Symfony/PostgreSQLMessenger
- Exception
- tests/Flow/Bridge/Symfony/PostgreSQLMessenger/Tests
- Integration
- Unit
- Double
- postgresql-session
- src/Flow/Bridge/Symfony/PostgreSQLSession
- Exception
- tests/Flow/Bridge/Symfony/PostgreSQLSession/Tests
- Context
- Integration
- Unit
- Double
- telemetry-bundle
- src/Flow/Bridge/Symfony/TelemetryBundle
- DependencyInjection
- Compiler
- Exception
- Instrumentation
- Cache
- Console
- Doctrine/DBAL
- V3
- V4
- HttpClient
- HttpKernel
- Messenger
- Twig
- Resources/config/instrumentation
- Resource/Detector
- tests/Flow/Bridge/Symfony/TelemetryBundle/Tests
- Context
- Fixtures
- Cache
- Command
- Controller
- HttpClient
- Logger
- MessageHandler
- Message
- Middleware
- Psr18
- config
- Integration
- Instrumentation
- Cache
- Console
- Doctrine/DBAL
- HttpClient
- HttpKernel
- Messenger
- Psr18
- Twig
- Unit
- DependencyInjection
- Instrumentation
- Cache
- Console
- Doctrine/DBAL
- V3
- HttpClient
- HttpKernel
- Messenger
- Twig
- Resource/Detector
- telemetry/otlp
- src
- Flow/Bridge/Telemetry/OTLP
- DSL
- Exporter
- Serializer
- Transport
- GPBMetadata/Opentelemetry/Proto
- Collector
- Logs/V1
- Metrics/V1
- Profiles/V1Development
- Trace/V1
- Common/V1
- Logs/V1
- Metrics/V1
- Profiles/V1Development
- Resource/V1
- Trace/V1
- Opentelemetry/Proto
- Collector
- Logs/V1
- Metrics/V1
- Profiles/V1development
- Trace/V1
- Common/V1
- Logs/V1
- Metrics/V1
- ExponentialHistogramDataPoint
- SummaryDataPoint
- Profiles/V1development
- Resource/V1
- Trace/V1
- Span
- Status
- tests/Flow/Bridge/Telemetry/OTLP/Tests
- Context
- Double
- Integration
- Unit
- DSL
- Exporter
- Serializer
- Transport
- cli
- src/Flow/CLI
- Arguments
- Command
- Traits
- DSL
- Factory
- Formatter
- Options
- Style
- tests/Flow/CLI/Tests
- Context
- Integration
- Fixtures
- Options
- Fixtures
- Unit/Options
- core/etl
- src/Flow
- ArrayComparison
- Calculator
- Exception
- Clock
- ETL
- Attribute
- Cache
- Implementation
- Config
- Cache
- Sort
- Telemetry
- Constraint
- UniqueConstraint
- DSL
- DataFrame
- Dataset
- Memory
- Statistics
- ErrorHandler
- Exception
- Execution
- Extractor
- SequenceGenerator
- Filesystem
- Formatter
- ASCII
- Function
- ArrayExpand
- ArraySort
- Between
- MatchCases
- ScalarFunction
- StyleConverter
- Hash
- Join
- Comparison
- Loader
- Memory
- Pipeline
- Optimizer
- Processor
- HashJoin
- Retry
- DelayFactory
- Fixed
- RetryStrategy
- Row
- Comparator
- Entry
- Formatter
- Schema
- Definition
- Formatter
- PHPFormatter
- Validator
- Sort
- ExternalSort
- BucketsCache
- String
- Time
- Transformation
- Transformer
- DropDuplicates
- OrderEntries
- Rename
- StyleConverter
- Serializer
- Exception
- tests/Flow
- ArrayComparison/Tests/Unit
- Calculator/Tests/Unit
- Clock
- ETL/Tests
- Double
- Fixtures
- Enum
- Integration
- Cache
- DataFrame
- Extractor
- Filesystem/FilesystemStreams
- NotPartitioned
- Partitioned
- Function
- Structure
- Loader
- Monitoring/Memory
- Pipeline
- Sort
- ExternalSort
- MemorySort
- Transformation
- Window
- Unit
- Cache/Implementation
- CaseConverter
- Config/Telemetry
- Constraint
- Dataset
- Memory
- Statistics
- Exception
- Execution
- Extractor
- Formatter
- ASCII
- Function
- Fixtures/CallUserFunc
- ScalarFunction
- Hash
- Join
- Comparison
- Loader
- Memory
- Pipeline
- Optimizer
- Processor
- HashJoin
- Retry
- DelayFactory
- RetryStrategy
- Rows
- Row
- Comparator
- Entry
- Schema
- Definition
- Formatter
- Fixtures
- PHPFormatter
- Time
- Transformation
- Transformer
- Rename
- ScalarFunctionTransformer
- Serializer/Tests/Unit
- extension
- arrow-ext/php/Flow/Arrow
- Parquet
- pg-query-ext/ext
- lib
- array-dot
- src/Flow/ArrayDot
- Exception
- tests/Flow/ArrayDot/Tests/Unit
- Fixtures
- azure-sdk
- src/Flow/Azure/SDK
- AuthorizationFactory
- BlobService
- BlockBlob
- CopyBlob
- CreateContainer
- DeleteBlob
- DeleteContainer
- GetBlobProperties
- GetBlob
- GetBlockBlobBlockList
- GetContainerProperties
- ListBlobs
- PutBlockBlobBlockList
- PutBlockBlobBlock
- PutBlockBlob
- URLFactory
- DSL
- Endpoints
- Exception
- Normalizer
- tests/Flow/Azure/SDK/Tests/Unit/BlobService/URLFactory
- doctrine-dbal-bulk
- src/Flow/Doctrine/Bulk
- Dialect
- Exception
- QueryFactory
- tests/Flow/Doctrine/Bulk/Tests
- Context
- Integration
- Unit
- dremel
- src/Flow/Dremel
- tests/Flow/Dremel/Tests
- Integration
- Unit
- filesystem
- src/Flow/Filesystem
- DSL
- Exception
- Local
- Memory
- StdOut
- StreamFilter
- Operations
- Path
- Filter
- Stream
- Block
- Telemetry
- tests/Flow/Filesystem/Tests
- Double
- Integration
- Local
- OS
- Unix
- Stream
- Windows
- Stream
- Stream
- Telemetry
- Mother
- Unit
- Operations
- Path
- Stream
- Telemetry
- parquet-viewer
- bin
- src/Flow/ParquetViewer
- Command
- tests/Flow/ParquetViewer/Tests/Integration
- parquet
- src
- Flow/Parquet
- BinaryReader
- BinaryWriter
- Binary
- Data
- Dremel
- ColumnData
- Statistics
- Validator
- Engine
- Arrow
- Exception
- ParquetFile
- Data
- Converter
- Page
- Header
- RowGroup
- Schema
- LogicalType
- Reader
- ThriftModel
- Thrift
- Writer
- ColumnChunkBuilder
- PageBuilder
- DictionaryBuilder
- ValueStorage
- tests/Flow/Parquet/Tests
- Integration
- Binary
- Data
- Engine
- IO
- ParquetFile
- Writer
- ColumnChunkBuilder
- PageBuilder
- Unit
- BinaryReader
- BinaryWriter
- Binary
- Data
- Dremel
- ColumnData
- Engine
- Arrow
- ParquetFile
- Data
- Converter
- Schema
- Thrift
- Writer
- ColumnChunkBuilder
- PageBuilder
- DictionaryBuilder
- postgresql/src/Flow/PostgreSql
- AST
- Nodes
- Exception
- Statement
- Transformers
- Visitors
- Client
- Exception
- Infrastructure/PgSql
- RowMapper
- Telemetry
- Types
- Converter
- DSL
- Exception
- Explain
- Analyzer
- Plan
- Extractors
- Migrations
- Exception
- Executor
- Generator
- Repository
- Store
- VersionGenerator
- Parser
- Protobuf
- AST
- Metadata
- QueryBuilder
- Bridge
- Clause
- Condition
- Copy
- Cursor
- Delete
- Exception
- Expression
- Factory
- Insert
- Listen
- Merge
- Notify
- Schema
- AlterSequence
- AlterTable
- Constraint
- CreateSequence
- CreateTableAs
- CreateTable
- Database
- Domain
- DropSequence
- DropTable
- Extension
- Function
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
70 | 70 | | |
71 | 71 | | |
72 | 72 | | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
73 | 76 | | |
74 | 77 | | |
75 | 78 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
45 | 45 | | |
46 | 46 | | |
47 | 47 | | |
48 | | - | |
| 48 | + | |
49 | 49 | | |
50 | 50 | | |
51 | 51 | | |
| |||
121 | 121 | | |
122 | 122 | | |
123 | 123 | | |
124 | | - | |
| 124 | + | |
125 | 125 | | |
126 | 126 | | |
127 | | - | |
| 127 | + | |
128 | 128 | | |
129 | 129 | | |
130 | 130 | | |
| |||
143 | 143 | | |
144 | 144 | | |
145 | 145 | | |
146 | | - | |
| 146 | + | |
147 | 147 | | |
148 | 148 | | |
149 | 149 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
36 | | - | |
| 36 | + | |
37 | 37 | | |
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
41 | | - | |
| 41 | + | |
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
91 | 91 | | |
92 | 92 | | |
93 | 93 | | |
94 | | - | |
| 94 | + | |
95 | 95 | | |
96 | 96 | | |
97 | 97 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
41 | | - | |
| 41 | + | |
42 | 42 | | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | 46 | | |
47 | | - | |
| 47 | + | |
48 | 48 | | |
49 | 49 | | |
50 | | - | |
| 50 | + | |
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
45 | | - | |
| 45 | + | |
46 | 46 | | |
47 | | - | |
| 47 | + | |
48 | 48 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
31 | | - | |
32 | 31 | | |
33 | 32 | | |
34 | | - | |
35 | | - | |
36 | | - | |
37 | | - | |
38 | | - | |
39 | | - | |
40 | | - | |
41 | | - | |
42 | 33 | | |
43 | 34 | | |
44 | 35 | | |
| |||
47 | 38 | | |
48 | 39 | | |
49 | 40 | | |
50 | | - | |
51 | | - | |
52 | | - | |
53 | | - | |
54 | | - | |
55 | | - | |
56 | | - | |
57 | | - | |
| 41 | + | |
| 42 | + | |
58 | 43 | | |
59 | | - | |
60 | | - | |
| 44 | + | |
| 45 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
120 | 120 | | |
121 | 121 | | |
122 | 122 | | |
123 | | - | |
| 123 | + | |
124 | 124 | | |
125 | 125 | | |
126 | 126 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
32 | 32 | | |
33 | 33 | | |
34 | 34 | | |
35 | | - | |
| 35 | + | |
36 | 36 | | |
37 | 37 | | |
38 | 38 | | |
| |||
This file was deleted.
0 commit comments