Package | Description |
---|---|
org.apache.flink.table.catalog | |
org.apache.flink.table.operations.ddl | |
org.apache.flink.table.resource |
Modifier and Type | Method and Description |
---|---|
List<ResourceUri> |
FunctionCatalog.InlineCatalogFunction.getFunctionResources() |
List<ResourceUri> |
CatalogFunctionImpl.getFunctionResources() |
List<ResourceUri> |
CatalogFunction.getFunctionResources()
Get a detailed resource description of the function.
|
Modifier and Type | Method and Description |
---|---|
void |
FunctionCatalog.registerFunctionJarResources(String functionName,
List<ResourceUri> resourceUris) |
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–2024 The Apache Software Foundation. All rights reserved.