natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add checkstyle modules for checking redundant and unused imports in Java code 

patch by Stefan Miklosovic; reviewed by Brandon Williams for CASSANDRA-17876

Co-authored-by: Ling Mao <maoling@apache.org>
This commit is contained in:
Stefan Miklosovic 2022-09-22 10:20:31 +02:00
parent 0f9ddb8b6c
commit 5d3c747719
147 changed files with 16 additions and 233 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
build.xml
View File

@ -2257,7 +2257,7 @@
</java>
</target>
<target name="init-checkstyle" depends="maven-ant-tasks-retrieve-build,build-project">
<target name="init-checkstyle" depends="maven-ant-tasks-retrieve-build,build-project" unless="no-checkstyle">
<path id="checkstyle.lib.path">
<fileset dir="${test.lib}/jars" includes="*.jar"/>
</path>
@ -2267,7 +2267,7 @@
classpathref="checkstyle.lib.path"/>
</target>
<target name="checkstyle" depends="init-checkstyle,maven-ant-tasks-retrieve-build,build-project" description="Run custom checkstyle code analysis" if="java.version.8">
<target name="checkstyle" depends="init-checkstyle,maven-ant-tasks-retrieve-build,build-project" description="Run custom checkstyle code analysis" if="java.version.8" unless="no-checkstyle">
<property name="checkstyle.log.dir" value="${build.dir}/checkstyle" />
<property name="checkstyle.report.file" value="${checkstyle.log.dir}/checkstyle_report.xml"/>
<mkdir dir="${checkstyle.log.dir}" />
@ -2283,7 +2283,7 @@
</checkstyle>
</target>
<target name="checkstyle-test" depends="init-checkstyle,maven-ant-tasks-retrieve-build,build-project" description="Run custom checkstyle code analysis on tests" if="java.version.8">
<target name="checkstyle-test" depends="init-checkstyle,maven-ant-tasks-retrieve-build,build-project" description="Run custom checkstyle code analysis on tests" if="java.version.8" unless="no-checkstyle">
<property name="checkstyle.log.dir" value="${build.dir}/checkstyle" />
<property name="checkstyle_test.report.file" value="${checkstyle.log.dir}/checkstyle_report_test.xml"/>
<mkdir dir="${checkstyle.log.dir}" />

3
checkstyle.xml
View File

@ -105,6 +105,9 @@
<property name="format" value="toFile\(\)"/>
<property name="message" value="Avoid Path#toFile(), as some implementations may not support it." />
</module>
<module name="RedundantImport"/>
<module name="UnusedImports"/>
</module>
</module>

3
checkstyle_test.xml
View File

@ -56,6 +56,9 @@
<module name="IllegalInstantiation">
<property name="classes" value=""/>
</module>
<module name="RedundantImport"/>
<module name="UnusedImports"/>
</module>
</module>

1
src/java/org/apache/cassandra/batchlog/BatchlogManager.java
View File

@ -36,7 +36,6 @@ import com.google.common.annotations.VisibleForTesting;
import com.google.common.collect.Iterables;
import com.google.common.util.concurrent.RateLimiter;
import org.apache.cassandra.concurrent.ScheduledExecutorPlus;
import org.apache.cassandra.db.marshal.TimeUUIDType;
import org.apache.cassandra.utils.TimeUUID;
import org.apache.cassandra.utils.concurrent.Future;
import org.slf4j.Logger;

2
src/java/org/apache/cassandra/cache/CaffeineCache.java vendored
View File

@ -21,8 +21,6 @@ import static com.google.common.base.Preconditions.checkState;
import java.util.Iterator;
import com.google.common.util.concurrent.MoreExecutors;
import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.Policy.Eviction;

2
src/java/org/apache/cassandra/cache/SerializingCache.java vendored
View File

@ -33,8 +33,6 @@ import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.Iterator;
import com.google.common.util.concurrent.MoreExecutors;
/**
* Serializes cache values off-heap.
*/

5
src/java/org/apache/cassandra/config/EncryptionOptions.java
View File

@ -25,10 +25,6 @@ import java.util.Map;
import java.util.Objects;
import java.util.Set;
import javax.net.ssl.KeyManagerFactory;
import javax.net.ssl.SSLException;
import javax.net.ssl.TrustManagerFactory;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.collect.ImmutableList;
@ -38,7 +34,6 @@ import org.slf4j.LoggerFactory;
import com.fasterxml.jackson.annotation.JsonIgnore;
import org.apache.cassandra.locator.IEndpointSnitch;
import org.apache.cassandra.locator.InetAddressAndPort;
import org.apache.cassandra.security.AbstractSslContextFactory;
import org.apache.cassandra.security.DisableSslContextFactory;
import org.apache.cassandra.security.ISslContextFactory;
import org.apache.cassandra.utils.FBUtilities;

1
src/java/org/apache/cassandra/cql3/WhereClause.java
View File

@ -24,7 +24,6 @@ import com.google.common.collect.ImmutableList;
import org.antlr.runtime.RecognitionException;
import org.apache.cassandra.cql3.restrictions.CustomIndexExpression;
import org.apache.cassandra.exceptions.InvalidRequestException;
import static java.lang.String.join;

1
src/java/org/apache/cassandra/cql3/restrictions/SingleColumnRestriction.java
View File

@ -23,7 +23,6 @@ import java.util.Collections;
import java.util.List;
import org.apache.cassandra.schema.ColumnMetadata;
import org.apache.cassandra.serializers.CollectionSerializer;
import org.apache.cassandra.serializers.ListSerializer;
import org.apache.cassandra.transport.ProtocolVersion;
import org.apache.cassandra.cql3.*;

