Package org.apache.cassandra.db

Examples of org.apache.cassandra.db.RangeTombstone$Tracker

71
72
73
74
75
76
77
    {
        ColumnFamily cf = rm.addOrGet(SystemKeyspace.SCHEMA_TRIGGERS_CF);
        int ldt = (int) (System.currentTimeMillis() / 1000);
        ColumnNameBuilder builder = CFMetaData.SchemaTriggerCf.getCfDef().getColumnNameBuilder();
        builder.add(ByteBufferUtil.bytes(cfName)).add(ByteBufferUtil.bytes(tentry.getKey()));
        cf.addAtom(new RangeTombstone(builder.build(), builder.buildAsEndOfRange(), modificationTimestamp, ldt));
    }
View Full Code Here
254
255
256
257
258
259
260
261
262
263
264
            {
                cfamily.addTombstone(path, col.getValue(), col.timestamp);
            }
            else if (col.isRangeTombstone())
            {
                cfamily.addAtom(new RangeTombstone(col.getName(), col.getValue(), col.timestamp, col.localExpirationTime));
            }
            // cql3 row marker, see CASSANDRA-5852
            else if (!path.columnName.hasRemaining())
            {
                cfamily.addColumn(new QueryPath(cfm.cfName, superName, ByteBuffer.wrap(new byte[3])), col.getValue(), col.timestamp);
View Full Code Here
1637
1638
1639
1640
1641
1642
1643
1644
1645
1646
1647
        Mutation mutation = new Mutation(Keyspace.SYSTEM_KS, SystemKeyspace.getSchemaKSKey(ksName));
        ColumnFamily cf = mutation.addOrGet(SchemaColumnFamiliesCf);
        int ldt = (int) (System.currentTimeMillis() / 1000);

        Composite prefix = SchemaColumnFamiliesCf.comparator.make(cfName);
        cf.addAtom(new RangeTombstone(prefix, prefix.end(), timestamp, ldt));

        for (ColumnDefinition cd : allColumns())
            cd.deleteFromSchema(mutation, timestamp);

        for (TriggerDefinition td : triggers.values())
View Full Code Here
TOP

Related Classes of org.apache.cassandra.db.RangeTombstone$Tracker

  • com.google.gwt.core.ext.TreeLogger
  • com.linkedin.common.stats.LongTracking
  • io.thp.psmove.PSMove
  • io.thp.psmove.PSMoveTracker
  • org.apache.cassandra.config.CFMetaData
  • org.apache.cassandra.config.TriggerOptions
  • org.apache.cassandra.db.composites.Composite
  • org.apache.cassandra.db.marshal.AbstractType
  • org.apache.cassandra.io.sstable.SSTableWriter
  • org.apache.cassandra.io.util.DataOutputBuffer
    • 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.