Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.internal | |
org.apache.flink.table.factories | |
org.apache.flink.table.module | |
org.apache.flink.table.module.hive |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironment.loadModule(String moduleName,
Module module)
Loads a
Module under a unique name. |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironmentImpl.loadModule(String moduleName,
Module module) |
Modifier and Type | Method and Description |
---|---|
default Module |
ModuleFactory.createModule(Map<String,String> properties)
Deprecated.
Use
ModuleFactory.createModule(Context) instead and implement Factory instead
of TableFactory . |
default Module |
ModuleFactory.createModule(ModuleFactory.Context context)
Creates and configures a
Module . |
static Module |
FactoryUtil.createModule(String moduleName,
Map<String,String> options,
ReadableConfig configuration,
ClassLoader classLoader)
Discovers a matching module factory and creates an instance of it.
|
Modifier and Type | Class and Description |
---|---|
class |
CoreModule
Module of default core metadata in Flink.
|
Modifier and Type | Method and Description |
---|---|
Module |
CoreModuleFactory.createModule(ModuleFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
ModuleManager.loadModule(String name,
Module module)
Load a module under a unique name.
|
Modifier and Type | Method and Description |
---|---|
<T extends Factory> |
ModuleManager.getFactory(java.util.function.Function<Module,Optional<T>> selector)
Returns the first factory found in the loaded modules given a selector.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveModule
Module to provide Hive built-in metadata.
|
Modifier and Type | Method and Description |
---|---|
Module |
HiveModuleFactory.createModule(ModuleFactory.Context context) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.