[
https://issues.apache.org/jira/browse/GOBBLIN-1697?focusedWorklogId=810204&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-810204
]
ASF GitHub Bot logged work on GOBBLIN-1697:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 19/Sep/22 23:37
Start Date: 19/Sep/22 23:37
Worklog Time Spent: 10m
Work Description: Will-Lo commented on code in PR #3549:
URL: https://github.com/apache/gobblin/pull/3549#discussion_r974767122
##########
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java:
##########
@@ -78,6 +78,16 @@ public interface SpecStore {
*/
Spec updateSpec(Spec spec) throws IOException, SpecNotFoundException;
+ /***
+ * Update {@link Spec} in the {@link SpecStore} when current version is
smaller than {@link version}.
+ * @param spec {@link Spec} to be updated.
+ * @param version largest version that current spec should be
+ * @throws IOException Exception in updating the {@link Spec}.
+ * @return Updated {@link Spec}.
+ * @throws SpecNotFoundException If {@link Spec} being updated is not
present in store.
+ */
+ default Spec updateSpec(Spec spec, long version) throws IOException,
SpecNotFoundException {return updateSpec(spec);};
Review Comment:
For that purpose, I think version isn't the best naming for this
functionality, maybe something more related to the modifiedTimestamp? e.g.
modifiedWatermark? Version makes me think that it would be directly incremental.
Reason being is that there was some interest in adding versioning to the
FlowSpecStore, if this is needed for users in the future for them to undo
changes, then it would make sense we refer to this timestamp differently.
Issue Time Tracking
-------------------
Worklog Id: (was: 810204)
Time Spent: 1h 20m (was: 1h 10m)
> Have a separate resource handler to rely on CDC stream to do message
> forwarding
> -------------------------------------------------------------------------------
>
> Key: GOBBLIN-1697
> URL: https://issues.apache.org/jira/browse/GOBBLIN-1697
> Project: Apache Gobblin
> Issue Type: Improvement
> Reporter: Zihan Li
> Priority: Major
> Time Spent: 1h 20m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
