Hi Devs
 
I would like to start the formal discussion about FLINK-16648. 

StreamQueryConfig is deprecated and replaced by TableConfig in the future, and 
TableEnvironment class has config object.

Do we need to delete the interfaces in StreamTableEnvironment and 
StreamTableEnvironmentImpl:
toAppendStream(Table table, Class<T> clazz, StreamQueryConfig queryConfig);
toAppendStream(Table table, TypeInformation<T> typeInfo, StreamQueryConfig 
queryConfig);
toRetractStream(Table table, Class<T> clazz, StreamQueryConfig queryConfig);
toRetractStream(Table table, TypeInformation<T> typeInfo, StreamQueryConfig 
queryConfig);
void sqlUpdate(String stmt, StreamQueryConfig config);
void insertInto(Table table, StreamQueryConfig queryConfig, String sinkPath, 
String... sinkPathContinued);


Best Regards

jinhai...@gmail.com

Reply via email to