Registry / other / flink-table-common

flink-table-common

library2.2.0javamavenunverified

This module contains extension points of the Table/SQL API, allowing implementation of user-defined functions, custom formats, and more with minimal dependencies.

other

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-table-common</artifactId>
  <version>2.2.0</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · FLINK-TABLE-COMMON

flink-table-common

otherjavav2.2.0

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

TableEnvironment

✓ org.apache.flink.table.api.TableEnvironment

Minimal example showing how to create a TableEnvironment for streaming mode.

import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.TableEnvironment; public class Quickstart { public static void main(String[] args) { EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().build(); TableEnvironment tableEnv = TableEnvironment.create(settings); System.out.println("Table environment created: " + tableEnv); } }

Debug

Known issues

breakingFlink Table API has breaking changes between major versions (e.g., 1.x to 2.x). Ensure compatibility with your Flink cluster version.

fix

Check the Flink version compatibility matrix and update your code accordingly when upgrading.

affects: >=2.0.0

Upgrade

Version history

2.2.0latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

2 hits · last 30 days

node

Resources

githubhttps://github.com/apache/flink ↗

homepagehttps://flink.apache.org ↗

docshttps://appdoc.app/artifact/org.apache.flink/flink-table-common/ ↗