This project provides example programs for key FeatHub APIs and functionalities.

• Flink - DerivedFeatureView
• Flink - SlidingFeatureView
• Flink - SqlFeatureView
• Flink - Join Stream from FileSystem with table from Redis
• Flink - Join stream from Kafka with table from FileSystem
• Flink - Read and Write HDFS
• Flink - Read and Write Hive
• Flink - Read and Write MySQL
• Flink - Read and Write Redis
• Flink - Report metrics to Prometheus
• Flink - Sequential Recommendation
• Flink - Kubernetes Application
• Flink - Yarn Application
• Flink - Fault Tolerance
• Spark - DerivedFeatureView

This project uses Black to format Python code, flake8 to check Python code style, and mypy to check type annotation.

Run the following command to format codes, check code style, and check type annotation before uploading PRs for review.

# Format python code
$ python -m black .

# Check python code style
$ python -m flake8 --config=setup.cfg .

# Check python type annotation
$ python -m mypy --config-file setup.cfg .

Chinese-speaking users are recommended to join the following DingTalk group for FeatHub-related questions and discussion.

English-speaking users can use this invitation link to join our Slack channel for questions and discussion.

We are actively looking for user feedback and contributors from the community. Please feel free to create pull requests and open Github issues for feedback and feature requests.

Come join us!