THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
/** A context to provide necessary context used by stored procedure. */ @PublicEvolving public interface ProcedureContext { /** Return the StreamExecutionEnvironment where the procedure is called. */ StreamExecutionEnvironment getExecutionEnvironment(); } |
Note: To avoid exposing to much to early to devs, we only put StreamExecutionEnvironment to the ProcedureContext currently since it's the most needed for stored procedure. If we find we stored procedure will need other things, we put add it to the ProcedureContext in the future.
then, we propose a new interface Procedure
for stored procedure. The stored procedure providers are expected to implement Procedure
to define their own procedure.
...