From 8b1f7e7d9c63391a9a714251e772a25d1f6a5733 Mon Sep 17 00:00:00 2001 From: Terry Brady Date: Fri, 22 Mar 2024 11:19:27 -0700 Subject: [PATCH] Update java-api.md --- design/queue-2023/java-api.md | 20 +++++++++++++++++--- 1 file changed, 17 insertions(+), 3 deletions(-) diff --git a/design/queue-2023/java-api.md b/design/queue-2023/java-api.md index 04cd0811..660228d2 100644 --- a/design/queue-2023/java-api.md +++ b/design/queue-2023/java-api.md @@ -86,7 +86,14 @@ abstract public class QueueItem public int intProperty(ZooKeeper client, ZKKey key) throws MerrittZKNodeInvalid; public long longProperty(ZooKeeper client, ZKKey key) throws MerrittZKNodeInvalid; public void setData(ZooKeeper client, ZKKey key, Object data) throws MerrittZKNodeInvalid; + + public abstract String dir(); + public abstract String prefix(); + public abstract IngestState initState(); + public abstract IngestState[] states(); public String path(); + public String prefixPath(); + public static String serialize(Object data); public static String createId(ZooKeeper client, String prefix); public JSONObject statusObject(IngestState status); @@ -104,9 +111,11 @@ public class Batch extends QueueItem { public boolean hasFailure(); - public static String dir(); - public static String prefix(); - public static String prefixPath(); + public String dir(); + public String prefix(); + public IngestState initState(); + public IngestState[] states(); + public static Batch createBatch(ZooKeeper client, JSONObject submission); public void delete(ZooKeeper client) throws MerrittStateError; @@ -122,6 +131,11 @@ public class Job extends QueueItem { private String jobStatePath; private String batchStatePath; + public String dir(); + public String prefix(); + public IngestState initState(); + public IngestState[] states(); + public Job(String id, String bid); public Job(String id, String bid, JSONObject data);