fix: change ES writes to use Bulk APIs (#97)

awslabs · Jul 29, 2021 · 7eee06e · 7eee06e
1 parent d668712
commit 7eee06e
Show file tree

Hide file tree

Showing 5 changed files with 535 additions and 176 deletions.
diff --git a/src/ddbToEs/ESBulkCommand.ts b/src/ddbToEs/ESBulkCommand.ts
@@ -0,0 +1,15 @@
+/*
+ *  Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ *  SPDX-License-Identifier: Apache-2.0
+ */
+
+export type OperationType = 'delete' | 'upsert-AVAILABLE' | 'upsert-DELETED';
+
+export default interface ESBulkCommand {
+    bulkCommand: any[];
+    /**
+     * This will be a unique identifier or composite id i.e. `<id>_<vid>`
+     */
+    id: string;
+    type: OperationType;
+}