Package io.github.flink.gcp.connector.base.source

Class ReaderInitializationContext

java.lang.Object

io.github.flink.gcp.connector.base.source.ReaderInitializationContext

All Implemented Interfaces:

org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext

@Internal
public final class ReaderInitializationContext
extends Object
implements org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext

Adapts a SourceReaderContext to the context a DeserializationSchema expects when a source opens it.

Flink offers no adapter of its own, so every FLIP-27 source that opens a deserialization schema needs one. This repository ships a base module, so the connectors share this one rather than each carrying a private copy of the same two delegations.

Constructor Summary

Constructors

Constructor	Description
ReaderInitializationContext(org.apache.flink.api.connector.source.SourceReaderContext context)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.metrics.MetricGroup	getMetricGroup()
org.apache.flink.util.UserCodeClassLoader	getUserCodeClassLoader()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReaderInitializationContext

public ReaderInitializationContext(org.apache.flink.api.connector.source.SourceReaderContext context)

Method Details

getMetricGroup

public org.apache.flink.metrics.MetricGroup getMetricGroup()

Specified by:

getMetricGroup in interface org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext

getUserCodeClassLoader

public org.apache.flink.util.UserCodeClassLoader getUserCodeClassLoader()

Specified by:

getUserCodeClassLoader in interface org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext