Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.internal | |
org.apache.flink.table.delegation |
Modifier and Type | Class and Description |
---|---|
static class |
PlanReference.ContentPlanReference
Plan reference to a string containing the serialized persisted plan in JSON.
|
static class |
PlanReference.FilePlanReference
Plan reference to a file in the local filesystem.
|
static class |
PlanReference.ResourcePlanReference
Plan reference to a file in the provided
ClassLoader . |
Modifier and Type | Method and Description |
---|---|
static PlanReference |
PlanReference.fromFile(File file)
Create a reference starting from a file path.
|
static PlanReference |
PlanReference.fromFile(Path path) |
static PlanReference |
PlanReference.fromFile(String path) |
static PlanReference |
PlanReference.fromJsonString(String jsonString)
Create a reference starting from a JSON string.
|
static PlanReference |
PlanReference.fromResource(ClassLoader classLoader,
String resourcePath)
Create a reference from a file in the classpath.
|
static PlanReference |
PlanReference.fromResource(String resourcePath)
Create a reference from a file in the classpath, using
Thread.currentThread().getContextClassLoader() as ClassLoader . |
Modifier and Type | Method and Description |
---|---|
default TableResult |
TableEnvironment.executePlan(PlanReference planReference)
Shorthand for
tEnv.loadPlan(planReference).execute() . |
CompiledPlan |
TableEnvironment.loadPlan(PlanReference planReference)
Loads a plan from a
PlanReference into a CompiledPlan . |
Modifier and Type | Method and Description |
---|---|
CompiledPlan |
TableEnvironmentImpl.loadPlan(PlanReference planReference) |
Modifier and Type | Method and Description |
---|---|
InternalPlan |
Planner.loadPlan(PlanReference planReference) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.