semvec/pypi-packages huggingface dataset:
rlink 0.1.5.dev0
rlink: run flink cluster on ray

# Rlink
Rlink brings popular big data frameworks including [Apache Flink](https://github.com/apache/flink) to [Ray](https://github.com/ray-project/ray/) ecosystem and integrates with other Ray libraries seamlessly. Rlink makes it simple to build distributed end-to-end data analytics and AI pipeline on Ray by using Flink for data preprocessing, RayTune for hyperparameter tunning, RaySGD for distributed deep learning, RLlib for reinforcement learning and RayServe for model serving.

```python
import rlink

# start a flink cluster on ray
envs = rlink.init_flink()

# execute sql
senv = envs.get_stream_table_env()
senv.execute_sql("create table t1 (day_date date) with ('connector' = 'print')")
senv.execute_sql("insert into t1 select CURRENT_DATE")
```