Package org.apache.flink.table.procedure
Interface ProcedureContext
-
- All Known Implementing Classes:
DefaultProcedureContext
@PublicEvolving public interface ProcedureContext
A context to provide necessary context used by stored procedure.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamExecutionEnvironment
getExecutionEnvironment()
Return theStreamExecutionEnvironment
where the procedure is called.
-
-
-
Method Detail
-
getExecutionEnvironment
StreamExecutionEnvironment getExecutionEnvironment()
Return theStreamExecutionEnvironment
where the procedure is called. Flink will create a newStreamExecutionEnvironment
based on the current configuration and pass it to the procedure for every procedure call. The procedure can modify the passed StreamExecutionEnvironment safely inside as it won't be leaked outside.
-
-