Package org.apache.cassandra.db.filter

Examples of org.apache.cassandra.db.filter.SliceQueryFilter

594
595
596
597
598
599
600
601
            ss.addAll(sp.column_names);
            return new NamesQueryFilter(ss);
        }
        else
        {
            return new SliceQueryFilter(sr.start, sr.finish, sr.reversed, sr.count);
        }
    }
View Full Code Here
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
        return trim(command, rows);
    }

    private static IDiskAtomFilter getEmptySlicePredicate()
    {
        return new SliceQueryFilter(ByteBufferUtil.EMPTY_BYTE_BUFFER,
                                    ByteBufferUtil.EMPTY_BYTE_BUFFER,
                                    false,
                                    -1);
    }
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
        List<ReadCommand> commands = new ArrayList<ReadCommand>(keys.size());
        for (ByteBuffer key : keys)
            commands.add(new SliceFromReadCommand(keyspace(),
                                                  key,
                                                  new QueryPath(columnFamily()),
                                                  new SliceQueryFilter(slices, false, Integer.MAX_VALUE)));

        try
        {
            List<Row> rows = local
                           ? SelectStatement.readLocally(keyspace(), commands)
View Full Code Here
595
596
597
598
599
600
601
602
            ss.addAll(sp.column_names);
            return new NamesQueryFilter(ss);
        }
        else
        {
            return new SliceQueryFilter(sr.start, sr.finish, sr.reversed, sr.count);
        }
    }
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
        List<ReadCommand> commands = new ArrayList<ReadCommand>(keys.size());
        for (ByteBuffer key : keys)
            commands.add(new SliceFromReadCommand(keyspace(),
                                                  key,
                                                  new QueryPath(columnFamily()),
                                                  new SliceQueryFilter(slices, false, Integer.MAX_VALUE)));

        try
        {
            List<Row> rows = local
                           ? SelectStatement.readLocally(keyspace(), commands)
View Full Code Here
186
187
188
189
190
191
192
193
194
195
        {
            sp.setColumn_names(new ArrayList<ByteBuffer>(((NamesQueryFilter)predicate).columns));
        }
        else
        {
            SliceQueryFilter sqf = (SliceQueryFilter)predicate;
            sp.setSlice_range(new SliceRange(sqf.start(), sqf.finish(), sqf.reversed, sqf.count));
        }
        return sp;
    }
View Full Code Here
269
270
271
272
273
274
275
276
277
278
279
        assert "k3".equals( key );

        assert rows.get(0).cf.getColumnCount() == 1 : rows.get(0).cf;

        // once more, this time with a slice rowset that needs to be expanded
        SliceQueryFilter emptyFilter = new SliceQueryFilter(Composites.EMPTY, Composites.EMPTY, false, 0);
        rows = cfs.search(range, clause, emptyFilter, 100);

        assert rows.size() == 1 : StringUtils.join(rows, ",");
        key = new String(rows.get(0).key.getKey().array(), rows.get(0).key.getKey().position(), rows.get(0).key.getKey().remaining());
        assert "k3".equals( key );
View Full Code Here
1030
1031
1032
1033
1034
1035
1036
1037
1038
    private static void assertTotalColCount(Collection<Row> rows, int expectedCount)
    {
        int columns = 0;
        for (Row row : rows)
        {
            columns += row.getLiveCount(new SliceQueryFilter(ColumnSlice.ALL_COLUMNS_ARRAY, false, expectedCount), System.currentTimeMillis());
        }
        assert columns == expectedCount : "Expected " + expectedCount + " live columns but got " + columns + ": " + rows;
    }
View Full Code Here
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
        row2 = iter.next();
        assertColumnNames(row1, "c2");
        assertColumnNames(row2, "c0", "c1");

        // Paging within bounds
        SliceQueryFilter sf = new SliceQueryFilter(cellname("c1"),
                                                   cellname("c2"),
                                                   false,
                                                   0);
        rows = cfs.getRangeSlice(cfs.makeExtendedFilter(new Bounds<RowPosition>(ka, kc), sf, cellname("c2"), cellname("c1"), null, 2, true, System.currentTimeMillis()));
        assert rows.size() == 2 : "Expected 2 rows, got " + toString(rows);
View Full Code Here
1405
1406
1407
1408
1409
1410
1411
1412
1413
1414
1415
1416
1417
1418
        putColsStandard(cfs, dk("a"), cols);

        cfs.forceBlockingFlush();

        SliceQueryFilter multiRangeForward = new SliceQueryFilter(ranges, false, 100);
        SliceQueryFilter multiRangeForwardWithCounting = new SliceQueryFilter(ranges, false, 3);
        SliceQueryFilter multiRangeReverse = new SliceQueryFilter(rangesReversed, true, 100);
        SliceQueryFilter multiRangeReverseWithCounting = new SliceQueryFilter(rangesReversed, true, 3);

        findRowGetSlicesAndAssertColsFound(cfs, multiRangeForward, "a", "colA", "colC", "colD", "colI");
        findRowGetSlicesAndAssertColsFound(cfs, multiRangeForwardWithCounting, "a", "colA", "colC", "colD");
        findRowGetSlicesAndAssertColsFound(cfs, multiRangeReverse, "a", "colI", "colD", "colC", "colA");
        findRowGetSlicesAndAssertColsFound(cfs, multiRangeReverseWithCounting, "a", "colI", "colD", "colC");
View Full Code Here
TOP

Related Classes of org.apache.cassandra.db.filter.SliceQueryFilter

  • com.stratio.cassandra.index.FullKeyMapperDataRangeFilter
  • com.stratio.cassandra.index.RowServiceWide
  • org.apache.cassandra.cql3.statements.ModificationStatement
  • org.apache.cassandra.cql3.statements.ModificationStatement$CQL3CasConditions
  • org.apache.cassandra.db.ColumnFamilyStore
  • org.apache.cassandra.db.ColumnFamilyStoreTest
  • org.apache.cassandra.db.columniterator.OnDiskAtomIterator
  • org.apache.cassandra.db.columniterator.SSTableSliceIterator
  • org.apache.cassandra.db.composites.CellName
  • org.apache.cassandra.db.composites.CellNameType
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.