About Fleak ZephFlow
ZephFlow is a lightweight, embeddable data processing engine that runs DAG-based transformation pipelines in JVM applications, Docker containers, or as an HTTP API service.
Quick Start Guide
Get started with ZephFlow in three ways: embed it in JVM applications, run as a standalone Docker container, or deploy as an HTTP API service for distributed data pipeline processing.
ZephFlow Nodes
3 items
Understanding Data Flows in ZephFlow
ZephFlow uses Directed Acyclic Graphs to define data processing logic, with support for branching, merging, and complex multi-step transformations from source to sink.
Fleak Eval Expression Language (FEEL) Reference
FEEL is a flexible expression language for ZephFlow data transformations, supporting rich data manipulation, path selection, and extensive functions for filtering, mapping, and validation.
Fleak SQL Language Reference
Fleak SQL is a PostgreSQL-compatible SQL dialect with extended support for JSON operations, log parsing, and nested data structures in ZephFlow transformation pipelines.
Supported Encodings
ZephFlow supports multiple encoding types (CSV, JSON, XML, Parquet) to serialize and deserialize data when interacting with external systems like Kafka, S3, and Kinesis.
Error Handling
ZephFlow provides robust error handling with Dead Letter Queue support (S3 and GCS) for capturing and analyzing failed records, ensuring data integrity throughout transformation pipelines.
Tutorials
1 item