diff --git a/.github/workflows/docs-ci.yml b/.github/workflows/docs-ci.yml
index 1e375f5b951..c9a87104254 100644
--- a/.github/workflows/docs-ci.yml
+++ b/.github/workflows/docs-ci.yml
@@ -20,14 +20,6 @@ jobs:
distribution: 'temurin'
java-version: '11'
- # TODO(deephaven-core#1513): Remove non-LTS JDK 15 as part of javadocs process
- - name: Setup JDK 15
- id: setup-java-15
- uses: actions/setup-java@v3
- with:
- distribution: 'zulu'
- java-version: '15'
-
- name: Setup JDK 17
id: setup-java-17
uses: actions/setup-java@v3
@@ -42,7 +34,7 @@ jobs:
run: |
cat .github/env/${{ runner.os }}/gradle.properties >> gradle.properties
echo >> gradle.properties
- echo "org.gradle.java.installations.paths=${{ steps.setup-java-11.outputs.path }},${{ steps.setup-java-15.outputs.path }},${{ steps.setup-java-17.outputs.path }}" >> gradle.properties
+ echo "org.gradle.java.installations.paths=${{ steps.setup-java-11.outputs.path }},${{ steps.setup-java-17.outputs.path }}" >> gradle.properties
cat gradle.properties
- name: All Javadoc
@@ -84,14 +76,6 @@ jobs:
distribution: 'temurin'
java-version: '11'
- # TODO(deephaven-core#1513): Remove non-LTS JDK 15 as part of javadocs process
- - name: Setup JDK 15
- id: setup-java-15
- uses: actions/setup-java@v3
- with:
- distribution: 'zulu'
- java-version: '15'
-
- name: Setup JDK 17
id: setup-java-17
uses: actions/setup-java@v3
@@ -106,7 +90,7 @@ jobs:
run: |
cat .github/env/${{ runner.os }}/gradle.properties >> gradle.properties
echo >> gradle.properties
- echo "org.gradle.java.installations.paths=${{ steps.setup-java-11.outputs.path }},${{ steps.setup-java-15.outputs.path }},${{ steps.setup-java-17.outputs.path }}" >> gradle.properties
+ echo "org.gradle.java.installations.paths=${{ steps.setup-java-11.outputs.path }},${{ steps.setup-java-17.outputs.path }}" >> gradle.properties
cat gradle.properties
- name: Generate Python Docs
diff --git a/Base/src/main/java/io/deephaven/base/ArrayUtil.java b/Base/src/main/java/io/deephaven/base/ArrayUtil.java
index b8300338bba..c65cf19a062 100644
--- a/Base/src/main/java/io/deephaven/base/ArrayUtil.java
+++ b/Base/src/main/java/io/deephaven/base/ArrayUtil.java
@@ -13,7 +13,7 @@ public class ArrayUtil {
/**
* The maximum array size is determined by the JVM and in practice is less than Integer.MAX_VALUE. (See note at
- * {@link jdk.internal.util.ArraysSupport#SOFT_MAX_ARRAY_LENGTH}.)
+ * {@code jdk.internal.util.ArraysSupport#SOFT_MAX_ARRAY_LENGTH}.)
*/
// We would like to use jdk.internal.util.ArraysSupport.MAX_ARRAY_LENGTH, but it is not exported
public static final int MAX_ARRAY_SIZE = Integer.MAX_VALUE - 8;
diff --git a/Base/src/main/java/io/deephaven/base/CompareUtils.java b/Base/src/main/java/io/deephaven/base/CompareUtils.java
index 2def1fc8365..a3a13e23788 100644
--- a/Base/src/main/java/io/deephaven/base/CompareUtils.java
+++ b/Base/src/main/java/io/deephaven/base/CompareUtils.java
@@ -120,7 +120,7 @@ public static boolean doubleEquals2(double x, double y, double tolerance) {
}
/**
- * Since logical comparison of double values considerig error is effectively a three-value logic, you can't really
+ * Since logical comparison of double values considering error is effectively a three-value logic, you can't really
* do !equals when you mean notEquals.
*
* @param x
@@ -159,7 +159,7 @@ public static boolean doubleNotEquals2(double x, double y, double tolerance) {
}
/**
- * You can't do double1 > double2 because floating point numbers are not exact values. Just make sure that x-y is
+ * You can't do double1 > double2 because floating point numbers are not exact values. Just make sure that x-y is
* greater than some allowable error factor for equality
*
* @param x
@@ -191,8 +191,8 @@ public static boolean doubleGreaterEqual(double x, double y, double tolerance) {
}
/**
- * You can't do double1 < double2 because floating point numbers are not exact values. Just make sure that y - x is
- * greater than some allowable error factor for equality
+ * You can't do double1 < double2 because floating point numbers are not exact values. Just make sure that y - x
+ * is greater than some allowable error factor for equality
*
* @param x
* @param y
diff --git a/Base/src/main/java/io/deephaven/base/LowGarbageArrayIntegerMap.java b/Base/src/main/java/io/deephaven/base/LowGarbageArrayIntegerMap.java
index f01398577b7..ad29fd102e9 100644
--- a/Base/src/main/java/io/deephaven/base/LowGarbageArrayIntegerMap.java
+++ b/Base/src/main/java/io/deephaven/base/LowGarbageArrayIntegerMap.java
@@ -19,7 +19,7 @@
* when expanding). This set only has one {@link Iterator}, which is reused. This set is not thread safe.
*
* Note: This class extends {@link HashMap} rather than {@link Map} (or {@link AbstractMap}) only because one of the
- * fields where we want to use it ({@link sun.nio.ch.EPollSelectorImpl#fdToKey}) is (improperly) declared as a HashMap
+ * fields where we want to use it ({@code sun.nio.ch.EPollSelectorImpl#fdToKey}) is (improperly) declared as a HashMap
* rather than a Map.
*/
public class LowGarbageArrayIntegerMap extends HashMap {
diff --git a/Base/src/main/java/io/deephaven/base/LowGarbageArraySet.java b/Base/src/main/java/io/deephaven/base/LowGarbageArraySet.java
index 6c3ae204f61..a181145d4e7 100644
--- a/Base/src/main/java/io/deephaven/base/LowGarbageArraySet.java
+++ b/Base/src/main/java/io/deephaven/base/LowGarbageArraySet.java
@@ -16,7 +16,7 @@
* expanding). This set only has one {@link Iterator}, which is reused. This set is not thread safe.
*
* Note: This class extends {@link HashSet} rather than {@link Set} (or {@link AbstractSet}) only because one of the
- * fields where we want to use it ({@link sun.nio.ch.SelectorImpl#keys}) is (improperly) declared as a HashSet rather
+ * fields where we want to use it ({@code sun.nio.ch.SelectorImpl#keys}) is (improperly) declared as a HashSet rather
* than a Set.
*/
public class LowGarbageArraySet extends HashSet {
diff --git a/Base/src/main/java/io/deephaven/base/MathUtil.java b/Base/src/main/java/io/deephaven/base/MathUtil.java
index 287ab50821a..f7ebc05b6b0 100644
--- a/Base/src/main/java/io/deephaven/base/MathUtil.java
+++ b/Base/src/main/java/io/deephaven/base/MathUtil.java
@@ -75,7 +75,7 @@ public static int gcd(int a, int b) {
};
/**
- * Compute 10^n as a int for 0 <= n <= 9.
+ * Compute 10^n as a int for 0 <= n <= 9.
*
* @param n the exponent
* @return 10^n
@@ -95,9 +95,9 @@ public static int pow10(int n) {
};
/**
- * Compute the number of base 10 digits in n's representation, for n >= 0.
+ * Compute the number of base 10 digits in n's representation, for n >= 0.
*
- * @param n an integer >= 0
+ * @param n an integer >= 0
* @return how many digits in n's base 10 representation.
*/
public static int base10digits(int n) {
diff --git a/Base/src/main/java/io/deephaven/base/cache/OpenAddressedCanonicalizationCache.java b/Base/src/main/java/io/deephaven/base/cache/OpenAddressedCanonicalizationCache.java
index b04dbaa1401..9ac75fc09a8 100644
--- a/Base/src/main/java/io/deephaven/base/cache/OpenAddressedCanonicalizationCache.java
+++ b/Base/src/main/java/io/deephaven/base/cache/OpenAddressedCanonicalizationCache.java
@@ -48,7 +48,7 @@ public interface Adapter {
int hashCode(@NotNull final INPUT_TYPE inputItem);
/**
- * Note: The following must be true: hashCode(inputItem) == outputItem.hashCode() && equals(inputItem,
+ * Note: The following must be true: hashCode(inputItem) == outputItem.hashCode() && equals(inputItem,
* outputItem)
*
* @param inputItem The input item
diff --git a/Base/src/main/java/io/deephaven/base/stats/Group.java b/Base/src/main/java/io/deephaven/base/stats/Group.java
index 3568e4a164b..dda1cb5a01c 100644
--- a/Base/src/main/java/io/deephaven/base/stats/Group.java
+++ b/Base/src/main/java/io/deephaven/base/stats/Group.java
@@ -95,7 +95,7 @@ public Item[] getItems() {
}
/**
- * Update the histories of all items in this group, logging all updated intervals >= logInterval.
+ * Update the histories of all items in this group, logging all updated intervals >= logInterval.
*/
public void update(ItemUpdateListener listener, long logInterval, long now, long appNow) {
Item[] arr = itemsArray;
diff --git a/Base/src/main/java/io/deephaven/base/stats/Item.java b/Base/src/main/java/io/deephaven/base/stats/Item.java
index 6849a494014..38831a7c692 100644
--- a/Base/src/main/java/io/deephaven/base/stats/Item.java
+++ b/Base/src/main/java/io/deephaven/base/stats/Item.java
@@ -71,7 +71,7 @@ public String getCompactName() {
}
/**
- * Update the history intervals for this item's value, logging updated intervals >= logInterval
+ * Update the history intervals for this item's value, logging updated intervals >= logInterval
*/
public void update(ItemUpdateListener listener, long logInterval, long now, long appNow) {
value.update(this, listener, logInterval, now, appNow);
diff --git a/Base/src/main/java/io/deephaven/base/stats/Stats.java b/Base/src/main/java/io/deephaven/base/stats/Stats.java
index d9d671b7d8e..fe5a5a7bced 100644
--- a/Base/src/main/java/io/deephaven/base/stats/Stats.java
+++ b/Base/src/main/java/io/deephaven/base/stats/Stats.java
@@ -161,7 +161,7 @@ public synchronized static Group getGroup(String name) {
}
/**
- * Update the histories of all items in all groups, logging all updated intervals >= logInterval.
+ * Update the histories of all items in all groups, logging all updated intervals >= logInterval.
*/
public synchronized static void update(ItemUpdateListener listener, long now, long appNow, long logInterval) {
for (Group g : groups) {
diff --git a/Base/src/main/java/io/deephaven/base/string/EncodingInfo.java b/Base/src/main/java/io/deephaven/base/string/EncodingInfo.java
index 573053d9d27..da81a36b50a 100644
--- a/Base/src/main/java/io/deephaven/base/string/EncodingInfo.java
+++ b/Base/src/main/java/io/deephaven/base/string/EncodingInfo.java
@@ -56,7 +56,8 @@ public String getEncodingName() {
}
/**
- * Can this encoding info's charset be encoded or decoded by simple linear assignment of char->byte or byte->char.
+ * Can this encoding info's charset be encoded or decoded by simple linear assignment of char->byte or
+ * byte->char.
*
* @return Whether this encoding info's charset is simple
*/
diff --git a/Base/src/main/java/io/deephaven/base/string/cache/MappedCompressedString.java b/Base/src/main/java/io/deephaven/base/string/cache/MappedCompressedString.java
index 1c9e085f909..9484fd80041 100644
--- a/Base/src/main/java/io/deephaven/base/string/cache/MappedCompressedString.java
+++ b/Base/src/main/java/io/deephaven/base/string/cache/MappedCompressedString.java
@@ -12,8 +12,8 @@
/**
* This is a ridiculously simple, light-as-I-can-make-it, but decidedly single-purpose data structure. Specifically,
* it's a CompressedString with an embedded (to avoid reference or Object instance overhead) open-addressed
- * SimpleReference
A "block" is a particular interval [n*2^16, (n+1)*2^16 - 1] of the long domain.
- *
A "span" is a partition of the domain consisting of one or more consecutive blocks;
a span is a subset of
- * the domain represented by an interval [n*2^16, (n+m)*2^16 - 1], m >= 1.
+ *
A "span" is a partition of the domain consisting of one or more consecutive blocks; a span is a subset of the
+ * domain represented by an interval [n*2^16, (n+m)*2^16 - 1], m >= 1.
*
Full blocks are blocks whose domain are fully contained in the set, ie, the set contains every possible value in
* the block's interval (as a bitmap, it would be "all ones").
*
Spans of full blocks are represented by a single "full blocks span" object (just a Long) which knows how many
@@ -89,8 +89,8 @@
*
*
*
- * There are two basic cases for a span: it is either a full blocks span, containing a >=1 number of full blocks, or it
- * is a container, containing individual values in the particular 2^16 block corresponding to the span's key.
+ * There are two basic cases for a span: it is either a full blocks span, containing a >=1 number of full blocks, or
+ * it is a container, containing individual values in the particular 2^16 block corresponding to the span's key.
*
*
*
@@ -1163,7 +1163,7 @@ public interface SpanCursorForward extends SpanCursor {
/**
* Advances the pointer forward to the last span in the sequence whose interval range has a value v such that
- * comp.directionToTargetFrom(v) >= 0.
+ * comp.directionToTargetFrom(v) >= 0.
*
* This operation is O(log(cardinality)).
*
diff --git a/engine/rowset/src/main/java/io/deephaven/engine/rowset/impl/rsp/RspRangeIterator.java b/engine/rowset/src/main/java/io/deephaven/engine/rowset/impl/rsp/RspRangeIterator.java
index cba97d7a23f..74026a1e5c7 100644
--- a/engine/rowset/src/main/java/io/deephaven/engine/rowset/impl/rsp/RspRangeIterator.java
+++ b/engine/rowset/src/main/java/io/deephaven/engine/rowset/impl/rsp/RspRangeIterator.java
@@ -284,8 +284,8 @@ public boolean advance(final long key) {
/**
* Advance the current iterator (start) position to the rightmost (last) value v that maintains
- * comp.directionToTargetFrom(v) >= 0. I.e, either hasNext() returns false after this call, or the next value in the
- * iterator nv would be such that comp.directionToTargetFrom(nv) < 0.
+ * comp.directionToTargetFrom(v) >= 0. I.e, either hasNext() returns false after this call, or the next value in
+ * the iterator nv would be such that comp.directionToTargetFrom(nv) < 0.
*
* Note this method should be called only after calling hasNext() and next() at least once, eg, from a valid current
* position in a non-empty and also non-exhausted iterator.
diff --git a/engine/table/src/main/java/io/deephaven/engine/page/Page.java b/engine/table/src/main/java/io/deephaven/engine/page/Page.java
index a3b7ef09ce8..1c35884c8a2 100644
--- a/engine/table/src/main/java/io/deephaven/engine/page/Page.java
+++ b/engine/table/src/main/java/io/deephaven/engine/page/Page.java
@@ -20,10 +20,10 @@
* Non overlapping pages can be collected together in a {@link PageStore}, which provides the {@link ChunkSource}
* interface to the collection of all of its Pages.
*
- * There are two distinct use cases/types of pages. The first use case are {@code Page}s which always have a length() >
- * 0. These store length() values, which can be assessed via the {@link ChunkSource} methods. Valid {@link RowSequence}
- * passed to those methods will have their offset in the range [firstRowOffset(), firstRowOffset() + length()). Passing
- * OrderKeys with offsets outside of this range will have undefined results.
+ * There are two distinct use cases/types of pages. The first use case are {@code Page}s which always have a length()
+ * > 0. These store length() values, which can be assessed via the {@link ChunkSource} methods. Valid
+ * {@link RowSequence} passed to those methods will have their offset in the range [firstRowOffset(), firstRowOffset() +
+ * length()). Passing OrderKeys with offsets outside of this range will have undefined results.
*
* The second use case will always have length() == 0 and firstRowOffset() == 0. These represent "Null" regions which
* return a fixed value, typically a null value, for every {@link RowSequence} passed into the {@link ChunkSource}
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/by/AggregationRowLookup.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/by/AggregationRowLookup.java
index b609a3e44e1..5b5872a41f7 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/by/AggregationRowLookup.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/by/AggregationRowLookup.java
@@ -35,7 +35,7 @@ public interface AggregationRowLookup {
*
Multiple group-by columns
*
Compound keys are {@code Object[]} of (boxed, if needed) objects, in the order of the aggregation's group-by
* columns
- *
+ *
*
* All key fields must be reinterpreted to the appropriate primitive value before boxing. See
* {@link io.deephaven.engine.table.impl.sources.ReinterpretUtils#maybeConvertToPrimitive}.
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/by/CopyingPermutedBlinkFirstOrLastChunkedOperator.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/by/CopyingPermutedBlinkFirstOrLastChunkedOperator.java
index 38677e96153..476466929b2 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/by/CopyingPermutedBlinkFirstOrLastChunkedOperator.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/by/CopyingPermutedBlinkFirstOrLastChunkedOperator.java
@@ -58,7 +58,7 @@ public final void startTrackingPrevValues() {
*
* This implementation proceeds chunk-wise in the following manner:
*
- *
Get a chunk of destination slots
+ *
Get a chunk of destination slots
*
Fill a chunk of source indices
*
Sort the chunk of source indices
*
For each input column: get a chunk of input values, permute it into a chunk of destination values, and then
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/join/dupexpand/DupExpandKernel.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/join/dupexpand/DupExpandKernel.java
index cfbefb8141a..06c919e01d1 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/join/dupexpand/DupExpandKernel.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/join/dupexpand/DupExpandKernel.java
@@ -39,7 +39,7 @@ static DupExpandKernel makeDupExpand(ChunkType chunkType) {
* keyRunLengths chunk is parallel to the original chunkToExpand; it is never modified.
*
* @param expandedSize the sum of all entries in keyRunLengths
- * @param chunkToExpand the values to expand in-place (this writable chunk must have capacity >= expandedSize)
+ * @param chunkToExpand the values to expand in-place (this writable chunk must have capacity >= expandedSize)
* @param keyRunLengths the key run-lengths parallel to chunkToExpand
*/
void expandDuplicates(int expandedSize, WritableChunk chunkToExpand,
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/locations/TableDataService.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/locations/TableDataService.java
index cde882809c6..6179ee63d22 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/locations/TableDataService.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/locations/TableDataService.java
@@ -46,7 +46,7 @@ default String getName() {
* Get a detailed description string.
*
* @return A description string
- * @implNote Defaults to {@link #toString()}
+ * @implNote Defaults to {@link Object#toString()}
*/
default String describe() {
return toString();
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/remote/ConstructSnapshot.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/remote/ConstructSnapshot.java
index c9e0ca891ad..bc0170e566f 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/remote/ConstructSnapshot.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/remote/ConstructSnapshot.java
@@ -1301,8 +1301,8 @@ public static boolean serializeAllTable(boolean usePrev,
*
* Populate a BarrageMessage with the specified positions to snapshot and columns.
*
- * >Note that care must be taken while using this method to ensure the underlying table is locked or does not
- * change, otherwise the resulting snapshot may be inconsistent. In general users should instead use
+ * Note that care must be taken while using this method to ensure the underlying table is locked or does not change,
+ * otherwise the resulting snapshot may be inconsistent. In general users should instead use
* {@link #constructBackplaneSnapshot} for simple use cases or {@link #callDataSnapshotFunction} for more advanced
* uses.
*
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/select/FormulaColumn.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/select/FormulaColumn.java
index a1f229cb58f..670b2ff1f51 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/select/FormulaColumn.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/select/FormulaColumn.java
@@ -35,8 +35,8 @@ default boolean hasConstantValue() {
}
/**
- * Returns true if the formula expression of the column has Array Access that conforms to "i +/- " or "ii
- * +/- " .
+ * Returns true if the formula expression of the column has Array Access that conforms to "i +/- <constant>"
+ * or "ii +/- <constant>".
*
* @return true or false
*/
@@ -46,8 +46,8 @@ default boolean hasConstantArrayAccess() {
/**
* Returns a Pair object consisting of formula string and shift to column MatchPairs. If the column formula or
- * expression has Array Access that conforms to "i +/- " or "ii +/- " . If there is a parsing
- * error for the expression null is returned.
+ * expression has Array Access that conforms to "i +/- <constant>" or "ii +/- <constant>". If there is a
+ * parsing error for the expression null is returned.
*
* @return Pair of final formula string and shift to column MatchPairs.
*/
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/sources/FillUnordered.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/sources/FillUnordered.java
index f12a524e71b..604c565d368 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/sources/FillUnordered.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/sources/FillUnordered.java
@@ -19,7 +19,7 @@ public interface FillUnordered {
*
*
* destination.setSize(keys.size());
- * for (int ii = 0; ii < keys.size(); ++ii) {
+ * for (int ii = 0; ii < keys.size(); ++ii) {
* destination.set(ii, get(keys.get(ii)));
* }
*
@@ -41,7 +41,7 @@ void fillChunkUnordered(
*
*
* destination.setSize(keys.size());
- * for (int ii = 0; ii < keys.size(); ++ii) {
+ * for (int ii = 0; ii < keys.size(); ++ii) {
* destination.set(ii, getPrev(keys.get(ii)));
* }
*
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigDecimalEmStdOperator.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigDecimalEmStdOperator.java
index 61e085865b2..2ec30bfc4c2 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigDecimalEmStdOperator.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigDecimalEmStdOperator.java
@@ -21,7 +21,7 @@
* Compute an exponential moving standard deviation for a BigDecimal column source. The output is expressed as a
* BigDecimal value and is computed using the following formula:
*
- * variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ * variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
*
* This function is described in the following document:
*
@@ -58,7 +58,7 @@ public void accumulateCumulative(@NotNull final RowSequence inputKeys,
curVariance = BigDecimal.ZERO;
curVal = null;
} else {
- // incremental variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ // incremental variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
curVariance = opAlpha.multiply(
curVariance.add(
opOneMinusAlpha.multiply(input.subtract(curEma).pow(2, mathContext)),
@@ -100,7 +100,7 @@ public void accumulateCumulative(@NotNull final RowSequence inputKeys,
oneMinusAlpha = computeOneMinusAlpha(alpha);
lastDt = dt;
}
- // incremental variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ // incremental variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
curVariance = alpha.multiply(
curVariance.add(
oneMinusAlpha.multiply(input.subtract(curEma).pow(2, mathContext)),
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigIntegerEmStdOperator.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigIntegerEmStdOperator.java
index 3b0a71e0434..62ddb7865d4 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigIntegerEmStdOperator.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/updateby/emstd/BigIntegerEmStdOperator.java
@@ -22,7 +22,7 @@
* Compute an exponential moving standard deviation for a BigInteger column source. The output is expressed as a
* BigDecimal value and is computed using the following formula:
*
- * variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ * variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
*
* This function is described in the following document:
*
@@ -59,7 +59,7 @@ public void accumulateCumulative(@NotNull final RowSequence inputKeys,
curVariance = BigDecimal.ZERO;
curVal = null;
} else {
- // incremental variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ // incremental variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
curVariance = opAlpha.multiply(
curVariance.add(
opOneMinusAlpha.multiply(decInput.subtract(curEma).pow(2, mathContext)), mathContext),
@@ -101,7 +101,7 @@ public void accumulateCumulative(@NotNull final RowSequence inputKeys,
oneMinusAlpha = computeOneMinusAlpha(alpha);
lastDt = dt;
}
- // incremental variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ // incremental variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
curVariance = alpha.multiply(
curVariance.add(
oneMinusAlpha.multiply(decInput.subtract(curEma).pow(2, mathContext)), mathContext),
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/util/RuntimeMemory.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/util/RuntimeMemory.java
index c2f82968d30..bdef8babbc5 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/util/RuntimeMemory.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/util/RuntimeMemory.java
@@ -16,10 +16,11 @@
* Cache memory utilization.
*
*
- * >Calling Runtime.getRuntime().freeMemory() is expensive; and we may do it a lot when we have automatically computed
+ * Calling Runtime.getRuntime().freeMemory() is expensive; and we may do it a lot when we have automatically computed
* tables, such as in a partitionBy. Instead of calling the runtime directly from the performance instrumentation
* framework, we call this class's methods; which cache the result for a configurable number of milliseconds to avoid
- * repeated calls that are not likely any different./p>
+ * repeated calls that are not likely any different.
+ *
*
*
* Additionally, we log our JVM heap usage on a regular basis; to enable users to quickly examine their worker logs and
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/util/TableTimeConversions.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/util/TableTimeConversions.java
index 6ebd43cb554..021e2bc14d7 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/util/TableTimeConversions.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/util/TableTimeConversions.java
@@ -30,7 +30,7 @@
*
*
* baseTable = db.i("Market", "Trades")
- * .where("Date > 2021-10-01")
+ * .where("Date > 2021-10-01")
*
* startTime = LocalTime.of(10,30,00)
* endTime = LocalTime.of(16,30,00)
diff --git a/engine/table/src/main/java/io/deephaven/engine/util/Formatter.java b/engine/table/src/main/java/io/deephaven/engine/util/Formatter.java
index 2f9904ef1d2..c672a0adee8 100644
--- a/engine/table/src/main/java/io/deephaven/engine/util/Formatter.java
+++ b/engine/table/src/main/java/io/deephaven/engine/util/Formatter.java
@@ -12,9 +12,9 @@
*/
public class Formatter {
/**
- * Add new lines and indentation to a String produced by {@link TableDataService#toString()}
+ * Add new lines and indentation to a String produced by {@link Object#toString()}
*
- * @param tdsStr the output of {@link TableDataService#toString()}
+ * @param tdsStr the output of {@link Object#toString()}
* @return the same string with newlines and tabs.
*/
@ScriptApi
diff --git a/engine/table/src/main/java/io/deephaven/engine/util/PythonScope.java b/engine/table/src/main/java/io/deephaven/engine/util/PythonScope.java
index ac1f4010fa2..8368a8a3aef 100644
--- a/engine/table/src/main/java/io/deephaven/engine/util/PythonScope.java
+++ b/engine/table/src/main/java/io/deephaven/engine/util/PythonScope.java
@@ -86,7 +86,7 @@ default boolean containsKey(String name) {
}
/**
- * Equivalent to {@link #getValueRaw(String)}.map({@link #convertValue(PyObj)})
+ * Equivalent to {@link #getValueRaw(String)}.map({@link #convertValue(Object)})
*
* @param name the name of the python variable
* @return the converted object value, or empty
@@ -110,7 +110,7 @@ default Optional getValue(String name, Class clazz) {
}
/**
- * Equivalent to {@link #getValue(String)}.map(x -> (T)x);
+ * Equivalent to {@link #getValue(String)}.map(x -> (T)x);
*
* @param name the name of the python variable
* @param the return type
@@ -123,7 +123,7 @@ default Optional getValueUnchecked(String name) {
}
/**
- * Equivalent to {@link #getKeysRaw()}.map({@link #convertStringKey(PyObj)})
+ * Equivalent to {@link #getKeysRaw()}.map({@link #convertStringKey(Object)})
*
* @return the string keys
*/
@@ -133,8 +133,8 @@ default Stream getKeys() {
}
/**
- * Equivalent to {@link #getEntriesRaw()}, where the keys have been converted via {@link #convertStringKey(PyObj)}
- * and the values via {@link #convertValue(PyObj)}
+ * Equivalent to {@link #getEntriesRaw()}, where the keys have been converted via {@link #convertStringKey(Object)}
+ * and the values via {@link #convertValue(Object)}.
*
* @return the string keys and converted values
*/
diff --git a/engine/table/src/main/java/io/deephaven/engine/util/file/FileHandle.java b/engine/table/src/main/java/io/deephaven/engine/util/file/FileHandle.java
index 80fdfc78450..effdbfbbbcc 100644
--- a/engine/table/src/main/java/io/deephaven/engine/util/file/FileHandle.java
+++ b/engine/table/src/main/java/io/deephaven/engine/util/file/FileHandle.java
@@ -203,7 +203,7 @@ public final int read(@NotNull final ByteBuffer destination) throws IOException
/**
*
- * Attempt to write {@code source.remaining(){} bytes, starting from {@code position} (0-indexed) in the file.
+ * Attempt to write {@code source.remaining()} bytes, starting from {@code position} (0-indexed) in the file.
*
* See {@link FileChannel#write(ByteBuffer, long)}.
*
diff --git a/engine/table/src/main/java/io/deephaven/engine/util/string/StringUtils.java b/engine/table/src/main/java/io/deephaven/engine/util/string/StringUtils.java
index 698220fa709..3af9fc84dd2 100644
--- a/engine/table/src/main/java/io/deephaven/engine/util/string/StringUtils.java
+++ b/engine/table/src/main/java/io/deephaven/engine/util/string/StringUtils.java
@@ -122,7 +122,7 @@ public String getKey(@NotNull final VALUE_TYPE value) {
* Generic accessor for the singleton StringKey instance.
*
* @param The type of the value for this key implementation
- * @return A String->StringKeyedObject key representation instance.
+ * @return A String->StringKeyedObject key representation instance.
*/
@SuppressWarnings("unused")
public static KeyedObjectKey.Basic stringKey() {
@@ -149,7 +149,7 @@ public String getKey(@NotNull final VALUE_TYPE value) {
* Generic accessor for the singleton NullSafeStringKey instance.
*
* @param The type of the value for this key implementation
- * @return A String->StringKeyedObject key representation instance that supports null keys.
+ * @return A String->StringKeyedObject key representation instance that supports null keys.
*/
@SuppressWarnings("unused")
public static KeyedObjectKey.NullSafeBasic nullSafeStringKey() {
@@ -188,7 +188,7 @@ public String getKey(@NotNull final VALUE_TYPE value) {
* Generic accessor for the singleton StringKeyedObjectKey instance.
*
* @param The type of the value for this key implementation
- * @return A String->StringKeyedObject key representation instance.
+ * @return A String->StringKeyedObject key representation instance.
*/
@SuppressWarnings("unused")
public static KeyedObjectKey.Basic stringKeyedObjectKey() {
@@ -217,7 +217,7 @@ public String getKey(@NotNull final VALUE_TYPE value) {
* Generic accessor for the singleton NullSafeStringKeyedObjectKey instance.
*
* @param The type of the value for this key implementation
- * @return A String->StringKeyedObject key representation instance that supports null keys.
+ * @return A String->StringKeyedObject key representation instance that supports null keys.
*/
@SuppressWarnings("unused")
public static KeyedObjectKey.NullSafeBasic nullSafeStringKeyedObjectKey() {
@@ -262,7 +262,7 @@ public boolean equalKey(@NotNull final CharSequence key, @NotNull final VALUE_TY
* Generic accessor for the singleton CharSequenceKey instance.
*
* @param The type of the value for this key implementation
- * @return A CharSequence->StringKeyedObject key representation instance.
+ * @return A CharSequence->StringKeyedObject key representation instance.
*/
public static KeyedObjectKey charSequenceKey() {
// noinspection unchecked
@@ -307,7 +307,7 @@ public boolean equalKey(final CharSequence key, @NotNull final VALUE_TYPE value)
* Generic accessor for the singleton CharSequenceKey instance, with support for null keys.
*
* @param The type of the value for this key implementation
- * @return A CharSequence->StringKeyedObject key representation instance.
+ * @return A CharSequence->StringKeyedObject key representation instance.
*/
@SuppressWarnings("unused")
public static KeyedObjectKey nullSafeCharSequenceKey() {
diff --git a/engine/table/src/main/java/io/deephaven/libs/GroovyStaticImports.java b/engine/table/src/main/java/io/deephaven/libs/GroovyStaticImports.java
index 941967ad098..4f99780eb8c 100644
--- a/engine/table/src/main/java/io/deephaven/libs/GroovyStaticImports.java
+++ b/engine/table/src/main/java/io/deephaven/libs/GroovyStaticImports.java
@@ -189,7 +189,7 @@ public class GroovyStaticImports {
public static double avg( io.deephaven.vector.LongVector values ) {return Numeric.avg( values );}
/** @see io.deephaven.function.Numeric#avg(io.deephaven.vector.ShortVector) */
public static double avg( io.deephaven.vector.ShortVector values ) {return Numeric.avg( values );}
- /** @see io.deephaven.function.BinSearch#binSearchIndex(T[],T,io.deephaven.function.BinSearchAlgo) */
+ /** @see io.deephaven.function.BinSearch#binSearchIndex(java.lang.Comparable[],java.lang.Comparable,io.deephaven.function.BinSearchAlgo) */
public static > int binSearchIndex( T[] values, T key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.binSearchIndex( values, key, choiceWhenEquals );}
/** @see io.deephaven.function.BinSearch#binSearchIndex(byte[],byte,io.deephaven.function.BinSearchAlgo) */
public static int binSearchIndex( byte[] values, byte key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.binSearchIndex( values, key, choiceWhenEquals );}
@@ -219,7 +219,7 @@ public class GroovyStaticImports {
public static int binSearchIndex( io.deephaven.vector.LongVector values, long key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.binSearchIndex( values, key, choiceWhenEquals );}
/** @see io.deephaven.function.BinSearch#binSearchIndex(io.deephaven.vector.ShortVector,short,io.deephaven.function.BinSearchAlgo) */
public static int binSearchIndex( io.deephaven.vector.ShortVector values, short key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.binSearchIndex( values, key, choiceWhenEquals );}
- /** @see io.deephaven.function.BinSearch#binSearchIndex(io.deephaven.vector.ObjectVector,T,io.deephaven.function.BinSearchAlgo) */
+ /** @see io.deephaven.function.BinSearch#binSearchIndex(io.deephaven.vector.ObjectVector,java.lang.Comparable,io.deephaven.function.BinSearchAlgo) */
public static > int binSearchIndex( io.deephaven.vector.ObjectVector values, T key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.binSearchIndex( values, key, choiceWhenEquals );}
/** @see io.deephaven.function.Cast#castDouble(byte) */
public static double castDouble( byte value ) {return Cast.castDouble( value );}
@@ -413,7 +413,7 @@ public class GroovyStaticImports {
public static long clamp( long value, long min, long max ) {return Numeric.clamp( value, min, max );}
/** @see io.deephaven.function.Numeric#clamp(short,short,short) */
public static short clamp( short value, short min, short max ) {return Numeric.clamp( value, min, max );}
- /** @see io.deephaven.function.Basic#concat(T[][]) */
+ /** @see io.deephaven.function.Basic#concat(java.lang.Object[][]) */
public static T[] concat( T[][] values ) {return Basic.concat( values );}
/** @see io.deephaven.function.Basic#concat(io.deephaven.vector.ByteVector[]) */
public static byte[] concat( io.deephaven.vector.ByteVector[] values ) {return Basic.concat( values );}
@@ -853,11 +853,11 @@ public class GroovyStaticImports {
public static long countDistinct( io.deephaven.vector.LongVector values, boolean countNull ) {return Basic.countDistinct( values, countNull );}
/** @see io.deephaven.function.Basic#countDistinct(io.deephaven.vector.ShortVector,boolean) */
public static long countDistinct( io.deephaven.vector.ShortVector values, boolean countNull ) {return Basic.countDistinct( values, countNull );}
- /** @see io.deephaven.function.Basic#countDistinctObj(T[]) */
+ /** @see io.deephaven.function.Basic#countDistinctObj(java.lang.Comparable[]) */
public static > long countDistinctObj( T[] values ) {return Basic.countDistinctObj( values );}
/** @see io.deephaven.function.Basic#countDistinctObj(io.deephaven.vector.ObjectVector) */
public static > long countDistinctObj( io.deephaven.vector.ObjectVector values ) {return Basic.countDistinctObj( values );}
- /** @see io.deephaven.function.Basic#countDistinctObj(T[],boolean) */
+ /** @see io.deephaven.function.Basic#countDistinctObj(java.lang.Comparable[],boolean) */
public static > long countDistinctObj( T[] values, boolean countNull ) {return Basic.countDistinctObj( values, countNull );}
/** @see io.deephaven.function.Basic#countDistinctObj(io.deephaven.vector.ObjectVector,boolean) */
public static > long countDistinctObj( io.deephaven.vector.ObjectVector values, boolean countNull ) {return Basic.countDistinctObj( values, countNull );}
@@ -897,7 +897,7 @@ public class GroovyStaticImports {
public static long countNeg( io.deephaven.vector.LongVector values ) {return Numeric.countNeg( values );}
/** @see io.deephaven.function.Numeric#countNeg(io.deephaven.vector.ShortVector) */
public static long countNeg( io.deephaven.vector.ShortVector values ) {return Numeric.countNeg( values );}
- /** @see io.deephaven.function.Basic#countObj(T[]) */
+ /** @see io.deephaven.function.Basic#countObj(java.lang.Object[]) */
public static long countObj( T[] values ) {return Basic.countObj( values );}
/** @see io.deephaven.function.Basic#countObj(io.deephaven.vector.ObjectVector) */
public static long countObj( io.deephaven.vector.ObjectVector values ) {return Basic.countObj( values );}
@@ -1461,11 +1461,11 @@ public class GroovyStaticImports {
public static long[] distinct( io.deephaven.vector.LongVector values, boolean includeNull ) {return Basic.distinct( values, includeNull );}
/** @see io.deephaven.function.Basic#distinct(io.deephaven.vector.ShortVector,boolean) */
public static short[] distinct( io.deephaven.vector.ShortVector values, boolean includeNull ) {return Basic.distinct( values, includeNull );}
- /** @see io.deephaven.function.Basic#distinctObj(T[]) */
+ /** @see io.deephaven.function.Basic#distinctObj(java.lang.Comparable[]) */
public static > T[] distinctObj( T[] values ) {return Basic.distinctObj( values );}
/** @see io.deephaven.function.Basic#distinctObj(io.deephaven.vector.ObjectVector) */
public static > T[] distinctObj( io.deephaven.vector.ObjectVector values ) {return Basic.distinctObj( values );}
- /** @see io.deephaven.function.Basic#distinctObj(T[],boolean) */
+ /** @see io.deephaven.function.Basic#distinctObj(java.lang.Comparable[],boolean) */
public static > T[] distinctObj( T[] values, boolean includeNull ) {return Basic.distinctObj( values, includeNull );}
/** @see io.deephaven.function.Basic#distinctObj(io.deephaven.vector.ObjectVector,boolean) */
public static > T[] distinctObj( io.deephaven.vector.ObjectVector values, boolean includeNull ) {return Basic.distinctObj( values, includeNull );}
@@ -1551,11 +1551,11 @@ public class GroovyStaticImports {
public static long firstIndexOf( short val, short[] values ) {return Basic.firstIndexOf( val, values );}
/** @see io.deephaven.function.Basic#firstIndexOf(short,io.deephaven.vector.ShortVector) */
public static long firstIndexOf( short val, io.deephaven.vector.ShortVector values ) {return Basic.firstIndexOf( val, values );}
- /** @see io.deephaven.function.Basic#firstIndexOfObj(T,T[]) */
+ /** @see io.deephaven.function.Basic#firstIndexOfObj(java.lang.Object,java.lang.Object[]) */
public static long firstIndexOfObj( T val, T[] values ) {return Basic.firstIndexOfObj( val, values );}
- /** @see io.deephaven.function.Basic#firstIndexOfObj(T,io.deephaven.vector.ObjectVector) */
+ /** @see io.deephaven.function.Basic#firstIndexOfObj(java.lang.Object,io.deephaven.vector.ObjectVector) */
public static long firstIndexOfObj( T val, io.deephaven.vector.ObjectVector values ) {return Basic.firstIndexOfObj( val, values );}
- /** @see io.deephaven.function.Basic#firstObj(T[]) */
+ /** @see io.deephaven.function.Basic#firstObj(java.lang.Object[]) */
public static T firstObj( T[] values ) {return Basic.firstObj( values );}
/** @see io.deephaven.function.Basic#firstObj(io.deephaven.vector.ObjectVector) */
public static T firstObj( io.deephaven.vector.ObjectVector values ) {return Basic.firstObj( values );}
@@ -1599,7 +1599,7 @@ public class GroovyStaticImports {
public static long[] forwardFill( io.deephaven.vector.LongVector values ) {return Basic.forwardFill( values );}
/** @see io.deephaven.function.Basic#forwardFill(io.deephaven.vector.ShortVector) */
public static short[] forwardFill( io.deephaven.vector.ShortVector values ) {return Basic.forwardFill( values );}
- /** @see io.deephaven.function.Basic#forwardFillObj(T[]) */
+ /** @see io.deephaven.function.Basic#forwardFillObj(java.lang.Object[]) */
public static T[] forwardFillObj( T[] values ) {return Basic.forwardFillObj( values );}
/** @see io.deephaven.function.Basic#forwardFillObj(io.deephaven.vector.ObjectVector) */
public static T[] forwardFillObj( io.deephaven.vector.ObjectVector values ) {return Basic.forwardFillObj( values );}
@@ -1673,13 +1673,13 @@ public class GroovyStaticImports {
public static long[] ifelse( io.deephaven.vector.ObjectVector condition, long trueCase, long falseCase ) {return Basic.ifelse( condition, trueCase, falseCase );}
/** @see io.deephaven.function.Basic#ifelse(io.deephaven.vector.ObjectVector,short,short) */
public static short[] ifelse( io.deephaven.vector.ObjectVector condition, short trueCase, short falseCase ) {return Basic.ifelse( condition, trueCase, falseCase );}
- /** @see io.deephaven.function.Basic#ifelseObj(java.lang.Boolean[],T,T) */
+ /** @see io.deephaven.function.Basic#ifelseObj(java.lang.Boolean[],java.lang.Object,java.lang.Object) */
public static T[] ifelseObj( java.lang.Boolean[] condition, T trueCase, T falseCase ) {return Basic.ifelseObj( condition, trueCase, falseCase );}
- /** @see io.deephaven.function.Basic#ifelseObj(java.lang.Boolean[],T[],T[]) */
+ /** @see io.deephaven.function.Basic#ifelseObj(java.lang.Boolean[],java.lang.Object[],java.lang.Object[]) */
public static T[] ifelseObj( java.lang.Boolean[] condition, T[] trueCase, T[] falseCase ) {return Basic.ifelseObj( condition, trueCase, falseCase );}
- /** @see io.deephaven.function.Basic#ifelseObj(java.lang.Boolean,T,T) */
+ /** @see io.deephaven.function.Basic#ifelseObj(java.lang.Boolean,java.lang.Object,java.lang.Object) */
public static T ifelseObj( java.lang.Boolean condition, T trueCase, T falseCase ) {return Basic.ifelseObj( condition, trueCase, falseCase );}
- /** @see io.deephaven.function.Basic#ifelseObj(io.deephaven.vector.ObjectVector,T,T) */
+ /** @see io.deephaven.function.Basic#ifelseObj(io.deephaven.vector.ObjectVector,java.lang.Object,java.lang.Object) */
public static T[] ifelseObj( io.deephaven.vector.ObjectVector condition, T trueCase, T falseCase ) {return Basic.ifelseObj( condition, trueCase, falseCase );}
/** @see io.deephaven.function.Basic#ifelseObj(io.deephaven.vector.ObjectVector,io.deephaven.vector.ObjectVector,io.deephaven.vector.ObjectVector) */
public static T[] ifelseObj( io.deephaven.vector.ObjectVector condition, io.deephaven.vector.ObjectVector trueCase, io.deephaven.vector.ObjectVector falseCase ) {return Basic.ifelseObj( condition, trueCase, falseCase );}
@@ -1697,11 +1697,11 @@ public class GroovyStaticImports {
public static boolean in( long testedValues, long[] possibleValues ) {return Basic.in( testedValues, possibleValues );}
/** @see io.deephaven.function.Basic#in(short,short[]) */
public static boolean in( short testedValues, short[] possibleValues ) {return Basic.in( testedValues, possibleValues );}
- /** @see io.deephaven.function.Basic#inObj(T,T[]) */
+ /** @see io.deephaven.function.Basic#inObj(java.lang.Object,java.lang.Object[]) */
public static boolean inObj( T testedValue, T[] possibleValues ) {return Basic.inObj( testedValue, possibleValues );}
- /** @see io.deephaven.function.Basic#inObj(T,io.deephaven.vector.ObjectVector) */
+ /** @see io.deephaven.function.Basic#inObj(java.lang.Object,io.deephaven.vector.ObjectVector) */
public static boolean inObj( T testedValue, io.deephaven.vector.ObjectVector possibleValues ) {return Basic.inObj( testedValue, possibleValues );}
- /** @see io.deephaven.function.Basic#inRange(T,T,T) */
+ /** @see io.deephaven.function.Basic#inRange(java.lang.Comparable,java.lang.Comparable,java.lang.Comparable) */
public static > boolean inRange( T testedValue, T lowInclusiveValue, T highInclusiveValue ) {return Basic.inRange( testedValue, lowInclusiveValue, highInclusiveValue );}
/** @see io.deephaven.function.Basic#inRange(byte,byte,byte) */
public static boolean inRange( byte testedValue, byte lowInclusiveValue, byte highInclusiveValue ) {return Basic.inRange( testedValue, lowInclusiveValue, highInclusiveValue );}
@@ -1753,7 +1753,7 @@ public class GroovyStaticImports {
public static long indexOfMax( io.deephaven.vector.LongVector values ) {return Numeric.indexOfMax( values );}
/** @see io.deephaven.function.Numeric#indexOfMax(io.deephaven.vector.ShortVector) */
public static long indexOfMax( io.deephaven.vector.ShortVector values ) {return Numeric.indexOfMax( values );}
- /** @see io.deephaven.function.Numeric#indexOfMaxObj(T[]) */
+ /** @see io.deephaven.function.Numeric#indexOfMaxObj(java.lang.Comparable[]) */
public static > long indexOfMaxObj( T[] values ) {return Numeric.indexOfMaxObj( values );}
/** @see io.deephaven.function.Numeric#indexOfMaxObj(io.deephaven.vector.ObjectVector) */
public static > long indexOfMaxObj( io.deephaven.vector.ObjectVector values ) {return Numeric.indexOfMaxObj( values );}
@@ -1793,7 +1793,7 @@ public class GroovyStaticImports {
public static long indexOfMin( io.deephaven.vector.LongVector values ) {return Numeric.indexOfMin( values );}
/** @see io.deephaven.function.Numeric#indexOfMin(io.deephaven.vector.ShortVector) */
public static long indexOfMin( io.deephaven.vector.ShortVector values ) {return Numeric.indexOfMin( values );}
- /** @see io.deephaven.function.Numeric#indexOfMinObj(T[]) */
+ /** @see io.deephaven.function.Numeric#indexOfMinObj(java.lang.Comparable[]) */
public static > long indexOfMinObj( T[] values ) {return Numeric.indexOfMinObj( values );}
/** @see io.deephaven.function.Numeric#indexOfMinObj(io.deephaven.vector.ObjectVector) */
public static > long indexOfMinObj( io.deephaven.vector.ObjectVector values ) {return Numeric.indexOfMinObj( values );}
@@ -1869,7 +1869,7 @@ public class GroovyStaticImports {
public static boolean isNaN( long value ) {return Numeric.isNaN( value );}
/** @see io.deephaven.function.Numeric#isNaN(short) */
public static boolean isNaN( short value ) {return Numeric.isNaN( value );}
- /** @see io.deephaven.function.Basic#isNull(T) */
+ /** @see io.deephaven.function.Basic#isNull(java.lang.Object) */
public static boolean isNull( T value ) {return Basic.isNull( value );}
/** @see io.deephaven.function.Basic#isNull(byte) */
public static boolean isNull( byte value ) {return Basic.isNull( value );}
@@ -1913,11 +1913,11 @@ public class GroovyStaticImports {
public static long last( io.deephaven.vector.LongVector values ) {return Basic.last( values );}
/** @see io.deephaven.function.Basic#last(io.deephaven.vector.ShortVector) */
public static short last( io.deephaven.vector.ShortVector values ) {return Basic.last( values );}
- /** @see io.deephaven.function.Basic#lastObj(T[]) */
+ /** @see io.deephaven.function.Basic#lastObj(java.lang.Object[]) */
public static T lastObj( T[] values ) {return Basic.lastObj( values );}
/** @see io.deephaven.function.Basic#lastObj(io.deephaven.vector.ObjectVector) */
public static T lastObj( io.deephaven.vector.ObjectVector values ) {return Basic.lastObj( values );}
- /** @see io.deephaven.function.Basic#len(T[]) */
+ /** @see io.deephaven.function.Basic#len(java.lang.Object[]) */
public static long len( T[] values ) {return Basic.len( values );}
/** @see io.deephaven.function.Basic#len(byte[]) */
public static long len( byte[] values ) {return Basic.len( values );}
@@ -2007,7 +2007,7 @@ public class GroovyStaticImports {
public static long max( io.deephaven.vector.LongVector values ) {return Numeric.max( values );}
/** @see io.deephaven.function.Numeric#max(io.deephaven.vector.ShortVector) */
public static short max( io.deephaven.vector.ShortVector values ) {return Numeric.max( values );}
- /** @see io.deephaven.function.Numeric#maxObj(T[]) */
+ /** @see io.deephaven.function.Numeric#maxObj(java.lang.Comparable[]) */
public static > T maxObj( T[] values ) {return Numeric.maxObj( values );}
/** @see io.deephaven.function.Numeric#maxObj(io.deephaven.vector.ObjectVector) */
public static > T maxObj( io.deephaven.vector.ObjectVector values ) {return Numeric.maxObj( values );}
@@ -2083,7 +2083,7 @@ public class GroovyStaticImports {
public static long min( io.deephaven.vector.LongVector values ) {return Numeric.min( values );}
/** @see io.deephaven.function.Numeric#min(io.deephaven.vector.ShortVector) */
public static short min( io.deephaven.vector.ShortVector values ) {return Numeric.min( values );}
- /** @see io.deephaven.function.Numeric#minObj(T[]) */
+ /** @see io.deephaven.function.Numeric#minObj(java.lang.Comparable[]) */
public static > T minObj( T[] values ) {return Numeric.minObj( values );}
/** @see io.deephaven.function.Numeric#minObj(io.deephaven.vector.ObjectVector) */
public static > T minObj( io.deephaven.vector.ObjectVector values ) {return Numeric.minObj( values );}
@@ -2119,7 +2119,7 @@ public class GroovyStaticImports {
public static long nth( long index, io.deephaven.vector.LongVector values ) {return Basic.nth( index, values );}
/** @see io.deephaven.function.Basic#nth(long,io.deephaven.vector.ShortVector) */
public static short nth( long index, io.deephaven.vector.ShortVector values ) {return Basic.nth( index, values );}
- /** @see io.deephaven.function.Basic#nthObj(long,T[]) */
+ /** @see io.deephaven.function.Basic#nthObj(long,java.lang.Object[]) */
public static T nthObj( long index, T[] values ) {return Basic.nthObj( index, values );}
/** @see io.deephaven.function.Basic#nthObj(long,io.deephaven.vector.ObjectVector) */
public static T nthObj( long index, io.deephaven.vector.ObjectVector values ) {return Basic.nthObj( index, values );}
@@ -2307,7 +2307,7 @@ public class GroovyStaticImports {
public static long randomLong( long min, long max ) {return Random.randomLong( min, max );}
/** @see io.deephaven.function.Random#randomLong(long,long,int) */
public static long[] randomLong( long min, long max, int size ) {return Random.randomLong( min, max, size );}
- /** @see io.deephaven.function.BinSearch#rawBinSearchIndex(T[],T,io.deephaven.function.BinSearchAlgo) */
+ /** @see io.deephaven.function.BinSearch#rawBinSearchIndex(java.lang.Comparable[],java.lang.Comparable,io.deephaven.function.BinSearchAlgo) */
public static > int rawBinSearchIndex( T[] values, T key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.rawBinSearchIndex( values, key, choiceWhenEquals );}
/** @see io.deephaven.function.BinSearch#rawBinSearchIndex(byte[],byte,io.deephaven.function.BinSearchAlgo) */
public static int rawBinSearchIndex( byte[] values, byte key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.rawBinSearchIndex( values, key, choiceWhenEquals );}
@@ -2337,9 +2337,9 @@ public class GroovyStaticImports {
public static int rawBinSearchIndex( io.deephaven.vector.LongVector values, long key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.rawBinSearchIndex( values, key, choiceWhenEquals );}
/** @see io.deephaven.function.BinSearch#rawBinSearchIndex(io.deephaven.vector.ShortVector,short,io.deephaven.function.BinSearchAlgo) */
public static int rawBinSearchIndex( io.deephaven.vector.ShortVector values, short key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.rawBinSearchIndex( values, key, choiceWhenEquals );}
- /** @see io.deephaven.function.BinSearch#rawBinSearchIndex(io.deephaven.vector.ObjectVector,T,io.deephaven.function.BinSearchAlgo) */
+ /** @see io.deephaven.function.BinSearch#rawBinSearchIndex(io.deephaven.vector.ObjectVector,java.lang.Comparable,io.deephaven.function.BinSearchAlgo) */
public static > int rawBinSearchIndex( io.deephaven.vector.ObjectVector values, T key, io.deephaven.function.BinSearchAlgo choiceWhenEquals ) {return BinSearch.rawBinSearchIndex( values, key, choiceWhenEquals );}
- /** @see io.deephaven.function.Basic#repeat(T,int) */
+ /** @see io.deephaven.function.Basic#repeat(java.lang.Object,int) */
public static T[] repeat( T value, int size ) {return Basic.repeat( value, size );}
/** @see io.deephaven.function.Basic#repeat(byte,int) */
public static byte[] repeat( byte value, int size ) {return Basic.repeat( value, size );}
@@ -2379,9 +2379,9 @@ public class GroovyStaticImports {
public static double[] replaceIfNonFinite( io.deephaven.vector.DoubleVector values, double replacement ) {return Numeric.replaceIfNonFinite( values, replacement );}
/** @see io.deephaven.function.Numeric#replaceIfNonFinite(io.deephaven.vector.FloatVector,float) */
public static float[] replaceIfNonFinite( io.deephaven.vector.FloatVector values, float replacement ) {return Numeric.replaceIfNonFinite( values, replacement );}
- /** @see io.deephaven.function.Basic#replaceIfNull(T,T) */
+ /** @see io.deephaven.function.Basic#replaceIfNull(java.lang.Object,java.lang.Object) */
public static T replaceIfNull( T value, T replacement ) {return Basic.replaceIfNull( value, replacement );}
- /** @see io.deephaven.function.Basic#replaceIfNull(T[],T) */
+ /** @see io.deephaven.function.Basic#replaceIfNull(java.lang.Object[],java.lang.Object) */
public static T[] replaceIfNull( T[] values, T replacement ) {return Basic.replaceIfNull( values, replacement );}
/** @see io.deephaven.function.Basic#replaceIfNull(byte,byte) */
public static byte replaceIfNull( byte value, byte replacement ) {return Basic.replaceIfNull( value, replacement );}
@@ -2421,7 +2421,7 @@ public class GroovyStaticImports {
public static long[] replaceIfNull( io.deephaven.vector.LongVector values, long replacement ) {return Basic.replaceIfNull( values, replacement );}
/** @see io.deephaven.function.Basic#replaceIfNull(io.deephaven.vector.ShortVector,short) */
public static short[] replaceIfNull( io.deephaven.vector.ShortVector values, short replacement ) {return Basic.replaceIfNull( values, replacement );}
- /** @see io.deephaven.function.Basic#replaceIfNull(io.deephaven.vector.ObjectVector,T) */
+ /** @see io.deephaven.function.Basic#replaceIfNull(io.deephaven.vector.ObjectVector,java.lang.Object) */
public static T[] replaceIfNull( io.deephaven.vector.ObjectVector values, T replacement ) {return Basic.replaceIfNull( values, replacement );}
/** @see io.deephaven.function.Basic#replaceIfNull(long,long) */
public static long replaceIfNull( long value, long replacement ) {return Basic.replaceIfNull( value, replacement );}
@@ -2467,7 +2467,7 @@ public class GroovyStaticImports {
public static long[] reverse( io.deephaven.vector.LongVector values ) {return Basic.reverse( values );}
/** @see io.deephaven.function.Basic#reverse(io.deephaven.vector.ShortVector) */
public static short[] reverse( io.deephaven.vector.ShortVector values ) {return Basic.reverse( values );}
- /** @see io.deephaven.function.Basic#reverseObj(T[]) */
+ /** @see io.deephaven.function.Basic#reverseObj(java.lang.Object[]) */
public static T[] reverseObj( T[] values ) {return Basic.reverseObj( values );}
/** @see io.deephaven.function.Basic#reverseObj(io.deephaven.vector.ObjectVector) */
public static T[] reverseObj( io.deephaven.vector.ObjectVector values ) {return Basic.reverseObj( values );}
@@ -2603,19 +2603,19 @@ public class GroovyStaticImports {
public static long[] sortDescending( io.deephaven.vector.LongVector values ) {return Sort.sortDescending( values );}
/** @see io.deephaven.function.Sort#sortDescending(io.deephaven.vector.ShortVector) */
public static short[] sortDescending( io.deephaven.vector.ShortVector values ) {return Sort.sortDescending( values );}
- /** @see io.deephaven.function.Sort#sortDescendingObj(T[]) */
+ /** @see io.deephaven.function.Sort#sortDescendingObj(java.lang.Comparable[]) */
public static > T[] sortDescendingObj( T[] values ) {return Sort.sortDescendingObj( values );}
/** @see io.deephaven.function.Sort#sortDescendingObj(io.deephaven.vector.ObjectVector) */
public static > T[] sortDescendingObj( io.deephaven.vector.ObjectVector values ) {return Sort.sortDescendingObj( values );}
- /** @see io.deephaven.function.Sort#sortDescendingObj(T[],java.util.Comparator) */
+ /** @see io.deephaven.function.Sort#sortDescendingObj(java.lang.Comparable[],java.util.Comparator) */
public static > T[] sortDescendingObj( T[] values, java.util.Comparator comparator ) {return Sort.sortDescendingObj( values, comparator );}
/** @see io.deephaven.function.Sort#sortDescendingObj(io.deephaven.vector.ObjectVector,java.util.Comparator) */
public static > T[] sortDescendingObj( io.deephaven.vector.ObjectVector values, java.util.Comparator comparator ) {return Sort.sortDescendingObj( values, comparator );}
- /** @see io.deephaven.function.Sort#sortObj(T[]) */
+ /** @see io.deephaven.function.Sort#sortObj(java.lang.Comparable[]) */
public static > T[] sortObj( T[] values ) {return Sort.sortObj( values );}
/** @see io.deephaven.function.Sort#sortObj(io.deephaven.vector.ObjectVector) */
public static > T[] sortObj( io.deephaven.vector.ObjectVector values ) {return Sort.sortObj( values );}
- /** @see io.deephaven.function.Sort#sortObj(T[],java.util.Comparator) */
+ /** @see io.deephaven.function.Sort#sortObj(java.lang.Comparable[],java.util.Comparator) */
public static > T[] sortObj( T[] values, java.util.Comparator comparator ) {return Sort.sortObj( values, comparator );}
/** @see io.deephaven.function.Sort#sortObj(io.deephaven.vector.ObjectVector,java.util.Comparator) */
public static > T[] sortObj( io.deephaven.vector.ObjectVector values, java.util.Comparator comparator ) {return Sort.sortObj( values, comparator );}
@@ -2863,7 +2863,7 @@ public class GroovyStaticImports {
public static io.deephaven.vector.LongVector vec( long[] values ) {return Basic.vec( values );}
/** @see io.deephaven.function.Basic#vec(short[]) */
public static io.deephaven.vector.ShortVector vec( short[] values ) {return Basic.vec( values );}
- /** @see io.deephaven.function.Basic#vecObj(T[]) */
+ /** @see io.deephaven.function.Basic#vecObj(java.lang.Object[]) */
public static io.deephaven.vector.ObjectVector vecObj( T[] values ) {return Basic.vecObj( values );}
/** @see io.deephaven.function.Numeric#wavg(byte[],byte[]) */
public static double wavg( byte[] values, byte[] weights ) {return Numeric.wavg( values, weights );}
diff --git a/engine/table/src/test/java/io/deephaven/engine/table/impl/updateby/TestEmStd.java b/engine/table/src/test/java/io/deephaven/engine/table/impl/updateby/TestEmStd.java
index 1a338d9fbae..f29aaffd115 100644
--- a/engine/table/src/test/java/io/deephaven/engine/table/impl/updateby/TestEmStd.java
+++ b/engine/table/src/test/java/io/deephaven/engine/table/impl/updateby/TestEmStd.java
@@ -917,7 +917,7 @@ public static double[] compute_emstd_ticks(OperationControl control, long ticks,
runningVariance = 0.0;
outputVal = Double.NaN;
} else {
- // incremental variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ // incremental variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
runningVariance = alpha * (runningVariance + oneMinusAlpha * Math.pow(values[i] - runningEma, 2.0));
final double decayedEmaVal = runningEma * alpha;
@@ -961,7 +961,7 @@ public static BigDecimal[] compute_emstd_ticks(OperationControl control, long ti
runningVariance = BigDecimal.ZERO;
outputVal = null;
} else {
- // incremental variance = alpha * (prevVariance + (1 − alpha) * (x − prevEma)^2)
+ // incremental variance = alpha * (prevVariance + (1 - alpha) * (x - prevEma)^2)
runningVariance = alpha.multiply(
runningVariance.add(
oneMinusAlpha.multiply(values[i].subtract(runningEma).pow(2, mathContextDefault)),
@@ -1027,7 +1027,7 @@ public static double[] compute_emstd_time(OperationControl control, long nanos,
final double alpha = Math.exp(-dt / (double) nanos);
final double oneMinusAlpha = 1.0 - alpha;
- // incremental variance = (1 − alpha)(prevVariance + alpha * (x − prevEma)^2)
+ // incremental variance = (1 - alpha)(prevVariance + alpha * (x - prevEma)^2)
runningVariance = alpha * (runningVariance + oneMinusAlpha * Math.pow(values[i] - runningEma, 2.0));
final double decayedEmaVal = runningEma * alpha;
diff --git a/engine/updategraph/src/main/java/io/deephaven/engine/updategraph/UpdateGraphProcessor.java b/engine/updategraph/src/main/java/io/deephaven/engine/updategraph/UpdateGraphProcessor.java
index a448ba1622d..0aaba5c8f62 100644
--- a/engine/updategraph/src/main/java/io/deephaven/engine/updategraph/UpdateGraphProcessor.java
+++ b/engine/updategraph/src/main/java/io/deephaven/engine/updategraph/UpdateGraphProcessor.java
@@ -54,8 +54,8 @@
*
* This class can be configured via the following {@link Configuration} property
*
- *
{@value DEFAULT_TARGET_CYCLE_DURATION_MILLIS_PROP}(optional) - The default target cycle time in ms (1000 if
- * not defined)
+ *
{@value DEFAULT_TARGET_CYCLE_DURATION_MILLIS_PROP}(optional) - The default target cycle time in ms (1000 if not
+ * defined)
*
*/
public enum UpdateGraphProcessor implements UpdateSourceRegistrar, NotificationQueue, NotificationQueue.Dependency {
diff --git a/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/BarragePerformanceLog.java b/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/BarragePerformanceLog.java
index 0061e529cd5..467f44401c1 100644
--- a/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/BarragePerformanceLog.java
+++ b/extensions/barrage/src/main/java/io/deephaven/extensions/barrage/BarragePerformanceLog.java
@@ -22,13 +22,13 @@
/**
* Enable barrage performance metrics by setting the {@code BarragePerformanceLog.enableAll} configuration property, or
* by adding the {@link io.deephaven.engine.table.Table#BARRAGE_PERFORMANCE_KEY_ATTRIBUTE table key} as an
- * {@link io.deephaven.engine.table.Table#withAttributes(Map) attribute} to the table.
+ * {@link Table#withAttributes(Map)} attribute} to the table.
*/
public class BarragePerformanceLog {
/**
* If all barrage performance logging is enabled by default, then table's description is used as TableKey unless
* overridden with the {@link io.deephaven.engine.table.Table#BARRAGE_PERFORMANCE_KEY_ATTRIBUTE table key}
- * {@link io.deephaven.engine.table.Table#withAttributes(Map) attribute}.
+ * {@link Table#withAttributes(Map)} attribute}.
*/
public static final boolean ALL_PERFORMANCE_ENABLED = Configuration.getInstance().getBooleanForClassWithDefault(
BarragePerformanceLog.class, "enableAll", true);
diff --git a/extensions/jdbc/src/main/java/io/deephaven/jdbc/JdbcToTableAdapter.java b/extensions/jdbc/src/main/java/io/deephaven/jdbc/JdbcToTableAdapter.java
index 83181f417f2..ec672ab8a4f 100644
--- a/extensions/jdbc/src/main/java/io/deephaven/jdbc/JdbcToTableAdapter.java
+++ b/extensions/jdbc/src/main/java/io/deephaven/jdbc/JdbcToTableAdapter.java
@@ -38,10 +38,11 @@
/**
* The JdbcToTableAdapter class provides a simple interface to convert a Java Database Connectivity (JDBC)
* {@link ResultSet} to a Deephaven {@link Table}.
- *
*
+ *
* To use, first create a result set using your provided JDBC driver of choice:
- *
+ *
+ *
*
* Connection connection = DriverManager.getConnection("jdbc:sqlite:/path/to/db.sqlite");
* Statement statement = connection.createStatement();
diff --git a/extensions/kafka/src/main/java/io/deephaven/kafka/CdcTools.java b/extensions/kafka/src/main/java/io/deephaven/kafka/CdcTools.java
index 448948764cb..96875566a94 100644
--- a/extensions/kafka/src/main/java/io/deephaven/kafka/CdcTools.java
+++ b/extensions/kafka/src/main/java/io/deephaven/kafka/CdcTools.java
@@ -204,7 +204,7 @@ public static CdcSpec cdcLongSpec(
* @param topic The Kafka topic for the CDC events associated to the desired table data.
* @param keySchemaName The schema name for the Key Kafka field in the CDC events for the topic. This schema should
* include definitions for the columns forming the PRIMARY KEY of the underlying table.
- * @parar keySchemaVersion The version for the Key schema to look up in schema server.
+ * @param keySchemaVersion The version for the Key schema to look up in schema server.
* @param valueSchemaName The schema name for the Value Kafka field in the CDC events for the topic. This schema
* should include definitions for all the columns of the underlying table.
* @param valueSchemaVersion The version for the Value schema to look up in schema server.
diff --git a/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java b/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java
index 5e20e0fad68..26646ac88cd 100644
--- a/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java
+++ b/extensions/kafka/src/main/java/io/deephaven/kafka/KafkaTools.java
@@ -994,8 +994,8 @@ public static KeyOrValueSpec simpleSpec(final String columnName) {
* @param includeColumns An array with an entry for each column intended to be included in the JSON output. If
* null, include all columns except those specified in {@code excludeColumns}. If {@code includeColumns}
* is not null, {@code excludeColumns} should be null.
- * @param excludeColumns A set specifying column names to ommit; can only be used when {@columnNames} is null.
- * In this case all table columns except for the ones in {@code excludeColumns} will be included.
+ * @param excludeColumns A set specifying column names to omit; can only be used when {@code columnNames} is
+ * null. In this case all table columns except for the ones in {@code excludeColumns} will be included.
* @param columnToFieldMapping A map from column name to JSON field name to use for that column. Any column
* names implied by earlier arguments not included as a key in the map will be mapped to JSON fields of
* the same name. If null, map all columns to fields of the same name.
@@ -1038,8 +1038,9 @@ public static KeyOrValueSpec jsonSpec(
* @param includeColumns An array with an entry for each column intended to be included in the JSON output. If
* null, include all columns except those specified in {@code excludeColumns}. If {@code includeColumns}
* is not null, {@code excludeColumns} should be null.
- * @param excludeColumns A predicate specifying column names to ommit; can only be used when {@columnNames} is
- * null. In this case all table columns except for the ones in {@code excludeColumns} will be included.
+ * @param excludeColumns A predicate specifying column names to omit; can only be used when {@code columnNames}
+ * is null. In this case all table columns except for the ones in {@code excludeColumns} will be
+ * included.
* @param columnToFieldMapping A map from column name to JSON field name to use for that column. Any column
* names implied by earlier arguments not included as a key in the map will be mapped to JSON fields of
* the same name. If null, map all columns to fields of the same name.
diff --git a/extensions/kafka/src/main/java/io/deephaven/kafka/ingest/KafkaIngester.java b/extensions/kafka/src/main/java/io/deephaven/kafka/ingest/KafkaIngester.java
index a9f80358b59..a2d980a27d9 100644
--- a/extensions/kafka/src/main/java/io/deephaven/kafka/ingest/KafkaIngester.java
+++ b/extensions/kafka/src/main/java/io/deephaven/kafka/ingest/KafkaIngester.java
@@ -160,7 +160,7 @@ public String toString() {
* @param topic The topic to replicate
* @param partitionToStreamConsumer A function implementing a mapping from partition to its consumer of records. The
* function will be invoked once per partition at construction; implementations should internally defer
- * resource allocation until first call to {@link KafkaStreamConsumer#consume(Object)} or
+ * resource allocation until first call to {@link KafkaStreamConsumer#consume(List)} or
* {@link KafkaStreamConsumer#acceptFailure(Throwable)} if appropriate.
* @param partitionToInitialSeekOffset A function implementing a mapping from partition to its initial seek offset,
* or -1 if seek to beginning is intended.
@@ -189,7 +189,7 @@ public KafkaIngester(final Logger log,
* @param partitionFilter A predicate indicating which partitions we should replicate
* @param partitionToStreamConsumer A function implementing a mapping from partition to its consumer of records. The
* function will be invoked once per partition at construction; implementations should internally defer
- * resource allocation until first call to {@link KafkaStreamConsumer#consume(Object)} or
+ * resource allocation until first call to {@link KafkaStreamConsumer#consume(List)} or
* {@link KafkaStreamConsumer#acceptFailure(Throwable)} if appropriate.
* @param partitionToInitialSeekOffset A function implementing a mapping from partition to its initial seek offset,
* or -1 if seek to beginning is intended.
diff --git a/hotspot/src/main/java/io/deephaven/hotspot/JvmIntrospectionContext.java b/hotspot/src/main/java/io/deephaven/hotspot/JvmIntrospectionContext.java
index bebfa716595..3db7232500e 100644
--- a/hotspot/src/main/java/io/deephaven/hotspot/JvmIntrospectionContext.java
+++ b/hotspot/src/main/java/io/deephaven/hotspot/JvmIntrospectionContext.java
@@ -6,12 +6,15 @@
/**
* Utility class to facilitate obtaining data for safepoint pauses count and time between two points in code. A
* safepoint pause is a "stop the world, pause all threads" event in the HotSpot JVM. Note full Garbage Collection
- * pauses are a dominant cause of safepoint pauses, but there are other triggers like:
+ * pauses are a dominant cause of safepoint pauses, but there are other triggers like:
+ *
*
+ *
+ * And others; you can see a full list
* here .
*
diff --git a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java
index 3c2083b1816..746b4408f66 100644
--- a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java
+++ b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSnapshot.java
@@ -62,7 +62,8 @@ BarrageSnapshot snapshot(TableSpec tableSpec, BarrageSnapshotOptions options)
*
* @param viewport the position-space viewport to use for the snapshot
* @param columns the columns to include in the snapshot
- * @param reverseViewport Whether to treat {@code posRowSet} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code posRowSet} as offsets from
+ * {@link io.deephaven.engine.table.Table#size()} rather than {@code 0}
*
* @return the {@code BarrageTable}
*/
diff --git a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java
index 88d769a9c7e..8d68f52d0a9 100644
--- a/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java
+++ b/java-client/barrage/src/main/java/io/deephaven/client/impl/BarrageSubscription.java
@@ -90,7 +90,8 @@ BarrageSubscription subscribe(TableSpec tableSpec, BarrageSubscriptionOptions op
*
* @param viewport the position-space viewport to use for the subscription
* @param columns the columns to include in the subscription
- * @param reverseViewport Whether to treat {@code posRowSet} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code posRowSet} as offsets from
+ * {@link io.deephaven.engine.table.Table#size()} rather than {@code 0}
*
* @return the {@code BarrageTable}
*/
@@ -102,7 +103,8 @@ BarrageSubscription subscribe(TableSpec tableSpec, BarrageSubscriptionOptions op
*
* @param viewport the position-space viewport to use for the subscription
* @param columns the columns to include in the subscription
- * @param reverseViewport Whether to treat {@code posRowSet} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code posRowSet} as offsets from
+ * {@link io.deephaven.engine.table.Table#size()} rather than {@code 0}
* @param blockUntilComplete block execution until the subscribed table viewport is satisfied
*
* @return the {@code BarrageTable}
@@ -146,7 +148,8 @@ BarrageTable partialTable(RowSet viewport, BitSet columns, boolean reverseViewpo
*
* @param viewport the position-space viewport to use for the subscription
* @param columns the columns to include in the subscription
- * @param reverseViewport Whether to treat {@code posRowSet} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code posRowSet} as offsets from
+ * {@link io.deephaven.engine.table.Table#size()} rather than {@code 0}
*
* @return the {@code BarrageTable}
*/
@@ -159,7 +162,8 @@ BarrageTable snapshotPartialTable(RowSet viewport, BitSet columns, boolean rever
*
* @param viewport the position-space viewport to use for the subscription
* @param columns the columns to include in the subscription
- * @param reverseViewport Whether to treat {@code posRowSet} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code posRowSet} as offsets from
+ * {@link io.deephaven.engine.table.Table#size()} rather than {@code 0}
* @param blockUntilComplete block execution until the subscribed table viewport is satisfied
*
* @return the {@code BarrageTable}
diff --git a/java-client/session/src/main/java/io/deephaven/client/impl/TableHandleManager.java b/java-client/session/src/main/java/io/deephaven/client/impl/TableHandleManager.java
index 8205455ed68..f10073681e3 100644
--- a/java-client/session/src/main/java/io/deephaven/client/impl/TableHandleManager.java
+++ b/java-client/session/src/main/java/io/deephaven/client/impl/TableHandleManager.java
@@ -16,7 +16,8 @@
import java.util.List;
/**
- * A table handle manager is able to execute {@linkplain TableSpec tables}, {@link }
+ * A table handle manager is able to execute commands that produce tables, by accepting {@link TableSpec}s,
+ * {@link TableCreationLogic}s, and more.
*/
public interface TableHandleManager extends TableCreator {
diff --git a/py/jpy-ext/src/main/java/io/deephaven/jpy/BuiltinsModule.java b/py/jpy-ext/src/main/java/io/deephaven/jpy/BuiltinsModule.java
index 2d6c583a71a..028531218ea 100644
--- a/py/jpy-ext/src/main/java/io/deephaven/jpy/BuiltinsModule.java
+++ b/py/jpy-ext/src/main/java/io/deephaven/jpy/BuiltinsModule.java
@@ -41,7 +41,7 @@ static BuiltinsModule create() {
* Create a new dictionary.
*
* @return the dictionary
- * @see dict
*/
PyObject dict();
diff --git a/server/src/main/java/io/deephaven/server/config/ServerConfig.java b/server/src/main/java/io/deephaven/server/config/ServerConfig.java
index b572b377044..82561fe838d 100644
--- a/server/src/main/java/io/deephaven/server/config/ServerConfig.java
+++ b/server/src/main/java/io/deephaven/server/config/ServerConfig.java
@@ -75,12 +75,14 @@ public interface ServerConfig {
*
* Also parses {@link MainHelper#parseSSLConfig(Configuration)} into {@link Builder#ssl(SSLConfig)} and
* {@link MainHelper#parseOutboundSSLConfig(Configuration)} into {@link Builder#outboundSsl(SSLConfig)}.
- *
+ *
+ * See {@link MainHelper#parseSSLConfig(Configuration)} for {@link Builder#ssl(SSLConfig)}.
+ *
+ *
* @param builder the builder
* @param config the configuration
* @return the builder
* @param the builder type
- * @see MainHelper#parseSSLConfig(Configuration) for {@link Builder#ssl(SSLConfig)}
*/
static > B buildFromConfig(B builder, Configuration config) {
int httpSessionExpireMs = config.getIntegerWithDefault(HTTP_SESSION_DURATION_MS, -1);
diff --git a/server/src/main/java/io/deephaven/server/uri/BarrageTableResolver.java b/server/src/main/java/io/deephaven/server/uri/BarrageTableResolver.java
index 8a9a25fd7d8..d69bbe38abc 100644
--- a/server/src/main/java/io/deephaven/server/uri/BarrageTableResolver.java
+++ b/server/src/main/java/io/deephaven/server/uri/BarrageTableResolver.java
@@ -169,7 +169,8 @@ public Table subscribe(String targetUri, TableSpec table, RowSet viewport, BitSe
* @param table the table spec
* @param viewport the position-space viewport to use for the subscription
* @param columns the columns to include in the subscription
- * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link Table#size()} rather than
+ * {@code 0}
* @return the subscribed table
*/
public Table subscribe(String targetUri, TableSpec table, RowSet viewport, BitSet columns, boolean reverseViewport)
@@ -186,7 +187,8 @@ public Table subscribe(String targetUri, TableSpec table, RowSet viewport, BitSe
* @param options the options
* @param viewport the position-space viewport to use for the subscription
* @param columns the columns to include in the subscription
- * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link Table#size()} rather than
+ * {@code 0}
* @return the subscribed table
*/
public Table subscribe(DeephavenTarget target, TableSpec table, BarrageSubscriptionOptions options, RowSet viewport,
@@ -262,7 +264,8 @@ public Table snapshot(String targetUri, TableSpec table, RowSet viewport, BitSet
* @param table the table spec
* @param viewport the position-space viewport to use for the snapshot
* @param columns the columns to include in the snapshot
- * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link Table#size()} rather than
+ * {@code 0}
* @return the table to snapshot
*/
public Table snapshot(String targetUri, TableSpec table, RowSet viewport, BitSet columns, boolean reverseViewport)
@@ -279,7 +282,8 @@ public Table snapshot(String targetUri, TableSpec table, RowSet viewport, BitSet
* @param options the options
* @param viewport the position-space viewport to use for the snapshot
* @param columns the columns to include in the snapshot
- * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link #size()} rather than {@code 0}
+ * @param reverseViewport Whether to treat {@code viewport} as offsets from {@link Table#size()} rather than
+ * {@code 0}
* @return the table to snapshot
*/
public Table snapshot(DeephavenTarget target, TableSpec table, BarrageSubscriptionOptions options, RowSet viewport,
diff --git a/ssl/config/src/main/java/io/deephaven/ssl/config/package-info.java b/ssl/config/src/main/java/io/deephaven/ssl/config/package-info.java
index dba19431751..2ac8087976d 100644
--- a/ssl/config/src/main/java/io/deephaven/ssl/config/package-info.java
+++ b/ssl/config/src/main/java/io/deephaven/ssl/config/package-info.java
@@ -8,7 +8,7 @@
* JSON. It is meant to service the majority of server and client SSL configuration use-cases.
*
*
- * While not exposed to the end-user, the overall configuration structure is guided by sslcontext-kickstart.
*/
package io.deephaven.ssl.config;
diff --git a/table-api/src/main/java/io/deephaven/api/TableOperations.java b/table-api/src/main/java/io/deephaven/api/TableOperations.java
index d9e0135e66f..6b6b6cfc92f 100644
--- a/table-api/src/main/java/io/deephaven/api/TableOperations.java
+++ b/table-api/src/main/java/io/deephaven/api/TableOperations.java
@@ -524,7 +524,7 @@ TOPS asOfJoin(
*
A single-value range is a range where the left row’s values for the left start column and left end
* column are equal and both relative matches are inclusive ({@code <=} and {@code >=}, respectively). For a
* single-value range, only rows within the bucket where the right range column matches the single value are
- * included in the output aggregations.
+ * included in the output aggregations.
*
invalid ranges
*
An invalid range occurs in two scenarios: First, when the range is inverted, i.e. when the value of
* the left start column is greater than the value of the left end column. Second, when either relative-match is
@@ -568,9 +568,9 @@ TOPS rangeJoin(
* Perform a range join with {@code rightTable}. For each row in {@code this} Table, this operation joins
* {@link Aggregation aggregations} over a range of responsive rows from {@code rightTable} according to
* zero-or-more exact join matches and one range join match. The operation is performed
- * identically to {@link #rangeJoin(TABLE, Collection, RangeJoinMatch, Collection)}, after parsing is applied to the
- * elements of {@code columnsToMatch} to produce the {@link JoinMatch exact join matches} and {@link RangeJoinMatch
- * range join match}.
+ * identically to {@link #rangeJoin(Object, Collection, RangeJoinMatch, Collection)}, after parsing is applied to
+ * the elements of {@code columnsToMatch} to produce the {@link JoinMatch exact join matches} and
+ * {@link RangeJoinMatch range join match}.
*
*
{@code columnsToMatch} Parsing
*
@@ -605,7 +605,7 @@ TOPS rangeJoin(
*
For {@link RangeStartRule#LESS_THAN less than} paired with {@link RangeEndRule#GREATER_THAN greater than}:
*
*