MCPcopy Index your code
hub / github.com/factorhouse/examples

github.com/factorhouse/examples @v1.0

Chat with this repo
repository ↗ · DeepWiki ↗ · release v1.0 ↗ · + Follow
58 symbols 199 edges 28 files 7 documented · 12%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

factorhouse

Product Feature

Integration

Factor House Local

Looking for local development environment? Check out Factor House Local.

It provides a collection of pre-configured Docker Compose environments that demonstrate modern data platform architectures. Each setup is purpose-built around a specific use case and incorporates widely adopted technologies such as Kafka, Flink, Spark, Iceberg, and Pinot. These environments are further enhanced by enterprise-grade tools from Factor House: Kpow, for Kafka management and control, and Flex, for seamless integration with Flink.

Factor House Local Labs

The Factor House Local labs provide a fast and practical entry point for developers building real-time data pipelines using Kafka, Flink, Spark, Iceberg, and Pinot. These hands-on labs highlight key capabilities such as Avro serialization with Schema Registry, stream processing with Kafka Streams and Flink (via SQL and DataStream APIs), connector deployment with Kpow, modern lakehouse integrations using Iceberg, and real-time analytics with Pinot. Each lab is designed to be modular, hands-on, and production-inspired - making it easy to learn, prototype, and extend.

Visit the Labs to explore detailed walkthroughs, configuration examples, and practical exercises that will help you get up and running quickly with each tool in a real-world context.

Support

Any issues? Contact support or view our docs.

License

This repository is released under the Apache 2.0 License.

Copyright © Factor House.

Core symbols most depended-on inside this repo

apply
called by 7
fh-local-labs/lab-05/src/main/kotlin/io/factorhouse/demo/flink/SupplierStatsFunction.kt
create
called by 5
fh-local-labs/lab-01/model.py
schema_str
called by 4
fh-local-labs/lab-01/model.py
execute_statement
called by 2
fh-local-labs/lab-11/flink_sql_runner.py
create_item
called by 2
fh-local-labs/lab-01/model.py
from_dict
called by 2
fh-local-labs/lab-01/model.py
_make_schema
called by 2
fh-local-labs/lab-01/model.py
topic_exists
called by 1
features/offset-management/producer.py

Shape

Function 28
Method 18
Class 12

Languages

Python59%
Kotlin41%

Modules by API surface

fh-local-labs/lab-01/model.py11 symbols
fh-local-labs/lab-11/flink_sql_runner.py7 symbols
fh-local-labs/lab-05/src/main/kotlin/io/factorhouse/demo/flink/SupplierStatsAggregator.kt6 symbols
fh-local-labs/lab-12/query_supplier_stats.py4 symbols
fh-local-labs/lab-12/register_pinot_configs.py3 symbols
features/offset-management/producer.py3 symbols
fh-local-labs/lab-10/kafka_to_iceberg.py2 symbols
fh-local-labs/lab-08/src/main/kotlin/io/factorhouse/demo/TableApp.kt2 symbols
fh-local-labs/lab-05/src/main/kotlin/io/factorhouse/demo/kafka/Utils.kt2 symbols
fh-local-labs/lab-05/src/main/kotlin/io/factorhouse/demo/kafka/Connectors.kt2 symbols
fh-local-labs/lab-05/src/main/kotlin/io/factorhouse/demo/flink/SupplierStatsFunction.kt2 symbols
fh-local-labs/lab-05/src/main/kotlin/io/factorhouse/demo/DataStreamApp.kt2 symbols

For agents

$ claude mcp add examples \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact