Skip to content
FastFlowTransform – SQL & Python data transformation framework
fastflowtransform.streaming
Initializing search
MirrorsAndMisdirections/FastFlowTransform
FastFlowTransform – SQL & Python data transformation framework
MirrorsAndMisdirections/FastFlowTransform
Home
Quickstart
Technical Overview
API & Models
Configuration & Macros
Contracts
Cache & Parallelism
Incremental Processing
Profiles & Environments
Sources Declaration
Project Configuration
State Selection
YAML Tests
Data Quality Tests
Source Freshness
CLI Guide
Auto Docs
Logging
Unit Tests
Snapshots
CI Checks & Change-Aware Runs
Cost Monitoring
Hooks
Packages
Troubleshooting
Examples
Examples
Basic Demo
Materializations Demo
Environment Matrix
Data Quality Tests Demo
Macros Demo
Cache Demo
Incremental Demo
API Demo
Local Engine Setup
Snapshot Demo
Hooks Demo
Packages Demo
API Reference
API Reference
Overview
fastflowtransform._version
api
api
fastflowtransform.api
fastflowtransform.api.context
fastflowtransform.api.http
fastflowtransform.api.rate_limit
fastflowtransform.artifacts
fastflowtransform.cache
ci
ci
fastflowtransform.ci
fastflowtransform.ci.changed_since
fastflowtransform.ci.core
fastflowtransform.ci.sarif
cli
cli
fastflowtransform.cli
fastflowtransform.cli.main
fastflowtransform.cli.bootstrap
fastflowtransform.cli.ci_cmd
fastflowtransform.cli.dag_cmd
fastflowtransform.cli.deps_cmd
fastflowtransform.cli.docgen_cmd
fastflowtransform.cli.docs_cmd
fastflowtransform.cli.docs_utils
fastflowtransform.cli.init_cmd
fastflowtransform.cli.logging_utils
fastflowtransform.cli.options
fastflowtransform.cli.run
fastflowtransform.cli.seed_cmd
fastflowtransform.cli.selectors
fastflowtransform.cli.snapshot_cmd
fastflowtransform.cli.source_cmd
fastflowtransform.cli.sync_db_comments_cmd
fastflowtransform.cli.test_cmd
fastflowtransform.cli.utest_cmd
config
config
fastflowtransform.config
fastflowtransform.config.budgets
fastflowtransform.config.contracts
fastflowtransform.config.loaders
fastflowtransform.config.models
fastflowtransform.config.packages
fastflowtransform.config.project
fastflowtransform.config.seeds
fastflowtransform.config.sources
contracts
contracts
fastflowtransform.contracts
fastflowtransform.contracts.core
fastflowtransform.contracts.runtime
fastflowtransform.contracts.runtime.base
fastflowtransform.contracts.runtime.bigquery
fastflowtransform.contracts.runtime.databricks_spark
fastflowtransform.contracts.runtime.duckdb
fastflowtransform.contracts.runtime.postgres
fastflowtransform.contracts.runtime.snowflake_snowpark
fastflowtransform.core
fastflowtransform.dag
fastflowtransform.decorators
fastflowtransform.docs
fastflowtransform.errors
executors
executors
fastflowtransform.executors
fastflowtransform.executors._query_stats_adapter
fastflowtransform.executors._spark_imports
fastflowtransform.executors._sql_identifier
fastflowtransform.executors._test_utils
fastflowtransform.executors.base
fastflowtransform.executors.bigquery
fastflowtransform.executors.bigquery.base
fastflowtransform.executors.bigquery.bigframes
fastflowtransform.executors.bigquery.pandas
fastflowtransform.executors.budget
fastflowtransform.executors.budget.core
fastflowtransform.executors.budget.runtime
fastflowtransform.executors.budget.runtime.base
fastflowtransform.executors.budget.runtime.bigquery
fastflowtransform.executors.budget.runtime.databricks_spark
fastflowtransform.executors.budget.runtime.duckdb
fastflowtransform.executors.budget.runtime.postgres
fastflowtransform.executors.budget.runtime.snowflake_snowpark
fastflowtransform.executors.common
fastflowtransform.executors.databricks_spark
fastflowtransform.executors.duckdb
fastflowtransform.executors.postgres
fastflowtransform.executors.query_stats
fastflowtransform.executors.query_stats.core
fastflowtransform.executors.query_stats.runtime
fastflowtransform.executors.query_stats.runtime.base
fastflowtransform.executors.query_stats.runtime.bigquery
fastflowtransform.executors.query_stats.runtime.databricks_spark
fastflowtransform.executors.query_stats.runtime.duckdb
fastflowtransform.executors.query_stats.runtime.postgres
fastflowtransform.executors.query_stats.runtime.snowflake_snowpark
fastflowtransform.executors.snowflake_snowpark
fastflowtransform
fastflowtransform.fingerprint
hooks
hooks
fastflowtransform.hooks
fastflowtransform.hooks.registry
fastflowtransform.hooks.types
fastflowtransform.incremental
fastflowtransform.lineage
fastflowtransform.log_queue
fastflowtransform.logging
fastflowtransform.meta
fastflowtransform.packages
fastflowtransform.run_executor
fastflowtransform.schema_loader
fastflowtransform.seeding
fastflowtransform.settings
snapshots
snapshots
fastflowtransform.snapshots
fastflowtransform.snapshots.core
fastflowtransform.snapshots.runtime
fastflowtransform.snapshots.runtime.base
fastflowtransform.snapshots.runtime.bigquery
fastflowtransform.snapshots.runtime.databricks_spark
fastflowtransform.snapshots.runtime.duckdb
fastflowtransform.snapshots.runtime.postgres
fastflowtransform.snapshots.runtime.snowflake_snowpark
fastflowtransform.source_freshness
stdlib
stdlib
fastflowtransform.stdlib
fastflowtransform.stdlib.casts
fastflowtransform.stdlib.dates
fastflowtransform.stdlib.engine
fastflowtransform.stdlib.partitions
fastflowtransform.stdlib.sql
fastflowtransform.storage
fastflowtransform.streaming
fastflowtransform.streaming
Table of contents
streaming
table_formats
table_formats
fastflowtransform.table_formats
fastflowtransform.table_formats.base
fastflowtransform.table_formats.spark_default
fastflowtransform.table_formats.spark_delta
fastflowtransform.table_formats.spark_hudi
fastflowtransform.table_formats.spark_iceberg
testing
testing
fastflowtransform.testing
fastflowtransform.testing.base
fastflowtransform.testing.discovery
fastflowtransform.testing.registry
fastflowtransform.typing
fastflowtransform.utest
utils
utils
fastflowtransform.utils
fastflowtransform.utils.timefmt
fastflowtransform.validation
Contributing
License
Table of contents
streaming
fastflowtransform.streaming
¶
Back to top