GuidesChangelogData Inspector Library API Reference
Guides

Dependencies for stream pipelines

Dependencies for stream pipelines

To run an application that uses the Data Client Library within a stream pipeline (Flink), use the flink-support module as a dependency to your project.

Add the flink-support module as a dependency

The flink-support module is only released as a fat JAR containing all Data Library modules and some shared libraries. This is required to avoid conflicts with flakka (the Flink custom build of the Pekko library), which is incompatible with the Pekko version that Data Client Library is using.

Note

flink-support
The module flink-support is only compatible with Flink 2.2.0

To add the flink-support module to your project, add the following dependencies.

Note

flink-support dependencies
Note that

  • if you use Maven, the version of flink-support_2.13 should not be hard-coded but rather come from sdk pom.
  • if you use sbt, the version of flink-support_2.13 needs to be hard-coded.
    <dependencies>
        <dependency>
            <groupId>com.here.platform.data.client</groupId>
            <artifactId>flink-support_2.13</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-clients</artifactId>
            <version>2.2.0</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-table-planner</artifactId>
            <version>2.2.0</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>
      libraryDependencies ++=
        Seq(
          "com.here.platform.data.client" %% "flink-support" % "1.22.33",
          "org.apache.flink" % "flink-clients" % "2.2.0" % "provided",
          "org.apache.flink" % "flink-table-planner" % "2.2.0" % "provided"
        )