Pinned Repositories
airflow
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
flink
Apache Flink
skaffold
Easy and Repeatable Kubernetes Development
marquez
Collect, aggregate, and visualize a data ecosystem's metadata
airflow
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
astronomer-providers
Airflow Providers containing Deferrable Operators & Sensors from Astronomer
bugged-snowflake
celery
Distributed Task Queue (development branch)
flink
Apache Flink
OpenLineage
An Open Standard for lineage metadata collection
mobuchowski's Repositories
mobuchowski/airflow
Apache Airflow - A platform to programmatically author, schedule, and monitor workflows
mobuchowski/astronomer-providers
Airflow Providers containing Deferrable Operators & Sensors from Astronomer
mobuchowski/bugged-snowflake
mobuchowski/celery
Distributed Task Queue (development branch)
mobuchowski/flink
Apache Flink
mobuchowski/flink-tutorial
mobuchowski/flink-tutorial-1
mobuchowski/great_expectations
Always know what to expect from your data.
mobuchowski/jnp3
mobuchowski/kafka-connect-jdbc
Kafka Connect connector for JDBC-compatible databases
mobuchowski/marquez
Collect, aggregate, and visualize a data ecosystem's metadata
mobuchowski/OpenLineage
mobuchowski/openlineage-aggregator
Aggregator for OpenLineage events
mobuchowski/spark-sql-flow-plugin
Visualize column-level data lineage in Spark SQL
mobuchowski/sqllineage
mobuchowski/sqlparser-rs
Extensible SQL Lexer and Parser for Rust
mobuchowski/xdelta3-python
Fast delta encoding in python using xdelta3