Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ Supplier<List<AccumulatorWrapper<Row>>> accumulatorsFactory(
*
* @param left Collations of left row.
* @param right Collations of right row.
* @param allowNulls Matching null fields. Usually, NULL <> NULL in SQL. Except IS DISTINCT / IS NOT DISTINCT.
* @param allowNulls Matching null fields. Usually, {@code NULL <> NULL} in SQL. Except IS DISTINCT / IS NOT DISTINCT.
* @return Rows comparator.
*/
Comparator<Row> comparator(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -311,15 +311,15 @@ public static boolean gtAny(Object a, Object b) {
return SqlFunctions.gtAny(a, b);
}

/** SQL <=. */
/** SQL {@code <=}. */
public static boolean leAny(Object a, Object b) {
if (Commons.isBinaryComparable(a, b))
return Commons.compareBinary(a, b) <= 0;

return SqlFunctions.leAny(a, b);
}

/** SQL <. */
/** SQL {@code <}. */
public static boolean ltAny(Object a, Object b) {
if (Commons.isBinaryComparable(a, b))
return Commons.compareBinary(a, b) < 0;
Expand All @@ -335,7 +335,7 @@ public static boolean eqAny(Object a, Object b) {
return SqlFunctions.eqAny(a, b);
}

/** SQL <>. */
/** SQL {@code <>}. */
public static boolean neAny(Object a, Object b) {
if (Commons.isBinaryComparable(a, b))
return Commons.compareBinary(a, b) != 0;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ public interface FieldsMetadata {

/**
* @param typeFactory Type factory.
* @return Query field descriptors collection&
* @return Query field descriptors collection.
*/
List<GridQueryFieldMetadata> queryFieldsMetadata(IgniteTypeFactory typeFactory);
}
Original file line number Diff line number Diff line change
Expand Up @@ -126,7 +126,7 @@ public class IgniteOwnSqlOperatorTable extends ReflectiveSqlOperatorTable {
OperandTypes.SAME_SAME,
SqlFunctionCategory.SYSTEM);

/** Bitwise '&' of two values. */
/** Bitwise {@code &} of two values. */
public static final SqlFunction BITAND =
new SqlFunction(
"BITAND",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -436,7 +436,7 @@ private void testSelect(int sz, boolean withIn, String column) {
res.stream().map(row -> row.get(0)).sorted().collect(Collectors.toList())
);
},
IntStream.of(values).boxed().toArray(Integer[]::new));
IntStream.of(values).boxed().toArray());
}

/** */
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,13 +31,13 @@
* Represents a storage of {@link OperationContextAttribute}s and their corresponding values bound to the JVM thread.
* The state of {@link OperationContext} is determined by a sequence of {@link Update}s applied to it. Each Update
* stores the updated or newly added {@link OperationContextAttribute} values and link to the previous Update.
* <pre>
* <pre>{@code
* +-----------+ +-----------+
* | | | A1 -> V2 |
* null <--| A1 -> V1 |<--| |
* | | | A2 -> V3 |
* +-----------+ +-----------+
*</pre>
* }</pre>
* {@link OperationContext} Updates can be undone in the same order they were applied by closing the {@link Scope}
* associated with each update (see {@link #set(OperationContextAttribute, Object)} and related methods).
*<p>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1259,7 +1259,7 @@ public static void quiet(boolean err, Object... objs) {
public static void quietMultipleLines(boolean err, String multiline) {
assert multiline != null;

quiet(err, multiline.split(NL));
quiet(err, (Object[])multiline.split(NL));
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ public final class X {
Method causeMtd;

try {
causeMtd = Throwable.class.getMethod("getCause", null);
causeMtd = Throwable.class.getMethod("getCause");
}
catch (Exception ignored) {
causeMtd = null;
Expand Down Expand Up @@ -615,7 +615,7 @@ private static Throwable getCauseUsingMethodName(Throwable throwable, String mtd
Method mtd = null;

try {
mtd = throwable.getClass().getMethod(mtdName, null);
mtd = throwable.getClass().getMethod(mtdName);
}
catch (NoSuchMethodException | SecurityException ignored) {
// exception ignored
Expand Down Expand Up @@ -694,7 +694,7 @@ public static boolean isNestedThrowable(Throwable throwable) {
Class<?> cls = throwable.getClass();
for (String CAUSE_MTD_NAME : CAUSE_MTD_NAMES) {
try {
Method mtd = cls.getMethod(CAUSE_MTD_NAME, null);
Method mtd = cls.getMethod(CAUSE_MTD_NAME);

if (mtd != null && Throwable.class.isAssignableFrom(mtd.getReturnType()))
return true;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements
/**
* The maximum capacity, used if a higher value is implicitly
* specified by either of the constructors with arguments. MUST
* be a power of two <= 1<<30 to ensure that entries are indexable
* be a power of two {@code <= 1<<30} to ensure that entries are indexable
* using ints.
*/
public static final int MAX_CAP_LIMIT = 1 << 30;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -608,7 +608,7 @@ private void printHelp(List<String> rawArgs) {
logger.info("");

logger.info(INDENT + join(" ",
join(" ", UTILITY_NAME, join(" ", new ArgumentParser(logger, registry, null).getCommonOptions())),
join(" ", UTILITY_NAME, join(" ", (Object[])new ArgumentParser(logger, registry, null).getCommonOptions())),
asOptional("command", true), "<command_parameters>"));
logger.info("");
logger.info("");
Expand Down Expand Up @@ -674,7 +674,7 @@ private void printCacheHelpHeader(IgniteLogger logger) {
logger.info(INDENT + "The '--cache subcommand' is used to get information about and perform actions" +
" with caches. The command has the following syntax:");
logger.info("");
logger.info(INDENT + join(" ", UTILITY_NAME, join(" ", new ArgumentParser(logger, null, null).getCommonOptions())) +
logger.info(INDENT + join(" ", UTILITY_NAME, join(" ", (Object[])new ArgumentParser(logger, null, null).getCommonOptions())) +
" --cache [subcommand] <subcommand_parameters>");
logger.info("");
logger.info(INDENT + "The subcommands that take [nodeId] as an argument ('list', 'find_garbage', " +
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1756,7 +1756,7 @@ public void testKillHangingRemoteTransactions() throws Exception {
if (id != 0)
U.awaitQuiet(lockLatch);

cache.invoke(0L, new IncrementClosure(), null);
cache.invoke(0L, new IncrementClosure());

if (id == 0) {
lockLatch.countDown();
Expand Down
1 change: 1 addition & 0 deletions modules/core/src/main/java/org/apache/ignite/Ignite.java
Original file line number Diff line number Diff line change
Expand Up @@ -753,6 +753,7 @@ public <T> IgniteQueue<T> queue(String name, int cap, @Nullable CollectionConfig
* @return Collection of {@link DataRegionMetrics} snapshots.
* @deprecated Check the {@link ReadOnlyMetricRegistry} with "name=io.dataregion.{data_region_name}" instead.
*/
@Deprecated
public Collection<DataRegionMetrics> dataRegionMetrics();

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -399,6 +399,7 @@ public IgniteFuture<Void> localLoadCacheAsync(@Nullable IgniteBiPredicate<K, V>
* @deprecated It is recommended to use {@link Ignite#reentrantLock(String, boolean, boolean, boolean)} instead.
* This method will be removed in future releases.
*/
@Deprecated
public Lock lockAll(Collection<? extends K> keys);

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1212,6 +1212,7 @@ public final class IgniteSystemProperties extends IgniteCommonsSystemProperties
*
* @deprecated Use {@link DataStorageConfiguration#setMinWalArchiveSize}.
*/
@Deprecated
@SystemProperty(value = "Property for setup percentage of WAL archive size to calculate threshold since which " +
"removing of old archive should be started", type = Double.class)
public static final String IGNITE_THRESHOLD_WAL_ARCHIVE_SIZE_PERCENTAGE =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2444,6 +2444,7 @@ public IgniteConfiguration setTracingSpi(TracingSpi tracingSpi) {
* @deprecated The Ignite Tracing is deprecated and subject to removal in a future release. Ignite Tracing has been
* retired in favor of Ignite Performance Statistics and Ignite Metrics.
*/
@Deprecated(forRemoval = true)
public TracingSpi getTracingSpi() {
return NoopTracingSpi.INSTANCE;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@ public class TransactionConfiguration implements Serializable {
* Default size of pessimistic transactions log.
* @deprecated Pessimistic tx log linger property has no effect.
*/
@Deprecated
public static final int DFLT_PESSIMISTIC_TX_LOG_LINGER = 10_000;

/** Default transaction serializable flag. */
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,7 @@ public boolean inlineObjectSupported() {

/**
* Static analyze inline_size and inline columns set.
* e.g.: indexed: (long, obj) and inline_size < 12.
* e.g.: indexed: (long, obj) and {@code inline_size < 12}.
* In this case there is no space for inline object.
*
* @param keyDefs Index key definition.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
/**
* DateValue is a representation of a date in bit form:
*
* dv = (year << SHIFT_YEAR) | (month << SHIFT_MONTH) | day.
* {@code dv = (year << SHIFT_YEAR) | (month << SHIFT_MONTH) | day}.
*/
public class DateValueUtils {
/** Calendar with UTC time zone instance. */
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ public interface IgniteCacheProxy<K, V> extends IgniteCache<K, V>, Externalizabl
* <p> For example, if you use {@link Integer} as a key and {@code Value} class as a value (which will be
* stored in binary format), you should acquire following projection to avoid deserialization:
* <pre>
* IgniteInternalCache<Integer, GridBinaryObject> prj = cache.keepBinary();
* IgniteInternalCache&lt;Integer, GridBinaryObject&gt; prj = cache.keepBinary();
*
* // Value is not deserialized and returned in binary format.
* GridBinaryObject po = prj.get(1);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1984,7 +1984,7 @@ else if (clazz.isAssignableFrom(IgniteEx.class)) {
* <p> For example, if you use {@link Integer} as a key and {@code Value} class as a value (which will be
* stored in binary format), you should acquire following projection to avoid deserialization:
* <pre>
* IgniteInternalCache<Integer, GridBinaryObject> prj = cache.keepBinary();
* IgniteInternalCache&lt;Integer, GridBinaryObject&gt; prj = cache.keepBinary();
*
* // Value is not deserialized and returned in binary format.
* GridBinaryObject po = prj.get(1);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,7 @@
* that class definitions are present in the classpath). By default, cache works with deserialized form
* (example shows the case when {@link Integer} is used as a key for a binary object):
* <pre>
* IgniteInternalCache<Integer, Value> prj = Ignition.grid().cache(null);
* IgniteInternalCache&lt;Integer, Value&gt; prj = Ignition.grid().cache(null);
*
* // Value will be serialized and stored in cache in binary format.
* prj.put(1, new Value());
Expand All @@ -193,7 +193,7 @@
* needed for performance reasons. To work with binary format directly you should create special projection
* using {@link #keepBinary()} method:
* <pre>
* IgniteInternalCache<Integer, GridBinaryObject> prj = Ignition.grid().cache(null).keepBinary();
* IgniteInternalCache&lt;Integer, GridBinaryObject&gt; prj = Ignition.grid().cache(null).keepBinary();
*
* // Value is not deserialized and returned in binary format.
* GridBinaryObject po = prj.get(1);
Expand Down Expand Up @@ -258,7 +258,7 @@ public interface IgniteInternalCache<K, V> extends Iterable<Cache.Entry<K, V>> {
* (which will be stored in binary format), you should acquire following projection
* to avoid deserialization:
* <pre>
* IgniteInternalCache<Integer, GridBinaryObject> prj = cache.keepBinary();
* IgniteInternalCache&lt;Integer, GridBinaryObject&gt; prj = cache.keepBinary();
*
* // Value is not deserialized and returned in binary format.
* GridBinaryObject po = prj.get(1);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ public interface PartitionUpdateCounter extends Iterable<long[]> {
/**
* Applies counter update out of range. Update ranges must not intersect.
*
* @param start Start (<= lwm).
* @param start Start ({@code <= lwm}).
* @param delta Delta.
* @return {@code True} if update was actually applied.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
*/

/**
* This package contain cache-related processors & persistence implementation. <br>
* This package contain cache-related processors and persistence implementation. <br>
* See also <a href="
* https://github.com/apache/ignite/tree/master/modules/core/src/main/java/org/apache/ignite/internal/processors/cache">
* GitHub Package Readme</a>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import org.jetbrains.annotations.NotNull;

/**
* Exception is needed to distinguish WAL manager & page store critical I/O errors.
* Exception is needed to distinguish WAL manager and page store critical I/O errors.
*/
public class StorageException extends IgniteCheckedException implements InvalidEnvironmentException {
/** */
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -231,7 +231,8 @@
* new org.locationtech.jts.geom.Coordinate(0, 0)
* });
*
* Map.Entry<String, UserData> records = cache.queries().createSqlQuery(MapPoint.class, "select * from MapPoint where location && ?")
* Map.Entry&lt;String, UserData&gt; records = cache.queries()
* .createSqlQuery(MapPoint.class, "select * from MapPoint where location &amp;&amp; ?")
* .queryArguments(square)
* .execute()
* .get();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
* Unlike other "single shot" request-reply commands, the
* COPY command the client-server interaction looks like this:
*
* <pre>
* <pre>{@code
* Thin JDBC client Server
* | |
* |------- JdbcQueryExecuteRequest ------>|
Expand Down Expand Up @@ -66,7 +66,7 @@
* | |
* (close the file) |
* | |
* </pre>
* }</pre>
*
* In case of input file reading error, a flag is carried to the server:
* {@link JdbcBulkLoadBatchRequest#CMD_FINISHED_ERROR} and the processing
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ public int getTimeoutMultiplier() {
* - timeout * multiplier;
* - timeout * multiplier * multiplier;
* - etc...
* If the multiplier <= 1, the warning message is printed once.
* If the multiplier {@code <= 1}, the warning message is printed once.
*
* @param timeoutMult Long query timeout multiplier.
*/
Expand Down Expand Up @@ -237,7 +237,7 @@ public void setResultSetSizeThreshold(long rsSizeThreshold) {
* - size of result set > threshold * multiplier;
* - size of result set > threshold * multiplier * multiplier;
* - etc.
* If the multiplier <= 1, the warning message is printed once.
* If the multiplier {@code <= 1}, the warning message is printed once.
* @return Result set size threshold multiplier.
*/
public int getResultSetSizeThresholdMultiplier() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ void setLongQueryWarningTimeout(
* - timeout * multiplier;
* - timeout * multiplier * multiplier;
* - etc.
* If the multiplier <= 1, the warning message is printed once.
* If the multiplier {@code <= 1}, the warning message is printed once.
*
* @param longQueryTimeoutMultiplier Long query timeout multiplier.
*/
Expand Down Expand Up @@ -102,7 +102,7 @@ void setLongQueryWarningTimeout(
* - size of result set > threshold * multiplier;
* - size of result set > threshold * multiplier * multiplier;
* - etc.
* If the multiplier <= 1, the warning message is printed once during query execution and the next one on the query end.
* If the multiplier {@code <= 1}, the warning message is printed once during query execution and the next one on the query end.
*
* @return Result set size threshold multiplier.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ public StatisticsProcessor(
* 2) If byObsolescence and no table awailable - clean obsolescence and partition statistics for the given key.
* 3) Submit tasks for each specified partition.
* 4) after last task finish gathering - it starts aggregation.
* 5) read all partitions & obsolescence from repo and
* 5) read all partitions and obsolescence from repo and
* if byObsolescence = {@code true} - remove unnecessary one and aggregate by specified list
* if byObsolescence = {@code false} - aggregate all presented in store (because it should contains only actual ones)
* 5) save aggregated local statistics
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@ public static byte packVersionByte(final int schemaVersion, final int typeOrdina
* If 'auto' is chosen, this value should be <code>63</code>.
* </li>
* <li>
* If a cutoff of 2<sup>n</sup> is desired, for <code>0 <= n < 31</code>,
* If a cutoff of 2<sup>n</sup> is desired, for {@code 0 <= n < 31},
* this value should be <code>n + 1</code>.
* </li>
* </ul>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,9 +29,9 @@
* Concurrent queue that wraps collection of {@code Pair<K, V[]>}
* The only garantee {@link #next} provided is sequentially emptify values per key array.
* i.e. input like: <br>
* p1 = new Pair<1, [1, 3, 5, 7]> <br>
* p2 = new Pair<2, [2, 3]> <br>
* p3 = new Pair<3, [200, 100]> <br>
* {@code p1 = new Pair<1, [1, 3, 5, 7]>} <br>
* {@code p2 = new Pair<2, [2, 3]>} <br>
* {@code p3 = new Pair<3, [200, 100]>} <br>
* and further sequence of {@code poll} or {@code forEach} calls may produce output like: <br>
* [3, 200], [3, 100], [1, 1], [1, 3], [1, 5], [1, 7], [2, 2], [2, 3]
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2230,7 +2230,7 @@ public static <T> Iterable<T> asIterable(final Enumeration<T> e) {
}

/**
* Copy source file (or folder) to destination file (or folder). Supported source & destination:
* Copy source file (or folder) to destination file (or folder). Supported source and destination:
* <ul>
* <li>File to File</li>
* <li>File to Folder</li>
Expand Down
Loading
Loading