Support bidirectional streaming on websockets

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/ByteValueTracker.java

@@ -9,8 +9,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.util.QueryConstants.NULL_BYTE;
 

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/CharValueTracker.java

@@ -6,8 +6,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.util.QueryConstants.NULL_CHAR;
 

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/DoubleValueTracker.java

@@ -9,8 +9,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.util.QueryConstants.NULL_DOUBLE;
 

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/FloatValueTracker.java

@@ -9,8 +9,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.util.QueryConstants.NULL_FLOAT;
 

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/IntValueTracker.java

@@ -9,8 +9,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.util.QueryConstants.NULL_INT;
 

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/LongValueTracker.java

@@ -9,8 +9,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.util.QueryConstants.NULL_LONG;
 

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/ObjectValueTracker.java

@@ -8,8 +8,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 public final class ObjectValueTracker<T extends Comparable<T>> extends ValueTracker {
     private final ObjectArraySource<T> source;

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/ShortValueTracker.java

@@ -9,8 +9,7 @@
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.util.QueryConstants.NULL_SHORT;
 

ClientSupport/src/main/java/io/deephaven/clientsupport/plotdownsampling/ValueTracker.java

@@ -8,8 +8,8 @@
 import io.deephaven.db.v2.sources.chunk.Chunk;
 import io.deephaven.db.v2.utils.Index;
 import io.deephaven.db.v2.utils.IndexShiftData;
+import org.jetbrains.annotations.Nullable;
 
-import javax.annotation.Nullable;
 import java.util.List;
 
 /**

DB/DB.gradle

@@ -52,9 +52,7 @@ dependencies {
             project(':deephaven-jpy-ext'),
             project(':Parquet'),
             project(':DHProcess'),
-            project(':proto:proto-backplane-grpc-util'),
             project(':log-factory'),
-            project(':open-api-lang-api'),
             project(':Container'),
             project(':table-api'),
             project(':qst'),
@@ -79,6 +77,8 @@ dependencies {
 
     annotationProcessor 'org.immutables:value:2.8.1'
     compileOnly 'org.immutables:value-annotations:2.8.1'
+
+    compileOnly 'com.google.code.findbugs:jsr305:3.0.2'
 }
 
 task jmhRun(type: JavaExec)  {

DB/src/main/java/io/deephaven/db/tables/CodecLookup.java

@@ -9,9 +9,9 @@
 import io.deephaven.util.codec.ExternalizableCodec;
 import io.deephaven.util.codec.ObjectCodec;
 import io.deephaven.util.codec.SerializableCodec;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 
-import javax.annotation.Nullable;
-import javax.validation.constraints.NotNull;
 import java.io.Externalizable;
 
 /**

DB/src/main/java/io/deephaven/db/util/AbstractScriptSession.java

@@ -11,8 +11,6 @@
 import io.deephaven.db.tables.select.QueryScope;
 import io.deephaven.db.util.liveness.LivenessScope;
 import io.deephaven.db.util.liveness.LivenessScopeStack;
-import io.deephaven.lang.parse.api.CompletionParseService;
-import io.deephaven.lang.parse.api.CompletionParseServiceNoOp;
 import io.deephaven.util.SafeCloseable;
 import org.jetbrains.annotations.Nullable;
 
@@ -45,7 +43,6 @@ private static void createOrClearDirectory(final File directory) {
     protected final QueryScope queryScope;
     protected final QueryLibrary queryLibrary;
     protected final CompilerTools.Context compilerContext;
-    private final CompletionParseService<?, ?, ?> parser;
 
     protected AbstractScriptSession(boolean isDefaultScriptSession) {
         final UUID scriptCacheId = UuidCreator.getRandomBased();
@@ -74,16 +71,6 @@ protected AbstractScriptSession(boolean isDefaultScriptSession) {
             QueryScope.setDefaultScope(queryScope);
             QueryLibrary.setDefaultLibrary(queryLibrary);
         }
-        @SuppressWarnings("rawtypes")
-        ServiceLoader<CompletionParseService> loader = ServiceLoader.load(CompletionParseService.class);
-        @SuppressWarnings("rawtypes")
-        final Iterator<CompletionParseService> itr = loader.iterator();
-        if (itr.hasNext()) {
-            parser = itr.next();
-        } else {
-            // hm, should maybe log to the user that we are using a do-nothing completer...
-            parser = new CompletionParseServiceNoOp();
-        }
     }
 
     @Override
@@ -171,13 +158,6 @@ protected void destroy() {
      */
     protected abstract QueryScope newQueryScope();
 
-    @Override
-    @SuppressWarnings("rawtypes")
-    public CompletionParseService getParser() {
-        return parser;
-    }
-
-
     @Override
     public Class getVariableType(final String var) {
         final Object result = getVariable(var, null);

DB/src/main/java/io/deephaven/db/util/ScriptSession.java

@@ -9,7 +9,6 @@
 import io.deephaven.db.util.liveness.ReleasableLivenessManager;
 import io.deephaven.db.util.scripts.ScriptPathLoader;
 import io.deephaven.db.util.scripts.ScriptPathLoaderState;
-import io.deephaven.lang.parse.api.CompletionParseService;
 import org.jetbrains.annotations.Nullable;
 
 import java.util.HashMap;
@@ -49,8 +48,6 @@ public interface ScriptSession extends ReleasableLivenessManager, LivenessNode {
      */
     VariableProvider getVariableProvider();
 
-    CompletionParseService getParser();
-
     class Changes {
         public Map<String, ExportedObjectType> created = new HashMap<>();
         public Map<String, ExportedObjectType> updated = new HashMap<>();

DB/src/main/java/io/deephaven/db/v2/locations/impl/AbstractTableLocationProvider.java

@@ -4,8 +4,8 @@
 import io.deephaven.hash.KeyedObjectHashMap;
 import io.deephaven.hash.KeyedObjectKey;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 
-import javax.annotation.Nullable;
 import java.util.Collection;
 import java.util.Collections;
 

DB/src/main/java/io/deephaven/db/v2/sources/ColumnSource.java

@@ -5,7 +5,6 @@
 package io.deephaven.db.v2.sources;
 
 import io.deephaven.base.verify.Require;
-import io.deephaven.db.tables.ColumnDefinition;
 import io.deephaven.db.v2.sources.chunk.*;
 import io.deephaven.db.v2.sources.chunk.Attributes.Values;
 import io.deephaven.db.v2.tuples.TupleSource;

DB/src/main/java/io/deephaven/db/v2/sources/regioned/RegionedColumnSourceArray.java

@@ -2,13 +2,13 @@
 
 import io.deephaven.base.verify.Require;
 
-import javax.annotation.Nullable;
 import javax.annotation.OverridingMethodsMustInvokeSuper;
 import io.deephaven.db.tables.ColumnDefinition;
 import io.deephaven.db.v2.locations.ColumnLocation;
 import io.deephaven.db.v2.sources.chunk.Attributes;
 import io.deephaven.util.annotations.TestUseOnly;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 
 import java.util.function.Supplier;
 

DB/src/main/java/io/deephaven/db/v2/sources/regioned/RegionedColumnSourceObject.java

@@ -7,9 +7,7 @@
 import io.deephaven.db.v2.sources.ColumnSourceGetDefaults;
 import io.deephaven.db.v2.sources.chunk.Attributes.Values;
 import org.jetbrains.annotations.NotNull;
-
-import javax.annotation.Nullable;
-import java.util.function.Supplier;
+import org.jetbrains.annotations.Nullable;
 
 import static io.deephaven.db.v2.utils.ReadOnlyIndex.NULL_KEY;
 

DB/src/test/java/io/deephaven/db/v2/utils/ImmutableColumnHolder.java

@@ -5,8 +5,7 @@
 package io.deephaven.db.v2.utils;
 
 import org.jetbrains.annotations.NotNull;
-
-import javax.annotation.Nullable;
+import org.jetbrains.annotations.Nullable;
 
 public class ImmutableColumnHolder<T> extends ColumnHolder<T> {
     @SuppressWarnings("unchecked")

Plot/src/main/java/io/deephaven/db/plot/util/tables/TableMapBackedTableMapHandle.java

@@ -6,9 +6,9 @@
 import io.deephaven.db.tables.TableDefinition;
 import io.deephaven.db.tables.utils.TableTools;
 import io.deephaven.db.v2.TableMap;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 
-import javax.annotation.Nullable;
-import javax.validation.constraints.NotNull;
 import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;