public class ExecutionContext extends Object
Constructor and Description |
---|
ExecutionContext(Configuration flinkConfig,
MutableURLClassLoader classLoader,
SessionContext.SessionState sessionState) |
ExecutionContext(ExecutionContext context)
Create a new
ExecutionContext . |
Modifier and Type | Method and Description |
---|---|
StreamTableEnvironment |
getTableEnvironment() |
<R> R |
wrapClassLoader(java.util.function.Supplier<R> supplier)
Executes the given supplier using the execution context's classloader as thread classloader.
|
public ExecutionContext(Configuration flinkConfig, MutableURLClassLoader classLoader, SessionContext.SessionState sessionState)
public ExecutionContext(ExecutionContext context)
ExecutionContext
.
It just copies from the ExecutionContext
and rebuild a new TableEnvironment
.
public StreamTableEnvironment getTableEnvironment()
public <R> R wrapClassLoader(java.util.function.Supplier<R> supplier)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.