Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.internal | |
org.apache.flink.table.catalog | |
org.apache.flink.table.operations.ddl | |
org.apache.flink.table.resource |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironment.createFunction(String path,
String className,
List<ResourceUri> resourceUris)
Registers a
UserDefinedFunction class as a catalog function in the given path by the
specific class name and user defined resource uri. |
void |
TableEnvironment.createFunction(String path,
String className,
List<ResourceUri> resourceUris,
boolean ignoreIfExists)
Registers a
UserDefinedFunction class as a catalog function in the given path by the
specific class name and user defined resource uri. |
void |
TableEnvironment.createTemporaryFunction(String path,
String className,
List<ResourceUri> resourceUris)
Registers a
UserDefinedFunction class as a temporary catalog function in the given
path by the specific class name and user defined resource uri. |
void |
TableEnvironment.createTemporarySystemFunction(String name,
String className,
List<ResourceUri> resourceUris)
Registers a
UserDefinedFunction class as a temporary system function by the specific
class name and user defined resource uri. |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironmentImpl.createFunction(String path,
String className,
List<ResourceUri> resourceUris) |
void |
TableEnvironmentImpl.createFunction(String path,
String className,
List<ResourceUri> resourceUris,
boolean ignoreIfExists) |
void |
TableEnvironmentImpl.createTemporaryFunction(String path,
String className,
List<ResourceUri> resourceUris) |
void |
TableEnvironmentImpl.createTemporarySystemFunction(String name,
String className,
List<ResourceUri> resourceUris) |
Modifier and Type | Method and Description |
---|---|
List<ResourceUri> |
CatalogFunctionImpl.getFunctionResources() |
List<ResourceUri> |
FunctionCatalog.InlineCatalogFunction.getFunctionResources() |
List<ResourceUri> |
CatalogFunction.getFunctionResources()
Get a detailed resource description of the function.
|
Modifier and Type | Method and Description |
---|---|
void |
FunctionCatalog.registerCatalogFunction(UnresolvedIdentifier unresolvedIdentifier,
String className,
List<ResourceUri> resourceUris,
boolean ignoreIfExists) |
void |
FunctionCatalog.registerFunctionJarResources(String functionName,
List<ResourceUri> resourceUris) |
void |
FunctionCatalog.registerTemporarySystemFunction(String name,
String className,
List<ResourceUri> resourceUris)
Registers a temporary system function from resource uris.
|
Constructor and Description |
---|
CatalogFunctionImpl(String className,
FunctionLanguage functionLanguage,
List<ResourceUri> resourceUris) |
Constructor and Description |
---|
CreateTempSystemFunctionOperation(String functionName,
String functionClass,
boolean ignoreIfExists,
FunctionLanguage functionLanguage,
List<ResourceUri> resourceUris) |
Modifier and Type | Field and Description |
---|---|
protected Map<ResourceUri,URL> |
ResourceManager.resourceInfos |
Modifier and Type | Method and Description |
---|---|
Map<ResourceUri,URL> |
ResourceManager.getResources() |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManager.registerJarResources(List<ResourceUri> resourceUris)
Due to anyone of the resource in list maybe fail during register, so we should stage it
before actual register to guarantee transaction process.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.