Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
SDFs will be the only way to add streaming and liquid sharded IO for Go.
Design doc: https://s.apache.org/splittable-do-fn
Attachments
Issue Links
- links to
(7 links to)
1.
|
Add SDF validation code | Resolved | Daniel Oliveira | |||||||||
2.
|
Add SDF execution-time runners | Resolved | Daniel Oliveira |
|
||||||||
3.
|
Add user-facing Go SDF documentation. | Resolved | Daniel Oliveira |
|
||||||||
4.
|
Add capability to run SDFs on Flink Runner and Python FnApiRunner. | Resolved | Daniel Oliveira |
|
||||||||
5.
|
Add thread-safe restriction trackers. | Resolved | Daniel Oliveira |
|
||||||||
6.
|
Sharing restriction trackers between SDF ProcessElement executor and DataSource | Resolved | Daniel Oliveira |
|
||||||||
7.
|
Sub-element progress tracking and reporting in Go SDK. | Resolved | Daniel Oliveira |
|
||||||||
8.
|
Implement dynamic splitting support for SDFs in Go SDK. | Resolved | Daniel Oliveira |
|
||||||||
9.
|
Adjust Go SDF progress reporting to account for multi-window elements. | Resolved | Daniel Oliveira |
|
||||||||
10.
|
Fix multi-window SDF splitting in Go. | Resolved | Daniel Oliveira |
|