From eb19caa64b11c5a79e3d62cd8411a002b8b06b47 Mon Sep 17 00:00:00 2001 From: alerman Date: Mon, 30 Sep 2024 16:51:33 +0000 Subject: [PATCH 1/2] Update methods to match usage --- .../java/datawave/accumulo/inmemory/InMemoryScannerBase.java | 4 ++++ .../datawave/accumulo/inmemory/InMemoryTableOperations.java | 5 +++++ 2 files changed, 9 insertions(+) diff --git a/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java b/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java index 46eb346..fb5a1db 100644 --- a/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java +++ b/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java @@ -98,6 +98,10 @@ public IteratorScope getIteratorScope() { public boolean isFullMajorCompaction() { return false; } + + public boolean isUserCompaction() { + return false; + } private ArrayList> topLevelIterators = new ArrayList<>(); diff --git a/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java b/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java index 69f8684..7cf8cdf 100644 --- a/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java +++ b/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java @@ -499,6 +499,11 @@ public void importTable(String tableName, Set importDirs, ImportConfigur throws TableExistsException, AccumuloException, AccumuloSecurityException { throw new UnsupportedOperationException(); } + + public void importTable(String tableName, String importDir, boolean keepMappings, boolean skipOnline) + throws TableExistsException, AccumuloException, AccumuloSecurityException { + throw new UnsupportedOperationException(); + } @Override public void exportTable(String tableName, String exportDir) throws TableNotFoundException, AccumuloException, AccumuloSecurityException { From ee5411e90588da8632fbd4b92b9ab1a8c9feb9c2 Mon Sep 17 00:00:00 2001 From: Adam Lerman Date: Mon, 30 Sep 2024 17:02:27 +0000 Subject: [PATCH 2/2] Fix formatting --- .../java/datawave/accumulo/inmemory/InMemoryScannerBase.java | 2 +- .../datawave/accumulo/inmemory/InMemoryTableOperations.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java b/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java index fb5a1db..5a89101 100644 --- a/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java +++ b/src/main/java/datawave/accumulo/inmemory/InMemoryScannerBase.java @@ -98,7 +98,7 @@ public IteratorScope getIteratorScope() { public boolean isFullMajorCompaction() { return false; } - + public boolean isUserCompaction() { return false; } diff --git a/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java b/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java index 7cf8cdf..1603038 100644 --- a/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java +++ b/src/main/java/datawave/accumulo/inmemory/InMemoryTableOperations.java @@ -499,7 +499,7 @@ public void importTable(String tableName, Set importDirs, ImportConfigur throws TableExistsException, AccumuloException, AccumuloSecurityException { throw new UnsupportedOperationException(); } - + public void importTable(String tableName, String importDir, boolean keepMappings, boolean skipOnline) throws TableExistsException, AccumuloException, AccumuloSecurityException { throw new UnsupportedOperationException();