apache / apache/iotdb-extras

[Feature request] Python example for IOTDB sink from apache-flink

Open
#97 1 comment 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
33
Forks
29
Avg merge
1d 3h
Merged PRs (30d)
5

Description

### Search before asking

- [x] I searched in the [issues](https://github.com/apache/iotdb/issues) and found nothing similar.

### Motivation

Is there an example to send data to IoTDB using flink with it's official python package that is PyFlink [apache-flink](https://pypi.org/project/apache-flink/). Tried to use the flink-connector jars but could not do it. My flink version is 2.1.0 and IoTdb version is 2.0.4.

### Solution

Integration of python function in [apache-iotdb](https://pypi.org/project/apache-iotdb/) from flink to iotdb.

### Alternatives

_No response_

### Are you willing to submit a PR?

- [ ] I'm willing to submit a PR!

Contributor guide

No contributing guide indexed for this repository

Research direction

No repository file or test is named. Review existing IoTDB connector examples alongside the official PyFlink and apache-iotdb package documentation, using Flink 2.1.0 and IoTDB 2.0.4 as the compatibility targets. Done means a documented, runnable Python example that sends data from Flink to IoTDB.

Written by the indexing model from the issue text.

Assessment

Tech stack
python
Domain
data-engineering, databases
Issue type
Feature
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.