This project is an extension and update of the [XGBoost//github.com/dmlc/xgboost) library. Thids extension deals only with the Flink connectors in the JVM package for scala langauge. The main purpose of this project is the implementaion of Flink XGBoost over the streaming API which follows the needs of the Flink community.
The existing minimal Flink batch implementation is extended by more easy-to-use function and some new feature. There is implemented the XGBoost connector over the streaming API.
The flink version is updated.
The Flink implementation: XGBoost4J-Flink
There are some examples for usage here: XGBoost4J Code Examples
An example application for streaming and batch usage of this extension: https://github.com/streamline-eu/xgboost-application