List of buildAsEndOfRange() Examples

Examples of buildAsEndOfRange()

org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()
Build the column name so that the result sorts at the end of the range represented by this (uncomplete) column name. @throws IllegalStateException if the builder is empty or full.

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        ColumnFamily cf = rm.addOrGet(SchemaColumnFamiliesCf);
        int ldt = (int) (System.currentTimeMillis() / 1000);


        ColumnNameBuilder builder = SchemaColumnFamiliesCf.getCfDef().getColumnNameBuilder();
        builder.add(ByteBufferUtil.bytes(cfName));
        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), timestamp, ldt));


        for (ColumnDefinition cd : column_metadata.values())
            cd.deleteFromSchema(rm, cfName, timestamp);


        for (TriggerDefinition td : triggers.values())

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()


        ColumnNameBuilder builder = CFMetaData.SchemaColumnsCf.getCfDef().getColumnNameBuilder();
        // Note: the following is necessary for backward compatibility. For CQL3, comparator will be UTF8 and nameBytes == name
        ByteBuffer nameBytes = ByteBufferUtil.bytes(comparator.getString(name));
        builder.add(ByteBufferUtil.bytes(cfName)).add(nameBytes);
        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), timestamp, ldt));
    }


    public void toSchema(RowMutation rm, String cfName, AbstractType<?> comparator, long timestamp)
    {
        ColumnFamily cf = rm.addOrGet(CFMetaData.SchemaColumnsCf);

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        }
        else
        {
            builder = index.getIndexComparator().builder().add(key);
        }
        return isStart ? builder.build() : builder.buildAsEndOfRange();
    }


    private ColumnFamilyStore.AbstractScanIterator getIndexedIterator(final ExtendedFilter filter)
    {
        // Start with the most-restrictive indexed clause, then apply remaining clauses

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        ColumnFamily cf = rm.addOrGet(SchemaColumnFamiliesCf);
        int ldt = (int) (System.currentTimeMillis() / 1000);


        ColumnNameBuilder builder = SchemaColumnFamiliesCf.getCfDef().getColumnNameBuilder();
        builder.add(ByteBufferUtil.bytes(cfName));
        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), timestamp, ldt));


        for (ColumnDefinition cd : column_metadata.values())
            cd.deleteFromSchema(rm, cfName, getColumnDefinitionComparator(cd), timestamp);


        for (TriggerDefinition td : triggers.values())

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        }
        else
        {
            builder = index.getIndexComparator().builder().add(key);
        }
        return isStart ? builder.build() : builder.buildAsEndOfRange();
    }


    private ColumnFamilyStore.AbstractScanIterator getIndexedIterator(final ExtendedFilter filter)
    {
        // Start with the most-restrictive indexed clause, then apply remaining clauses

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        ColumnFamily cf = rm.addOrGet(CFMetaData.SchemaColumnsCf);
        int ldt = (int) (System.currentTimeMillis() / 1000);


        ColumnNameBuilder builder = CFMetaData.SchemaColumnsCf.getCfDef().getColumnNameBuilder();
        builder.add(ByteBufferUtil.bytes(cfName)).add(name);
        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), timestamp, ldt));
    }


    public void toSchema(RowMutation rm, String cfName, AbstractType<?> comparator, long timestamp)
    {
        ColumnFamily cf = rm.addOrGet(CFMetaData.SchemaColumnsCf);

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

    {
        ColumnFamily cf = rm.addOrGet(CFMetaData.SchemaTriggersCf);
        int ldt = (int) (System.currentTimeMillis() / 1000);
        ColumnNameBuilder builder = CFMetaData.SchemaTriggersCf.getCfDef().getColumnNameBuilder();
        builder.add(ByteBufferUtil.bytes(cfName)).add(ByteBufferUtil.bytes(tentry.getKey()));
        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), modificationTimestamp, ldt));
    }


    public static void update(CFMetaData cfm, String triggerName, String clazz)
    {
        Map<String, Map<String, String>> existingTriggers = cfm.getTriggers();

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        ColumnFamily cf = rm.addOrGet(SchemaColumnFamiliesCf);
        int ldt = (int) (System.currentTimeMillis() / 1000);


        ColumnNameBuilder builder = SchemaColumnFamiliesCf.getCfDef().getColumnNameBuilder();
        builder.add(ByteBufferUtil.bytes(cfName));
        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), timestamp, ldt));


        ColumnFamily tcf = rm.addOrGet(SchemaTriggersCf);
        ColumnNameBuilder tbuilder = SchemaTriggersCf.getCfDef().getColumnNameBuilder();
        tbuilder.add(ByteBufferUtil.bytes(cfName));
        tcf.addAtom(new RangeTombstone(tbuilder.build(), tbuilder.buildAsEndOfRange(), timestamp, ldt));

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), timestamp, ldt));


        ColumnFamily tcf = rm.addOrGet(SchemaTriggersCf);
        ColumnNameBuilder tbuilder = SchemaTriggersCf.getCfDef().getColumnNameBuilder();
        tbuilder.add(ByteBufferUtil.bytes(cfName));
        tcf.addAtom(new RangeTombstone(tbuilder.build(), tbuilder.buildAsEndOfRange(), timestamp, ldt));


        for (ColumnDefinition cd : column_metadata.values())
            cd.deleteFromSchema(rm, cfName, timestamp);


        return rm;

View Full Code Here

Examples of org.apache.cassandra.cql3.ColumnNameBuilder.buildAsEndOfRange()

        }
        else
        {
            builder = index.getIndexComparator().builder().add(key);
        }
        return isStart ? builder.build() : builder.buildAsEndOfRange();
    }


    private ColumnFamilyStore.AbstractScanIterator getIndexedIterator(final ExtendedFilter filter)
    {
        // Start with the most-restrictive indexed clause, then apply remaining clauses

View Full Code Here

0 1 2

TOP

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.