1
src/java/org/apache/cassandra/cql3/selection/MapSelector.java
View File

@ -35,7 +35,6 @@ import org.apache.cassandra.db.TypeSizes;
import org.apache.cassandra.db.filter.ColumnFilter.Builder;
import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.db.marshal.MapType;
import org.apache.cassandra.exceptions.InvalidRequestException;
import org.apache.cassandra.io.util.DataInputPlus;
import org.apache.cassandra.io.util.DataOutputPlus;
import org.apache.cassandra.schema.ColumnMetadata;

1
src/java/org/apache/cassandra/cql3/statements/schema/AlterTableStatement.java
View File

@ -17,7 +17,6 @@
*/
package org.apache.cassandra.cql3.statements.schema;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;

1
src/java/org/apache/cassandra/cql3/statements/schema/TableAttributes.java
View File

@ -20,7 +20,6 @@ package org.apache.cassandra.cql3.statements.schema;
import java.util.Map;
import java.util.Set;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Sets;

2
src/java/org/apache/cassandra/db/ReadResponse.java
View File

@ -34,8 +34,6 @@ import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.schema.TableMetadata;
import org.apache.cassandra.utils.ByteBufferUtil;
import static org.apache.cassandra.db.RepairedDataInfo.NO_OP_REPAIRED_DATA_INFO;
public abstract class ReadResponse
{
// Serializer for single partition read response

1
src/java/org/apache/cassandra/db/SystemKeyspaceMigrator41.java
View File

@ -35,7 +35,6 @@ import org.apache.cassandra.db.marshal.BytesType;
import org.apache.cassandra.db.marshal.Int32Type;
import org.apache.cassandra.db.marshal.TimeUUIDType;
import org.apache.cassandra.db.marshal.UTF8Type;
import org.apache.cassandra.db.marshal.UUIDType;
import org.apache.cassandra.io.sstable.SequenceBasedSSTableId;
import org.apache.cassandra.schema.SchemaConstants;
import org.apache.cassandra.utils.CassandraVersion;

2
src/java/org/apache/cassandra/db/compaction/writers/CompactionAwareWriter.java
View File

@ -39,8 +39,6 @@ import org.apache.cassandra.io.sstable.format.SSTableReader;
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.TimeUUID;
import org.apache.cassandra.utils.concurrent.Transactional;
import org.apache.cassandra.db.compaction.OperationType;
/**
* Class that abstracts away the actual writing of files to make it possible to use CompactionTask for more

1
src/java/org/apache/cassandra/db/filter/ClusteringIndexFilter.java
View File

@ -23,7 +23,6 @@ import org.apache.cassandra.db.*;
import org.apache.cassandra.db.partitions.CachedPartition;
import org.apache.cassandra.db.partitions.Partition;
import org.apache.cassandra.db.rows.*;
import org.apache.cassandra.index.Index;
import org.apache.cassandra.io.sstable.format.SSTableReader;
import org.apache.cassandra.io.util.DataInputPlus;
import org.apache.cassandra.io.util.DataOutputPlus;

1
src/java/org/apache/cassandra/db/filter/ClusteringIndexSliceFilter.java
View File

@ -30,7 +30,6 @@ import org.apache.cassandra.db.transform.Transformation;
import org.apache.cassandra.io.sstable.format.SSTableReader;
import org.apache.cassandra.io.util.DataInputPlus;
import org.apache.cassandra.io.util.DataOutputPlus;
import org.stringtemplate.v4.ST;
/**
* A filter over a single partition.

1
src/java/org/apache/cassandra/db/marshal/AbstractTimeUUIDType.java
View File

@ -24,7 +24,6 @@ import org.apache.cassandra.cql3.CQL3Type;
import org.apache.cassandra.cql3.Constants;
import org.apache.cassandra.cql3.Term;
import org.apache.cassandra.serializers.MarshalException;
import org.apache.cassandra.serializers.TypeSerializer;
import org.apache.cassandra.serializers.UUIDSerializer;
import org.apache.cassandra.utils.TimeUUID;

2
src/java/org/apache/cassandra/db/memtable/SkipListMemtableFactory.java
View File

@ -18,13 +18,11 @@
package org.apache.cassandra.db.memtable;
import java.util.Map;
import java.util.concurrent.atomic.AtomicReference;
import com.google.common.collect.ImmutableMap;
import org.apache.cassandra.config.InheritingClass;
import org.apache.cassandra.config.ParameterizedClass;
import org.apache.cassandra.db.commitlog.CommitLogPosition;
import org.apache.cassandra.schema.TableMetadataRef;

1
src/java/org/apache/cassandra/db/repair/CassandraKeyspaceRepairManager.java
View File

@ -20,7 +20,6 @@ package org.apache.cassandra.db.repair;
import java.util.Collection;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.ExecutorService;
import java.util.function.BooleanSupplier;

1
src/java/org/apache/cassandra/db/repair/CassandraValidationIterator.java
View File

@ -40,7 +40,6 @@ import org.apache.cassandra.db.DecoratedKey;
import org.apache.cassandra.db.compaction.AbstractCompactionStrategy;
import org.apache.cassandra.db.compaction.ActiveCompactionsTracker;
import org.apache.cassandra.db.compaction.CompactionController;
import org.apache.cassandra.db.compaction.CompactionInfo;
import org.apache.cassandra.db.compaction.CompactionIterator;
import org.apache.cassandra.db.compaction.CompactionManager;
import org.apache.cassandra.db.compaction.OperationType;

3
src/java/org/apache/cassandra/db/rows/ComplexColumnData.java
View File

@ -28,11 +28,8 @@ import org.apache.cassandra.db.DeletionPurger;
import org.apache.cassandra.db.DeletionTime;
import org.apache.cassandra.db.Digest;
import org.apache.cassandra.db.LivenessInfo;
import org.apache.cassandra.db.context.CounterContext;
import org.apache.cassandra.db.filter.ColumnFilter;
import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.db.marshal.ByteType;
import org.apache.cassandra.db.marshal.CollectionType;
import org.apache.cassandra.db.marshal.SetType;
import org.apache.cassandra.schema.ColumnMetadata;
import org.apache.cassandra.schema.DroppedColumn;

2
src/java/org/apache/cassandra/db/virtual/StreamingVirtualTable.java
View File

@ -19,12 +19,10 @@ package org.apache.cassandra.db.virtual;
import java.util.Date;
import java.util.Map;
import java.util.UUID;
import java.util.stream.Collectors;
import org.apache.cassandra.db.DecoratedKey;
import org.apache.cassandra.db.marshal.TimeUUIDType;
import org.apache.cassandra.db.marshal.UUIDType;
import org.apache.cassandra.schema.TableMetadata;
import org.apache.cassandra.streaming.StreamManager;
import org.apache.cassandra.streaming.StreamingState;

1
src/java/org/apache/cassandra/hints/HintsStore.java
View File

@ -23,7 +23,6 @@ import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentLinkedDeque;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.function.Predicate;
import java.util.stream.Stream;
import javax.annotation.Nullable;

1
src/java/org/apache/cassandra/hints/PendingHintsInfo.java
View File

@ -18,7 +18,6 @@
package org.apache.cassandra.hints;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;

2
src/java/org/apache/cassandra/index/sasi/analyzer/filter/StemmerFactory.java
View File

@ -22,8 +22,6 @@ import java.util.HashMap;
import java.util.Locale;
import java.util.Map;
import com.google.common.util.concurrent.MoreExecutors;
import org.apache.cassandra.concurrent.ImmediateExecutor;
import org.tartarus.snowball.SnowballStemmer;
import org.tartarus.snowball.ext.*;

2
src/java/org/apache/cassandra/index/sasi/analyzer/filter/StopWordFactory.java
View File

@ -27,8 +27,6 @@ import java.util.Locale;
import java.util.Set;
import java.util.concurrent.CompletionException;
import com.google.common.util.concurrent.MoreExecutors;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.LoadingCache;

1
src/java/org/apache/cassandra/io/sstable/CQLSSTableWriter.java
View File

@ -46,7 +46,6 @@ import org.apache.cassandra.cql3.statements.ModificationStatement;
import org.apache.cassandra.db.Clustering;
import org.apache.cassandra.db.Slice;
import org.apache.cassandra.db.Slices;
import org.apache.cassandra.db.SystemKeyspace;
import org.apache.cassandra.db.marshal.AbstractType;
import org.apache.cassandra.dht.IPartitioner;
import org.apache.cassandra.dht.Murmur3Partitioner;

1
src/java/org/apache/cassandra/io/util/DataIntegrityMetadata.java
View File

@ -27,7 +27,6 @@ import com.google.common.annotations.VisibleForTesting;
import org.apache.cassandra.io.sstable.Component;
import org.apache.cassandra.io.sstable.Descriptor;
import org.apache.cassandra.io.util.File;
import org.apache.cassandra.utils.ChecksumType;
import org.apache.cassandra.utils.Throwables;

1
src/java/org/apache/cassandra/io/util/RandomAccessReader.java
View File

@ -25,7 +25,6 @@ import javax.annotation.concurrent.NotThreadSafe;
import com.google.common.primitives.Ints;
import org.apache.cassandra.io.compress.BufferType;
import org.apache.cassandra.io.util.File;
import org.apache.cassandra.io.util.Rebufferer.BufferHolder;
@NotThreadSafe

2
src/java/org/apache/cassandra/metrics/HintedHandoffMetrics.java
View File

@ -19,8 +19,6 @@ package org.apache.cassandra.metrics;
import java.util.Map.Entry;
import com.google.common.util.concurrent.MoreExecutors;
import com.codahale.metrics.Counter;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.LoadingCache;

1
src/java/org/apache/cassandra/metrics/HintsServiceMetrics.java
View File

@ -17,7 +17,6 @@
*/
package org.apache.cassandra.metrics;
import com.google.common.util.concurrent.MoreExecutors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

1
src/java/org/apache/cassandra/net/AsyncStreamingInputPlus.java
View File

@ -17,7 +17,6 @@
*/
package org.apache.cassandra.net;
import java.io.EOFException;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.ClosedChannelException;

1
src/java/org/apache/cassandra/net/OutboundConnections.java
View File

@ -50,7 +50,6 @@ import static org.apache.cassandra.net.ConnectionType.URGENT_MESSAGES;
import static org.apache.cassandra.net.ConnectionType.LARGE_MESSAGES;
import static org.apache.cassandra.net.ConnectionType.SMALL_MESSAGES;
import static org.apache.cassandra.net.ResourceLimits.*;
import static org.apache.cassandra.net.Verb.Priority.P0;
import static org.apache.cassandra.utils.concurrent.Condition.newOneTimeCondition;
/**

1
src/java/org/apache/cassandra/net/ParamType.java
View File

@ -27,7 +27,6 @@ import org.apache.cassandra.tracing.Tracing;
import org.apache.cassandra.utils.Int32Serializer;
import org.apache.cassandra.utils.Int64Serializer;
import org.apache.cassandra.utils.TimeUUID;
import org.apache.cassandra.utils.UUIDSerializer;
import static java.lang.Math.max;
import static org.apache.cassandra.locator.InetAddressAndPort.FwdFrmSerializer.fwdFrmSerializer;

1
src/java/org/apache/cassandra/net/RequestCallbacks.java
View File

@ -26,7 +26,6 @@ import javax.annotation.Nullable;
import com.google.common.annotations.VisibleForTesting;
import org.apache.cassandra.concurrent.ExecutorFactory;
import org.apache.cassandra.concurrent.ScheduledExecutorPlus;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

1
src/java/org/apache/cassandra/repair/IncrementalRepairTask.java
View File

@ -19,7 +19,6 @@ package org.apache.cassandra.repair;
import java.util.List;
import java.util.Set;
import java.util.UUID;
import com.google.common.collect.ImmutableSet;

1
src/java/org/apache/cassandra/repair/PreviewRepairTask.java
View File

@ -21,7 +21,6 @@ import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.UUID;
import com.google.common.base.Preconditions;

2
src/java/org/apache/cassandra/repair/RepairJobDesc.java
View File

@ -37,8 +37,6 @@ import org.apache.cassandra.io.util.DataInputPlus;
import org.apache.cassandra.io.util.DataOutputPlus;
import org.apache.cassandra.streaming.PreviewKind;
import org.apache.cassandra.utils.TimeUUID;
import org.apache.cassandra.utils.ByteBufferUtil;
import org.apache.cassandra.utils.UUIDSerializer;
import static org.apache.cassandra.utils.ByteBufferUtil.bytes;
import static org.apache.cassandra.utils.ByteBufferUtil.getArray;

1
src/java/org/apache/cassandra/repair/RepairRunnable.java
View File

@ -88,7 +88,6 @@ import static org.apache.cassandra.repair.state.AbstractState.INIT;
import static org.apache.cassandra.service.QueryState.forInternalCalls;
import static org.apache.cassandra.utils.Clock.Global.currentTimeMillis;
import static org.apache.cassandra.utils.Clock.Global.nanoTime;
import static org.apache.cassandra.utils.TimeUUID.Generator.nextTimeUUID;
public class RepairRunnable implements Runnable, ProgressEventNotifier, RepairNotifier
{

1
src/java/org/apache/cassandra/repair/state/SessionState.java
View File

@ -26,7 +26,6 @@ import java.util.concurrent.ConcurrentMap;
import org.apache.cassandra.locator.InetAddressAndPort;
import org.apache.cassandra.repair.CommonRange;
import org.apache.cassandra.utils.TimeUUID;
import org.apache.cassandra.utils.UUIDGen;
import static org.apache.cassandra.utils.TimeUUID.Generator.nextTimeUUID;

5
src/java/org/apache/cassandra/schema/SchemaPullVerbHandler.java
View File

@ -17,20 +17,15 @@
*/
package org.apache.cassandra.schema;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.function.Consumer;
import java.util.function.Function;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.db.Mutation;
import org.apache.cassandra.locator.InetAddressAndPort;
import org.apache.cassandra.net.IVerbHandler;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.net.NoPayload;
/**

2
src/java/org/apache/cassandra/schema/SchemaPushVerbHandler.java
View File

@ -25,11 +25,9 @@ import java.util.function.Consumer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.concurrent.Stage;
import org.apache.cassandra.db.Mutation;
import org.apache.cassandra.net.IVerbHandler;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.net.NoPayload;
/**
* Called when node receives updated schema state from the schema migration coordinator node.

1
src/java/org/apache/cassandra/security/CipherFactory.java
View File

@ -31,7 +31,6 @@ import javax.crypto.NoSuchPaddingException;
import javax.crypto.spec.IvParameterSpec;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.util.concurrent.MoreExecutors;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.LoadingCache;

1
src/java/org/apache/cassandra/serializers/ListSerializer.java
View File

@ -20,7 +20,6 @@ package org.apache.cassandra.serializers;
import java.nio.BufferUnderflowException;
import java.nio.ByteBuffer;
import java.nio.charset.CharacterCodingException;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;

3
src/java/org/apache/cassandra/service/ActiveRepairService.java
View File

@ -40,7 +40,6 @@ import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Iterables;
import com.google.common.collect.Lists;
import com.google.common.collect.Multimap;
import com.google.common.util.concurrent.MoreExecutors;
import org.apache.cassandra.concurrent.ExecutorPlus;
import org.apache.cassandra.config.Config;
@ -53,13 +52,11 @@ import org.apache.cassandra.utils.ExecutorUtils;
import org.apache.cassandra.repair.state.CoordinatorState;
import org.apache.cassandra.repair.state.ParticipateState;
import org.apache.cassandra.repair.state.ValidationState;
import org.apache.cassandra.utils.ObjectSizes;
import org.apache.cassandra.utils.Simulate;
import org.apache.cassandra.locator.EndpointsForToken;
import org.apache.cassandra.schema.Schema;
import org.apache.cassandra.schema.TableMetadata;
import org.apache.cassandra.streaming.PreviewKind;
import org.apache.cassandra.utils.Simulate;
import org.apache.cassandra.utils.TimeUUID;
import org.apache.cassandra.utils.concurrent.CountDownLatch;
import org.slf4j.Logger;

1
src/java/org/apache/cassandra/service/ClientState.java
View File

@ -28,7 +28,6 @@ import java.util.Optional;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
import java.util.function.LongSupplier;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.collect.ImmutableMap;

1
src/java/org/apache/cassandra/service/StorageProxy.java
View File

@ -39,7 +39,6 @@ import java.util.concurrent.atomic.AtomicLong;
import java.util.function.Function;
import java.util.stream.Collectors;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Preconditions;
import com.google.common.cache.CacheLoader;
import com.google.common.collect.Iterables;

3
src/java/org/apache/cassandra/service/paxos/Paxos.java
View File

@ -33,8 +33,6 @@ import javax.annotation.Nullable;
import com.google.common.base.Preconditions;
import com.google.common.collect.Maps;
import org.apache.commons.httpclient.methods.multipart.Part;
import com.codahale.metrics.Meter;
import org.apache.cassandra.exceptions.CasWriteTimeoutException;
import org.apache.cassandra.exceptions.ExceptionCode;
@ -80,7 +78,6 @@ import org.apache.cassandra.locator.InetAddressAndPort;
import org.apache.cassandra.metrics.ClientRequestMetrics;
import org.apache.cassandra.service.CASRequest;
import org.apache.cassandra.service.ClientState;
import org.apache.cassandra.service.FailureRecordingCallback;
import org.apache.cassandra.service.FailureRecordingCallback.AsMap;
import org.apache.cassandra.service.paxos.Commit.Proposal;
import org.apache.cassandra.service.reads.DataResolver;

1
src/java/org/apache/cassandra/service/paxos/PaxosCommitAndPrepare.java
View File

@ -31,7 +31,6 @@ import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.schema.TableMetadata;
import org.apache.cassandra.service.paxos.Commit.Agreed;
import org.apache.cassandra.tracing.Tracing;
import org.apache.cassandra.service.paxos.Ballot;
import static org.apache.cassandra.exceptions.RequestFailureReason.UNKNOWN;
import static org.apache.cassandra.net.Verb.PAXOS2_COMMIT_AND_PREPARE_REQ;

1
src/java/org/apache/cassandra/service/paxos/PaxosPrepareRefresh.java
View File

@ -33,7 +33,6 @@ import org.apache.cassandra.locator.InetAddressAndPort;
import org.apache.cassandra.net.IVerbHandler;
import org.apache.cassandra.net.Message;
import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.net.RequestCallback;
import org.apache.cassandra.net.RequestCallbackWithFailure;
import org.apache.cassandra.service.paxos.Commit.Agreed;
import org.apache.cassandra.service.paxos.Commit.Committed;

1
src/java/org/apache/cassandra/service/paxos/PaxosRepairHistory.java
View File

@ -30,7 +30,6 @@ import com.google.common.collect.ImmutableList;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.TypeSizes;
import org.apache.cassandra.db.marshal.BytesType;
import org.apache.cassandra.db.marshal.TimeUUIDType;
import org.apache.cassandra.db.marshal.TupleType;
import org.apache.cassandra.dht.Range;
import org.apache.cassandra.dht.Token;

1
src/java/org/apache/cassandra/service/paxos/TablePaxosRepairHistory.java
View File

@ -23,7 +23,6 @@ import java.util.Collection;
import org.apache.cassandra.db.SystemKeyspace;
import org.apache.cassandra.dht.Range;
import org.apache.cassandra.dht.Token;
import org.apache.cassandra.service.paxos.Ballot;
public class TablePaxosRepairHistory
{

1
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupLocalCoordinator.java
View File

@ -40,7 +40,6 @@ import org.apache.cassandra.service.paxos.PaxosRepair;
import org.apache.cassandra.service.paxos.PaxosState;
import org.apache.cassandra.service.paxos.uncommitted.UncommittedPaxosKey;
import org.apache.cassandra.utils.CloseableIterator;
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.concurrent.AsyncFuture;
import static org.apache.cassandra.service.paxos.cleanup.PaxosCleanupSession.TIMEOUT_NANOS;

1
src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupRequest.java
View File

@ -43,7 +43,6 @@ import org.apache.cassandra.utils.UUIDSerializer;
import static org.apache.cassandra.net.MessagingService.instance;
import static org.apache.cassandra.net.NoPayload.noPayload;
import static org.apache.cassandra.net.Verb.PAXOS2_CLEANUP_RSP;
import static org.apache.cassandra.net.Verb.PAXOS2_CLEANUP_RSP2;
// TODO: send the high bound as a minimum commit point, so later repairs can terminate early if a later commit has been witnessed

1
src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedDataFile.java
View File

@ -46,7 +46,6 @@ import org.apache.cassandra.io.util.File;
import org.apache.cassandra.io.util.RandomAccessReader;
import org.apache.cassandra.io.util.SequentialWriter;
import org.apache.cassandra.io.util.SequentialWriterOption;
import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.schema.TableId;
import org.apache.cassandra.service.paxos.Ballot;
import org.apache.cassandra.utils.AbstractIterator;

1
src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableData.java
View File

@ -61,7 +61,6 @@ import org.apache.cassandra.service.paxos.PaxosRepairHistory;
import org.apache.cassandra.utils.AbstractIterator;
import org.apache.cassandra.utils.CloseableIterator;
import org.apache.cassandra.utils.ExecutorUtils;
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.MergeIterator;
import org.apache.cassandra.utils.Throwables;

1
src/java/org/apache/cassandra/service/reads/FixedSpeculativeRetryPolicy.java
View File

@ -23,7 +23,6 @@ import java.util.regex.Pattern;
import com.google.common.base.Objects;
import com.codahale.metrics.Snapshot;
import org.apache.cassandra.exceptions.ConfigurationException;
import org.apache.cassandra.metrics.SnapshottingTimer;
import org.apache.cassandra.schema.TableParams;

1
src/java/org/apache/cassandra/service/reads/repair/BlockingReadRepair.java
View File

@ -21,7 +21,6 @@ package org.apache.cassandra.service.reads.repair;
import java.util.Map;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.TimeUnit;
import org.apache.cassandra.db.DecoratedKey;
import org.slf4j.Logger;

1
src/java/org/apache/cassandra/transport/ExceptionHandlers.java
View File

@ -24,7 +24,6 @@ import java.util.Set;
import java.util.concurrent.TimeUnit;
import com.google.common.base.Predicate;
import com.google.common.base.Predicates;
import com.google.common.collect.ImmutableSet;
import org.slf4j.Logger;

5
src/java/org/apache/cassandra/transport/messages/BatchMessage.java
View File

@ -20,13 +20,9 @@ package org.apache.cassandra.transport.messages;
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
import com.google.common.collect.ImmutableMap;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import io.netty.buffer.ByteBuf;
import org.apache.cassandra.cql3.Attributes;
import org.apache.cassandra.cql3.BatchQueryOptions;
@ -49,7 +45,6 @@ import org.apache.cassandra.transport.ProtocolException;
import org.apache.cassandra.transport.ProtocolVersion;
import org.apache.cassandra.utils.JVMStabilityInspector;
import org.apache.cassandra.utils.MD5Digest;
import org.apache.cassandra.utils.NoSpamLogger;
import static org.apache.cassandra.utils.Clock.Global.currentTimeMillis;

1
src/java/org/apache/cassandra/utils/CloseableIterator.java
View File

@ -19,7 +19,6 @@ package org.apache.cassandra.utils;
import java.util.Iterator;
import java.util.NoSuchElementException;
import java.util.function.Supplier;
// so we can instantiate anonymous classes implementing both interfaces
public interface CloseableIterator<T> extends Iterator<T>, AutoCloseable

1
src/java/org/apache/cassandra/utils/IntervalTree.java
View File

@ -23,7 +23,6 @@ import java.lang.reflect.InvocationTargetException;
import java.util.*;
import com.google.common.base.Joiner;
import org.apache.cassandra.utils.AbstractIterator;
import com.google.common.collect.Iterators;
import org.slf4j.Logger;

2
src/java/org/apache/cassandra/utils/Isolated.java
View File

@ -23,8 +23,6 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.apache.cassandra.utils.Shared;
/**
* Tells jvm-dtest that a class should be isolated and loaded into the instance class loader.
*

1
src/java/org/apache/cassandra/utils/NativeLibrary.java
View File

@ -23,7 +23,6 @@ import java.lang.reflect.Field;
import java.nio.channels.FileChannel;
import java.util.concurrent.TimeUnit;
import org.apache.cassandra.config.CassandraRelevantProperties;
import org.apache.cassandra.io.util.File;
import org.apache.cassandra.io.util.FileInputStreamPlus;
import org.slf4j.Logger;

1
src/java/org/apache/cassandra/utils/UUIDGen.java
View File

@ -19,7 +19,6 @@ package org.apache.cassandra.utils;
import java.nio.ByteBuffer;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
/**
* The goods are here: www.ietf.org/rfc/rfc4122.txt.

1
src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java
View File

@ -25,7 +25,6 @@ import java.util.function.Consumer;
import java.util.function.Function;
import net.nicoulaj.compilecommand.annotations.Inline;
import org.apache.cassandra.utils.BiLongAccumulator;
import org.apache.cassandra.utils.LongAccumulator;
/**

1
src/java/org/apache/cassandra/utils/concurrent/Ref.java
View File

@ -30,7 +30,6 @@ import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.function.Consumer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

1
test/distributed/org/apache/cassandra/distributed/Cluster.java
View File

@ -25,7 +25,6 @@ import org.apache.cassandra.distributed.api.IInstanceConfig;
import org.apache.cassandra.distributed.impl.AbstractCluster;
import org.apache.cassandra.distributed.api.IInvokableInstance;
import org.apache.cassandra.distributed.shared.Versions;
import org.apache.cassandra.utils.Shared;
/**
* A simple cluster supporting only the 'current' Cassandra version, offering easy access to the convenience methods

1
test/distributed/org/apache/cassandra/distributed/action/GossipHelper.java
View File

@ -29,7 +29,6 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import java.util.stream.Stream;

1
test/distributed/org/apache/cassandra/distributed/fuzz/SSTableGenerator.java
View File

@ -18,7 +18,6 @@
package org.apache.cassandra.distributed.fuzz;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.Collection;

1
test/distributed/org/apache/cassandra/distributed/impl/AbstractCluster.java
View File

@ -97,7 +97,6 @@ import org.apache.cassandra.utils.Shared.Recursive;
import org.apache.cassandra.utils.concurrent.Condition;
import org.reflections.Reflections;
import org.reflections.scanners.Scanners;
import org.reflections.scanners.TypeAnnotationsScanner;
import org.reflections.util.ConfigurationBuilder;
import org.reflections.util.NameHelper;

1
test/distributed/org/apache/cassandra/distributed/impl/InstanceMetrics.java
View File

@ -24,7 +24,6 @@ import java.util.List;
import java.util.Map;
import java.util.function.Predicate;
import com.codahale.metrics.Counter;
import com.codahale.metrics.Counting;
import com.codahale.metrics.Gauge;
import com.codahale.metrics.Histogram;

2
test/distributed/org/apache/cassandra/distributed/impl/UnsafeGossipHelper.java
View File

@ -23,8 +23,6 @@ import java.net.InetSocketAddress;
import java.util.Collection;
import java.util.UUID;
import com.google.common.collect.Iterables;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.SystemKeyspace;
import org.apache.cassandra.dht.IPartitioner;

1
test/distributed/org/apache/cassandra/distributed/test/AbstractEncryptionOptionsImpl.java
View File

@ -56,7 +56,6 @@ import org.apache.cassandra.security.SSLFactory;
import static java.util.concurrent.TimeUnit.SECONDS;
import static org.apache.cassandra.distributed.test.AbstractEncryptionOptionsImpl.ConnectResult.CONNECTING;
import static org.apache.cassandra.distributed.test.AbstractEncryptionOptionsImpl.ConnectResult.UNINITIALIZED;
import static org.apache.cassandra.security.SSLFactory.getOrCreateSslContext;
import static org.apache.cassandra.utils.concurrent.Condition.newOneTimeCondition;
public class AbstractEncryptionOptionsImpl extends TestBaseImpl

2
test/distributed/org/apache/cassandra/distributed/test/CASAddTest.java
View File

@ -30,8 +30,6 @@ import org.assertj.core.api.Assertions;
import static org.apache.cassandra.distributed.shared.AssertUtils.assertRows;
import static org.apache.cassandra.distributed.shared.AssertUtils.row;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
public class CASAddTest extends TestBaseImpl
{

1
test/distributed/org/apache/cassandra/distributed/test/CASTestBase.java
View File

@ -26,7 +26,6 @@ import org.junit.Assert;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.db.ConsistencyLevel;
import org.apache.cassandra.db.DecoratedKey;
import org.apache.cassandra.db.Keyspace;
import org.apache.cassandra.db.marshal.Int32Type;

1
test/distributed/org/apache/cassandra/distributed/test/FailingTruncationTest.java
View File

@ -19,7 +19,6 @@
package org.apache.cassandra.distributed.test;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicBoolean;
import org.junit.Test;

2
test/distributed/org/apache/cassandra/distributed/test/GossipShutdownTest.java
View File

@ -30,10 +30,8 @@ import org.apache.cassandra.utils.concurrent.Condition;
import org.junit.Test;
import org.apache.cassandra.distributed.Cluster;
import org.apache.cassandra.gms.ApplicationState;
import org.apache.cassandra.gms.EndpointState;
import org.apache.cassandra.gms.IEndpointStateChangeSubscriber;
import org.apache.cassandra.gms.VersionedValue;
import org.apache.cassandra.locator.InetAddressAndPort;
import org.apache.cassandra.service.StorageService;

8
test/distributed/org/apache/cassandra/distributed/test/NativeProtocolTest.java
View File

@ -31,14 +31,6 @@ import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.Session;
import com.datastax.driver.core.SimpleStatement;
import com.datastax.driver.core.Statement;
import com.datastax.driver.core.exceptions.DriverInternalError;
import com.datastax.driver.core.policies.LoadBalancingPolicy;
import net.bytebuddy.ByteBuddy;
import net.bytebuddy.dynamic.loading.ClassLoadingStrategy;
import net.bytebuddy.implementation.MethodDelegation;
import org.apache.cassandra.cql3.CQLStatement;
import org.apache.cassandra.cql3.QueryHandler;
import org.apache.cassandra.cql3.QueryProcessor;
import org.apache.cassandra.distributed.api.ICluster;
import org.apache.cassandra.distributed.impl.RowUtil;

1
test/distributed/org/apache/cassandra/distributed/test/RepairTest.java
View File

@ -22,7 +22,6 @@ import java.io.IOException;
import java.util.Arrays;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.function.Consumer;
import com.google.common.collect.ImmutableMap;

2
test/distributed/org/apache/cassandra/distributed/test/ReplicaFilteringProtectionTest.java
View File

@ -22,8 +22,6 @@ import java.io.IOException;
import java.util.List;
import org.junit.AfterClass;
import org.junit.Assume;
import org.junit.AssumptionViolatedException;
import org.junit.BeforeClass;
import org.junit.Test;

1
test/distributed/org/apache/cassandra/distributed/test/UpgradeSSTablesTest.java
View File

@ -23,7 +23,6 @@ import java.util.Set;
import org.junit.Assert;
import org.junit.Test;
import org.apache.cassandra.config.DatabaseDescriptor;
import org.apache.cassandra.db.ColumnFamilyStore;
import org.apache.cassandra.db.Keyspace;
import org.apache.cassandra.distributed.api.ConsistencyLevel;

1
test/distributed/org/apache/cassandra/distributed/upgrade/GroupByTest.java
View File

@ -21,7 +21,6 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import org.apache.cassandra.distributed.api.ConsistencyLevel;
import org.apache.cassandra.distributed.shared.Versions;
import static org.apache.cassandra.distributed.api.Feature.GOSSIP;
import static org.apache.cassandra.distributed.api.Feature.NETWORK;

2
test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV30Test.java
View File

@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import org.apache.cassandra.distributed.shared.Versions;
/**
* {@link MixedModeConsistencyTestBase} for upgrades from v30.
*/

2
test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV3XTest.java
View File

@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import org.apache.cassandra.distributed.shared.Versions;
/**
* {@link MixedModeConsistencyTestBase} for upgrades from v3X.
*/

2
test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3LoggedBatchTest.java
View File

@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import org.apache.cassandra.distributed.shared.Versions;
public class MixedModeFrom3LoggedBatchTest extends MixedModeBatchTestBase
{
@Test

2
test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3ReplicationTest.java
View File

@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import org.apache.cassandra.distributed.shared.Versions;
public class MixedModeFrom3ReplicationTest extends MixedModeReplicationTestBase
{
@Test

2
test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3UnloggedBatchTest.java
View File

@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import org.apache.cassandra.distributed.shared.Versions;
public class MixedModeFrom3UnloggedBatchTest extends MixedModeBatchTestBase
{
@Test

1
test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeGossipTest.java
View File

@ -33,7 +33,6 @@ import org.junit.Test;
import org.apache.cassandra.distributed.UpgradeableCluster;
import org.apache.cassandra.distributed.api.Feature;
import org.apache.cassandra.distributed.api.IMessageFilters;
import org.apache.cassandra.distributed.shared.Versions;
import org.apache.cassandra.net.Verb;
import org.assertj.core.api.Assertions;

1
test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeReadTest.java
View File

@ -22,7 +22,6 @@ import org.junit.Test;
import org.apache.cassandra.distributed.api.Feature;
import org.apache.cassandra.distributed.api.IInvokableInstance;
import org.apache.cassandra.distributed.shared.Versions;
import org.apache.cassandra.gms.Gossiper;
import org.apache.cassandra.utils.CassandraVersion;

5
test/distributed/org/apache/cassandra/distributed/upgrade/RepairRequestTimeoutUpgradeTest.java
View File

@ -20,13 +20,8 @@ package org.apache.cassandra.distributed.upgrade;
import org.junit.Test;
import com.vdurmont.semver4j.Semver;
import org.apache.cassandra.distributed.api.ConsistencyLevel;
import org.apache.cassandra.distributed.api.Feature;
import static org.apache.cassandra.distributed.shared.AssertUtils.assertRows;
import static org.apache.cassandra.distributed.shared.AssertUtils.row;
import static org.apache.cassandra.net.Verb.SYNC_REQ;
import static org.apache.cassandra.net.Verb.VALIDATION_REQ;
public class RepairRequestTimeoutUpgradeTest extends UpgradeTestBase

1
test/distributed/org/apache/cassandra/distributed/upgrade/UpgradeTest.java
View File

@ -22,7 +22,6 @@ import org.junit.Test;
import org.apache.cassandra.distributed.api.ConsistencyLevel;
import org.apache.cassandra.distributed.api.Feature;
import org.apache.cassandra.distributed.shared.Versions;
import static org.apache.cassandra.distributed.shared.AssertUtils.*;
public class UpgradeTest extends UpgradeTestBase

1
test/microbench/org/apache/cassandra/test/microbench/btree/AtomicBTreePartitionUpdateBench.java
View File

@ -24,7 +24,6 @@ import java.util.Comparator;
import java.util.List;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

2
test/simulator/asm/org/apache/cassandra/simulator/asm/InterceptAgent.java
View File

@ -45,11 +45,9 @@ import static org.apache.cassandra.simulator.asm.Flag.LOCK_SUPPORT;
import static org.apache.cassandra.simulator.asm.Flag.NO_PROXY_METHODS;
import static org.apache.cassandra.simulator.asm.Flag.SYSTEM_CLOCK;
import static org.apache.cassandra.simulator.asm.InterceptClasses.BYTECODE_VERSION;
import static org.objectweb.asm.Opcodes.ARETURN;
import static org.objectweb.asm.Opcodes.ALOAD;
import static org.objectweb.asm.Opcodes.GETFIELD;
import static org.objectweb.asm.Opcodes.GETSTATIC;
import static org.objectweb.asm.Opcodes.INVOKEINTERFACE;
import static org.objectweb.asm.Opcodes.INVOKESPECIAL;
import static org.objectweb.asm.Opcodes.INVOKESTATIC;
import static org.objectweb.asm.Opcodes.INVOKEVIRTUAL;

1
test/simulator/asm/org/apache/cassandra/simulator/asm/MethodLogger.java
View File

@ -27,7 +27,6 @@ import java.util.EnumSet;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
import org.objectweb.asm.MethodVisitor;
import org.objectweb.asm.util.Printer;

1
test/simulator/main/org/apache/cassandra/simulator/ClusterSimulation.java
View File

@ -102,7 +102,6 @@ import static java.util.concurrent.TimeUnit.NANOSECONDS;
import static java.util.concurrent.TimeUnit.SECONDS;
import static org.apache.cassandra.distributed.impl.AbstractCluster.getSharedClassPredicate;
import static org.apache.cassandra.simulator.SimulatorUtils.failWithOOM;
import static org.apache.cassandra.simulator.systems.NonInterceptible.Permit.REQUIRED;
import static org.apache.cassandra.utils.Shared.Scope.ANY;
import static org.apache.cassandra.utils.Shared.Scope.SIMULATION;

1
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceBootstrap.java
View File

@ -29,7 +29,6 @@ import org.apache.cassandra.simulator.systems.SimulatedActionTask;
import static java.util.Collections.singletonList;
import static org.apache.cassandra.simulator.Action.Modifier.DISPLAY_ORIGIN;
import static org.apache.cassandra.simulator.Action.Modifiers.RELIABLE_NO_TIMEOUTS;
import static org.apache.cassandra.simulator.Action.Modifiers.RELIABLE_NO_TIMEOUTS;
import static org.apache.cassandra.simulator.cluster.Utils.parseTokens;
class OnInstanceBootstrap extends SimulatedActionTask

1
test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWith.java
View File

@ -21,7 +21,6 @@ package org.apache.cassandra.simulator.cluster;
import java.net.InetSocketAddress;
import java.util.function.BiFunction;
import org.apache.cassandra.cql3.functions.Function;
import org.apache.cassandra.distributed.Cluster;
import org.apache.cassandra.distributed.api.IIsolatedExecutor;
import org.apache.cassandra.gms.Gossiper;

1
test/simulator/main/org/apache/cassandra/simulator/debug/Reconcile.java
View File

@ -40,7 +40,6 @@ import org.apache.cassandra.io.util.File;
import org.apache.cassandra.simulator.ClusterSimulation;
import org.apache.cassandra.simulator.RandomSource;
import org.apache.cassandra.simulator.SimulationRunner.RecordOption;
import org.apache.cassandra.simulator.systems.InterceptedWait;
import org.apache.cassandra.simulator.systems.InterceptedWait.CaptureSites.Capture;
import org.apache.cassandra.simulator.systems.SimulatedTime;
import org.apache.cassandra.utils.Closeable;

Some files were not shown because too many files have changed in this diff Show More