Can you show us where you found the suggestion to use iterate()?
On 20/02/2020 02:08, Fanbin Bu wrote:
Hi,
My app creates the source from JDBC inputformat and running some sql
and print out. But the source terminates itself after the query is
done. Is there anyway to keep the source running?
samle code:
val env = StreamExecutionEnvironment.getExecutionEnvironment
val settings = EnvironmentSettings.newInstance()
.useBlinkPlanner()
.inStreamingMode()
.build()
val tEnv = StreamTableEnvironment.create(env, settings)
val inputFormat
= JDBCInputFormat.buildJDBCInputFormat.setQuery("select * from
table")... .finish()
val source = env.createInput(inputFormat)
tEnv.registerTableSource(source)
val queryResult = tEnv.sqlQuery("select * from awesomeSource")
queryResult.insertInto(mySink)
I searched around and its suggested to use .iterate(). can somebody
give more examples on how to use it in this case?
Thanks,
Fanbin
