Commit f3b3d11
authored
File tree
- .github/workflows
- 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
- etl-adapter-csv
- src/Flow/ETL/Adapter/CSV
- Detector
- RowsNormalizer
- tests/Flow/ETL/Adapter/CSV/Tests
- Integration
- Unit
- 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
- Integration
- ElasticsearchPHP
- Unit
- etl-adapter-excel
- src/Flow/ETL/Adapter/Excel
- DSL
- RowsNormalizer
- Sheet
- tests/Flow/ETL/Adapter/Excel/Tests/Integration
- etl-adapter-google-sheet
- src/Flow/ETL/Adapter/GoogleSheet
- tests/Flow/ETL/Adapter/GoogleSheet/Tests
- Unit
- etl-adapter-http
- src/Flow/ETL/Adapter/Http
- 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
- Pagination
- QueryBuilder
- ValueConverter
- tests/Flow/ETL/Adapter/PostgreSql/Tests
- Integration
- Unit
- 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
- bridge
- filesystem
- async-aws
- src/Flow/Filesystem/Bridge/AsyncAWS
- AsyncAWSS3DesintationStream
- AsyncAWSS3SourceStream
- tests/Flow/Filesystem/Bridge/AsyncAWS/Tests
- Double
- Integration
- Unit
- azure
- src/Flow/Filesystem/Bridge/Azure
- AzureBlobDestinationStream
- tests/Flow/Filesystem/Bridge/Azure/Tests
- Double
- Integration
- Unit
- monolog
- http
- src/Flow/Bridge/Monolog/Http
- Config
- Exception
- Sanitization
- tests/Flow/Bridge/Monolog/Http/Tests/Unit
- telemetry
- src/Flow/Bridge/Monolog/Telemetry
- Exception
- tests/Flow/Bridge/Monolog/Telemetry/Tests
- Integration
- Unit
- openapi/specification
- src/Flow/Bridge/OpenAPI/Specification
- Exception
- tests/Flow/Bridge/OpenAPI/Specification/Tests/Unit
- phpunit
- postgresql
- src/Flow/Bridge/PHPUnit/PostgreSQL
- Subscriber
- tests/Flow/Bridge/PHPUnit/PostgreSQL/Tests
- Context
- Double
- Integration
- Unit
- telemetry
- src/Flow/Bridge/PHPUnit/Telemetry
- Subscriber
- tests/Flow/Bridge/PHPUnit/Telemetry/Tests
- Context
- Unit
- postgresql/valinor/tests/Flow/PostgreSql/Bridge/Valinor/Tests/Unit
- Fixture
- psr18/telemetry
- src/Flow/Bridge/Psr18/Telemetry
- Exception
- tests/Flow/Bridge/Psr18/Telemetry/Tests/Unit
- psr3/telemetry
- src/Flow/Bridge/Psr3/Telemetry
- tests/Flow/Bridge/Psr3/Telemetry/Tests
- Integration
- Unit
- psr7/telemetry
- src/Flow/Bridge/Psr7/Telemetry/Exception
- tests/Flow/Bridge/Psr7/Telemetry/Tests/Integration
- symfony
- filesystem-bundle
- src/Flow/Bridge/Symfony/FilesystemBundle
- Attribute
- Command
- DependencyInjection/Compiler
- Exception
- Filesystem
- Factory
- 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/Exception
- http-foundation
- src/Flow/Bridge/Symfony/HttpFoundation
- Output
- Response
- tests/Flow/Bridge/Symfony/HttpFoundation/Tests
- Integration
- Unit/Response
- postgresql-bundle
- src/Flow/Bridge/Symfony/PostgreSqlBundle
- Attribute
- Command
- DependencyInjection/Compiler
- Messenger
- Repository
- Sql
- tests/Flow/Bridge/Symfony/PostgreSqlBundle/Tests
- Context
- Double
- Fixtures
- Integration
- Command
- Sql
- Unit
- 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
- tests/Flow/Bridge/Symfony/TelemetryBundle/Tests
- Context
- Fixtures
- Cache
- Controller
- HttpClient
- Logger
- Psr18
- Integration
- Instrumentation
- Cache
- Console
- Doctrine/DBAL
- HttpClient
- HttpKernel
- Messenger
- Psr18
- Twig
- Unit
- DependencyInjection
- Instrumentation
- Cache
- Console
- Doctrine/DBAL
- V3
- HttpClient
- Resource/Detector
- telemetry/otlp
- src/Flow/Bridge/Telemetry/OTLP
- Exporter
- Serializer
- Transport
- tests/Flow/Bridge/Telemetry/OTLP/Tests
- Context
- Double
- Integration
- Unit
- DSL
- Exporter
- Serializer
- Transport
- cli
- src/Flow/CLI
- Arguments
- Command
- Factory
- Formatter
- Options
- tests/Flow/CLI/Tests
- Context
- Integration
- core/etl
- src/Flow
- ArrayComparison
- Calculator
- Exception
- Clock
- ETL
- Attribute
- Cache/Implementation
- Config
- Cache
- Sort
- Telemetry
- Constraint
- DSL
- Dataset
- Memory
- Statistics
- ErrorHandler
- Exception
- Execution
- Extractor
- SequenceGenerator
- Filesystem
- Formatter/ASCII
- Function
- ArraySort
- StyleConverter
- Hash
- Join
- Comparison
- Loader
- Memory
- Pipeline
- Optimizer
- Processor
- HashJoin
- Retry
- DelayFactory
- RetryStrategy
- Row
- Entry
- Formatter
- Schema
- Definition
- Formatter
- PHPFormatter
- Sort
- ExternalSort
- BucketsCache
- String
- Time
- Transformer
- OrderEntries
- Rename
- StyleConverter
- Serializer
- tests/Flow
- ArrayComparison/Tests/Unit
- Calculator/Tests/Unit
- Clock
- ETL/Tests
- Double
- Fixtures
- Integration
- Cache
- DataFrame
- Extractor
- Filesystem/FilesystemStreams
- NotPartitioned
- Partitioned
- Function
- Monitoring/Memory
- Pipeline
- Sort
- ExternalSort
- MemorySort
- Window
- Unit
- Cache/Implementation
- Config/Telemetry
- Constraint
- Dataset/Statistics
- Execution
- Extractor
- Formatter/ASCII
- Function
- Fixtures/CallUserFunc
- Join/Comparison
- Loader
- Pipeline
- Retry
- DelayFactory
- RetryStrategy
- Row
- Entry
- Schema
- Definition
- Time
- Transformer
- Rename
- ScalarFunctionTransformer
- Serializer/Tests/Unit
- extension/arrow-ext/php/Flow/Arrow
- Parquet
- lib
- array-dot
- src/Flow/ArrayDot
- Exception
- tests/Flow/ArrayDot/Tests/Unit
- azure-sdk
- src/Flow/Azure/SDK
- AuthorizationFactory
- BlobService
- BlockBlob
- GetBlobProperties
- GetBlob
- ListBlobs
- PutBlockBlobBlockList
- URLFactory
- DSL
- Exception
- Normalizer
- tests/Flow/Azure/SDK/Tests
- Context
- Double
- Unit
- AuthorizationFactory
- BlobService/ListBlobs
- Normalizer
- doctrine-dbal-bulk
- src/Flow/Doctrine/Bulk
- Dialect
- Exception
- tests/Flow/Doctrine/Bulk/Tests
- Context
- Integration
- Unit
- dremel/src/Flow/Dremel
- filesystem
- src/Flow/Filesystem
- DSL
- Exception
- Local
- Memory
- StdOut
- StreamFilter
- Path
- Filter
- Stream
- Block
- Telemetry
- tests/Flow/Filesystem/Tests
- Double
- Integration
- Local
- OS
- Unix
- Stream
- Windows
- Stream
- Stream
- Telemetry
- Unit
- Operations
- Path
- Stream
- Telemetry
- parquet-viewer
- 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
- Thrift
- Writer
- ColumnChunkBuilder
- PageBuilder
- DictionaryBuilder
- ValueStorage
- tests/Flow/Parquet/Tests
- Integration
- Binary
- Data
- Engine
- IO
- ParquetFile
- Writer/PageBuilder
- Unit
- BinaryReader
- 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
- QueryBuilder
- Clause
- Condition
- Copy
- Cursor
- Delete
- Exception
- Expression
- Insert
- Merge
- Schema
- AlterSequence
- Constraint
- CreateSequence
- CreateTableAs
- CreateTable
- Database
- Domain
- DropSequence
- DropTable
- Extension
- Function
- Grant
- Index
- CreateIndex
- DropIndex
- Ownership
- Role
- Rule
- Schema
- Trigger
- Truncate
- Type
- View
- CreateMaterializedView
- CreateView
- DropMaterializedView
- DropView
- Select
- Table
- Transaction
- Update
- Utility
- Schema
- Constraint
- Diff
- Exception
- tests/Flow/PostgreSql
- Migrations/Tests
- Double
- Integration
- Unit
- Exception
- Executor
- Generator
- Repository
- Store
- VersionGenerator
- Tests
- Integration
- Client
- Telemetry
- Types/Converter
- QueryBuilder/Database
- Mother
- Unit
- AST
- Nodes
- Statement
- Transformers
- Visitors
- Client
- Exception
- RowMapper
- Telemetry
- Types
- Converter
- DSL
- Explain
- Analyzer
- Plan
- Extractors
- Parser
- QueryBuilder
- Clause
- Condition
- Copy
- Delete
- Expression
- Insert
- Listen
- Merge
- Notify
- Schema
- AlterSequence
- AlterTable
- Constraint
- CreateSequence
- CreateTableAs
- CreateTable
- Database
- Domain
- DropSequence
- DropTable
- Extension
- Grant
- Index
- Ownership
- Role
- Schema
- Session
- Trigger
- Truncate
- Type
- View
- Select
- Table
- Transaction
- Unlisten
- Update
- Utility
- Schema
- Diff
- snappy
- src/Flow/Snappy
- tests/Flow/Snappy/Tests
- Integration
- Unit
- telemetry
- src/Flow/Telemetry
- Context
- DSL
- ErrorHandler
- Exception
- Logger
- Processor
- Meter
- Exemplar
- Instrument
- Processor
- Propagation
- Provider
- Clock
- Console
- Memory
- Resource/Detector
- Signal
- Tracer
- Processor
- Sampler
- tests/Flow/Telemetry/Tests
- Integration
- ErrorHandler
- Logger
- Meter
- Telemetry
- Tracer
- Mother
- Unit
- Context
- DSL
- ErrorHandler
- Logger
- Processor
- Meter
- Exemplar
- Instrument
- Processor
- Propagation
- Provider
- Console
- Memory
- Void
- Resource/Detector
- Tracer
- Processor
- Sampler
- types
- src/Flow/Types
- DSL
- Exception
- Type
- Logical
- XML
- Native
- String
- Value
- tests/Flow/Types/Tests/Unit/Type
- Fixtures
- Logical
- Native
- TypeDetector
- tools/documentation
- src/Flow/Documentation
- Models
- tests/Flow/Documentation/Tests/Integration
- tools
- box
- infection
- mago
- phpdocumentor
- web/landing
- resources
- src/Flow/Website
- Blog
- Command
- Controller
- EventListener
- Factory/Github
- Model/Documentation
- Service
- Documentation
- Manifest
- Markdown
- StaticSourceProvider
- Twig
- tests/Flow/Website/Tests
- Functional
- Integration
- Command
- Unit/Service/Manifest
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 | |
|---|---|---|---|
| |||
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
41 | 44 | | |
42 | 45 | | |
43 | 46 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
49 | 49 | | |
50 | 50 | | |
51 | 51 | | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
52 | 65 | | |
53 | 66 | | |
54 | 67 | | |
| |||
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
0 commit comments