FlatPostgresCollection Create Doc Impl

document-store/src/main/java/org/hypertrace/core/documentstore/CreateResult.java

@@ -1,16 +1,24 @@
 package org.hypertrace.core.documentstore;
 
+import java.util.List;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
 /*
  * Represent the result object for CREATE operation of document store APIs.
  * */
+@AllArgsConstructor
+@Getter
 public class CreateResult {
-  private boolean succeed;
+  private boolean isSucceed;
+  private boolean onRetry;
+  private List<String> skippedFields;
 
-  public CreateResult(boolean succeed) {
-    this.succeed = succeed;
+  public CreateResult(boolean isSucceed) {
+    this.isSucceed = isSucceed;
   }
 
-  public boolean isSucceed() {
-    return succeed;
+  public boolean isPartial() {
+    return !skippedFields.isEmpty();
   }
 }

document-store/src/main/java/org/hypertrace/core/documentstore/commons/ColumnMetadata.java

@@ -18,4 +18,9 @@ public interface ColumnMetadata {
    * @return whether this column can be set to NULL
    */
   boolean isNullable();
+
+  /**
+   * @return whether this column is an array type
+   */
+  boolean isArray();
 }

document-store/src/main/java/org/hypertrace/core/documentstore/model/exception/SchemaMismatchException.java

@@ -0,0 +1,22 @@
+package org.hypertrace.core.documentstore.model.exception;
+
+import java.io.IOException;
+
+/**
+ * Exception thrown when a document field doesn't match the expected schema. This can occur when:
+ *
+ * <ul>
+ *   <li>A field in the document doesn't exist in the schema
+ *   <li>A field's value type doesn't match the expected schema type
+ * </ul>
+ */
+public class SchemaMismatchException extends IOException {
+
+  public SchemaMismatchException(String message) {
+    super(message);
+  }
+
+  public SchemaMismatchException(String message, Throwable cause) {
+    super(message, cause);
+  }
+}