Status
Current state: Under Discussion
Discussion thread:
...
Page properties | ||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
|
...
|
Motivation
While implementing JDBC exactly once sink I found that the current abstractions (TwoPhaseCommitSinkFunction) don’t suit this use case. Having a requirement to avoid code duplication, I propose a new abstraction, with the following goals in mind:
...
This enables customization of various aspects independently and finer grained testing.
Extracting 2PC Resource also allows to run it not as a Sink (might be needed for a batch jobs to commit final pre-committed transactions when Tasks are not running anymore).
Serialization can be viewed as implementation detail of StateHandler. Though API to build it or some default implementation should be provided.
...