You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
| scan.streams | required for source | (none) | List<String> | Semicolon-separated list of stream names from which the table is read. |
93
94
| scan.start-streamcuts | optional | (none) | List<String> | Semicolon-separated list of base64 encoded strings for start streamcuts, begin of the stream if not specified |
94
95
| scan.end-streamcuts | optional | (none) | List<String> | Semicolon-separated list of base64 encoded strings for end streamcuts, unbounded end if not specified |
96
+
| scan.uid | optional | (none) | String | Uid for the table source operator to identify the checkpoint state |
95
97
| scan.reader-group.max-outstanding-checkpoint-request | optional | 3 | Integer | Maximum outstanding checkpoint requests to Pravega |
96
98
| scan.reader-group.refresh.interval | optional | 3 s | Duration | Refresh interval for reader group |
97
99
| scan.event-read.timeout.interval | optional | 1 s | Duration | Timeout for the call to read events from Pravega |
0 commit comments