Registry / networking / flink-connector-base

flink-connector-base

library2.2.1javamavenunverified

Base classes and utilities for building Apache Flink connectors to external systems.

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-connector-base</artifactId>
  <version>2.2.1</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · FLINK-CONNECTOR-BA

flink-connector-base

networkingjavav2.2.1

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.

RecordEmitter

✓ org.apache.flink.connector.base.source.reader.RecordEmitter

Implements a RecordEmitter to process source records in a Flink connector.

import org.apache.flink.connector.base.source.reader.RecordEmitter; import org.apache.flink.api.connector.source.SourceOutput; RecordEmitter<String, Integer> emitter = (element, output, state) -> { output.collect(element.length()); };

Debug

Known issues

No known issues recorded.

Upgrade

Version history

2.2.1latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

5 hits · last 30 days

node

OpenAI (training)

Resources

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

homepagehttps://flink.apache.org ↗

docshttps://appdoc.app/artifact/org.apache.flink/flink-connector-base/ ↗