This Jira has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems email email@example.com
Api will looks like:
DataStream[(String, Long, Int)] input = ???
// upsert with keyTable
table = tEnv.upsertFromStream(input, 'a, 'b, 'c.key)
// upsert without key -> single row tableTable
table = tEnv.upsertFromStream(input, 'a, 'b, 'c)
A simple design doc about this subtask.
GitHub Pull Request #6787