Versions Compared

Old Version 8

changes.mady.by.user Timo Walther

Saved on

compared with

New Version 9

changes.mady.by.user Aljoscha Krettek

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.


 

Status

Current state: "Accepted"

...

JIRA:

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-7594

Released:  -1.5

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

The supported materialization mode also depends on the query type:


 

Query Type

Internal Mode

External Mode*

Batch

collect() -> Heap/Database

File table sink

Append Stream

collect() -> Heap/Database

Kafka/file table sink

Retract/Upsert Stream

collect() -> Heap/Database

(Compacted Kafka)/Cassandra table sink
 


We might use usual heap space at the beginning. The internal database can be any JDBC database. External materialization modes (*) are not included in the first version. In the future, Kafka would be read by general Kafka utility functions. Files as well with support for different file systems.

...