Skip to content

Commit

Permalink
Support rollups and trees in the engine and gRPC server, and make tab…
Browse files Browse the repository at this point in the history
…le attributes immutable (deephaven#3243)

* Implement engine support for rollups and trees based on partitioned tables
* Implement a gRPC API for manipulating rollups and trees, and subscribing to snapshots thereof
* Implement (as yet unsupported in the UI) capability to "expand all" rollups and trees
* Make table attributes immutable
* DataColumn.set* are removed
* We now have ImmutableConstant*ColumnSources, for single value constant columns
* RowRedirection now properly implements ChunkSource.WithPrev and FillUnordered
* WritableRowRedirection now properly implements ChunkSink
* Legacy rollup and tree snapshot code has been removed
* Legacy SmartKey and TableMap code has been removed
  • Loading branch information
rcaudy authored Dec 29, 2022
1 parent 5810ede commit 49b3ec1
Show file tree
Hide file tree
Showing 415 changed files with 12,868 additions and 11,830 deletions.
180 changes: 0 additions & 180 deletions Base/src/main/java/io/deephaven/base/StringUtils.java

This file was deleted.

39 changes: 0 additions & 39 deletions Base/src/test/java/io/deephaven/base/TestStringUtils.java

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
*/
package io.deephaven.benchmarking;

import io.deephaven.base.StringUtils;
import io.deephaven.configuration.Configuration;
import io.deephaven.configuration.DataDir;
import io.deephaven.engine.context.ExecutionContext;
Expand All @@ -23,6 +22,7 @@
import java.util.Arrays;
import java.util.List;
import java.util.Random;
import java.util.stream.Collectors;

/**
* An entry point to get instances of {@link BenchmarkTableBuilder}s.
Expand Down Expand Up @@ -256,7 +256,7 @@ public static String stripName(String benchmark) {
}

public static String buildParameterString(BenchmarkParams params) {
return StringUtils.joinStrings(params.getParamsKeys().stream().map(params::getParam), ";");
return params.getParamsKeys().stream().map(params::getParam).collect(Collectors.joining(";"));
}

public static Path dataDir() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,12 @@
*/
package io.deephaven.benchmarking.impl;

import io.deephaven.base.StringUtils;
import io.deephaven.benchmarking.BenchmarkTable;

import java.util.*;
import java.util.Arrays;
import java.util.HashSet;
import java.util.LinkedHashSet;
import java.util.Set;

public class PersistentBenchmarkTableBuilder extends AbstractBenchmarkTableBuilder<PersistentBenchmarkTableBuilder> {

Expand Down Expand Up @@ -53,7 +55,7 @@ public BenchmarkTable build() {

if (!missingGroupingColumns.isEmpty()) {
throw new IllegalStateException("Grouping requested on the following nonexistant columns "
+ StringUtils.joinStrings(missingGroupingColumns, ", "));
+ String.join(", ", missingGroupingColumns));
}

// TODO (deephaven/deephaven-core/issues/147): Replace this with a Parquet-backed table, or delete this entirely
Expand Down
9 changes: 0 additions & 9 deletions ClientSupport/ClientSupport.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -12,15 +12,6 @@ dependencies {
implementation project(':log-factory')
implementation project(':Configuration')
implementation depCommonsLang3

testImplementation TestTools.projectDependency(project, 'Base')
testImplementation TestTools.projectDependency(project, 'engine-table')
testImplementation project(':extensions-csv')

testRuntimeOnly project(':log-to-slf4j')
testRuntimeOnly project(path: ':configs')
testRuntimeOnly project(path: ':test-configs')
Classpaths.inheritSlf4j(project, 'slf4j-simple', 'testRuntimeOnly')
}

spotless {
Expand Down
Loading

0 comments on commit 49b3ec1

Please sign in to comment.