|
24 | 24 | import java.util.stream.StreamSupport;
|
25 | 25 |
|
26 | 26 | import com.google.common.base.Joiner;
|
27 |
| -import com.google.common.collect.*; |
| 27 | +import com.google.common.collect.ImmutableMap; |
| 28 | +import com.google.common.collect.Iterators; |
| 29 | +import com.google.common.collect.Lists; |
| 30 | +import com.google.common.collect.Sets; |
| 31 | +import org.awaitility.Awaitility; |
| 32 | +import org.junit.BeforeClass; |
28 | 33 | import org.junit.Test;
|
29 | 34 |
|
30 | 35 | import org.apache.cassandra.Util;
|
31 | 36 | import org.apache.cassandra.cql3.CQLTester;
|
32 | 37 | import org.apache.cassandra.cql3.UntypedResultSet;
|
33 | 38 | import org.apache.cassandra.cql3.restrictions.StatementRestrictions;
|
34 |
| -import org.apache.cassandra.db.*; |
| 39 | +import org.apache.cassandra.db.ColumnFamilyStore; |
| 40 | +import org.apache.cassandra.db.DecoratedKey; |
| 41 | +import org.apache.cassandra.db.ReadExecutionController; |
| 42 | +import org.apache.cassandra.db.SinglePartitionReadCommand; |
| 43 | +import org.apache.cassandra.db.Slice; |
| 44 | +import org.apache.cassandra.db.Slices; |
| 45 | +import org.apache.cassandra.db.SystemKeyspace; |
35 | 46 | import org.apache.cassandra.db.filter.ClusteringIndexFilter;
|
36 | 47 | import org.apache.cassandra.db.filter.ClusteringIndexSliceFilter;
|
37 | 48 | import org.apache.cassandra.db.filter.ColumnFilter;
|
|
42 | 53 | import org.apache.cassandra.schema.ColumnMetadata;
|
43 | 54 | import org.apache.cassandra.schema.SchemaConstants;
|
44 | 55 | import org.apache.cassandra.schema.TableMetadata;
|
| 56 | +import org.apache.cassandra.service.StorageService; |
45 | 57 | import org.apache.cassandra.service.accord.AccordKeyspace;
|
46 | 58 | import org.apache.cassandra.utils.ByteBufferUtil;
|
47 | 59 | import org.apache.cassandra.utils.FBUtilities;
|
48 |
| -import org.awaitility.Awaitility; |
49 | 60 |
|
50 | 61 | import static org.apache.cassandra.Util.throwAssert;
|
51 | 62 | import static org.junit.Assert.assertArrayEquals;
|
|
59 | 70 | */
|
60 | 71 | public class CassandraIndexTest extends CQLTester
|
61 | 72 | {
|
| 73 | + @BeforeClass |
| 74 | + public static void setup() |
| 75 | + { |
| 76 | + StorageService.instance.unsafeSetInitialized(); |
| 77 | + } |
| 78 | + |
62 | 79 | @Test
|
63 | 80 | public void indexOnRegularColumn() throws Throwable
|
64 | 81 | {
|
|
0 commit comments