Package org.apache.flink.cdc.common.factories

Class FactoryHelper.DefaultContext

java.lang.Object

org.apache.flink.cdc.common.factories.FactoryHelper.DefaultContext

All Implemented Interfaces:

Factory.Context

Enclosing class:

FactoryHelper

public static class FactoryHelper.DefaultContext
extends Object
implements Factory.Context

Default implementation of Factory.Context.

Constructor Summary

Constructors

Constructor	Description
DefaultContext(Configuration factoryConfiguration, Configuration pipelineConfiguration, ClassLoader classLoader)
DefaultContext(Configuration factoryConfiguration, Configuration pipelineConfiguration, ClassLoader classLoader, org.apache.flink.configuration.ReadableConfig flinkConf)

Method Summary

Modifier and Type	Method	Description
ClassLoader	getClassLoader()	Returns the class loader of the current session.
Configuration	getFactoryConfiguration()	Returns the factory options used to create the object instances.
org.apache.flink.configuration.ReadableConfig	getFlinkConf()	Returns the flink configuration of the current session.
Configuration	getPipelineConfiguration()	Returns the configuration of current pipeline.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultContext

public DefaultContext(Configuration factoryConfiguration,
                      Configuration pipelineConfiguration,
                      ClassLoader classLoader)

DefaultContext

public DefaultContext(Configuration factoryConfiguration,
                      Configuration pipelineConfiguration,
                      ClassLoader classLoader,
                      org.apache.flink.configuration.ReadableConfig flinkConf)

Method Detail

getFactoryConfiguration

public Configuration getFactoryConfiguration()

Description copied from interface: Factory.Context

Returns the factory options used to create the object instances.

Specified by:

getFactoryConfiguration in interface Factory.Context

Returns:

options of the current session.

getPipelineConfiguration

public Configuration getPipelineConfiguration()

Description copied from interface: Factory.Context

Returns the configuration of current pipeline.

Specified by:

getPipelineConfiguration in interface Factory.Context

getClassLoader

public ClassLoader getClassLoader()

Description copied from interface: Factory.Context

Returns the class loader of the current session.

The class loader is in particular useful for discovering factories.

Specified by:

getClassLoader in interface Factory.Context

getFlinkConf

public org.apache.flink.configuration.ReadableConfig getFlinkConf()

Description copied from interface: Factory.Context

Returns the flink configuration of the current session.

Specified by:

getFlinkConf in interface Factory.Context