Examples of CounterColumn

Examples of org.apache.cassandra.thrift.CounterColumn

1503
1504
1505
1506
1507
1508
1509
1510
1511
1512
1513
     *            the name
     * @return the counter column
     */
    private CounterColumn prepareCounterColumn(String value, byte[] name)
    {
        CounterColumn counterColumn = new CounterColumn();
        counterColumn.setName(name);
        LongAccessor accessor = new LongAccessor();
        counterColumn.setValue(accessor.fromString(LongAccessor.class, value));
        return counterColumn;
    }
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

1695
1696
1697
1698
1699
1700
1701
1702
1703
1704
1705
1706
1707
            }
            if (null != value)
            {
                try
                {
                    CounterColumn thriftColumn = new CounterColumn();
                    thriftColumn.setName(PropertyAccessorFactory.STRING.toBytes(name));
                    thriftColumn.setValue(Long.parseLong(value));
                    thriftColumns.add(thriftColumn);

                    tableName = ((AbstractAttribute) column).getTableName() != null ? ((AbstractAttribute) column)
                            .getTableName() : tableName;
                    CounterSuperColumn thriftSuperColumn = (CounterSuperColumn) thriftCounterSuperColumns
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

55
56
57
58
59
60
61
62
63
64
    }
    return columnPath;
  }
 
  public static CounterColumn createCounterColumn(String name, long value) {
    CounterColumn cc = new CounterColumn();
    cc.setName(StringSerializer.get().toByteBuffer(name));
    cc.setValue(value);
    return cc;
  }
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

62
63
64
65
66
67
68
69
70
71
    cc.setValue(value);
    return cc;
  }
 
  public static <N> CounterColumn createCounterColumn(N name, long value, Serializer<N> ns) {
    CounterColumn cc = new CounterColumn();
    cc.setName(ns.toByteBuffer(name));
    cc.setValue(value);
    return cc;
  }
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

63
64
65
66
67
68
69
70
71
72
73
        keyspace.doExecute(new KeyspaceOperationCallback<HCounterColumn<N>>() {

          @Override
          public HCounterColumn<N> doInKeyspace(KeyspaceService ks) throws HectorException {
            try {
              CounterColumn thriftCounter = ks.getCounter(keySerializer.toByteBuffer(key),
                  ThriftFactory.createColumnPath(columnFamilyName, name, columnNameSerializer));
              return new HCounterColumnImpl<N>(thriftCounter, columnNameSerializer);
            } catch (HNotFoundException e) {
              return null;
            }
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

29
30
31
32
33
34
35
  public HCounterColumnImpl(N name, Long value, Serializer<N> nameSerializer) {
    this(nameSerializer);
    notNull(name, "name is null");
    notNull(value, "value is null");
    this.counterColumn = new CounterColumn(nameSerializer.toByteBuffer(name), value);
  }
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

41
42
43
44
45
46
47
  }

  public HCounterColumnImpl(Serializer<N> nameSerializer) {
    notNull(nameSerializer, "nameSerializer is null");
    this.nameSerializer = nameSerializer;
    this.counterColumn = new CounterColumn();
  }
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
    @Override
    public ColumnListMutation<C> incrementCounterColumn(C columnName, long amount) {
        Preconditions.checkNotNull(columnName, "Column name cannot be null");
       
        // 1. Set up the column with all the data
        CounterColumn column = new CounterColumn();
        column.setName(columnSerializer.toByteBuffer(columnName));
        if (column.getName().length == 0) {
            throw new RuntimeException("Column name cannot be empty");
        }
        column.setValue(amount);

        // 2. Create a mutation and append to the mutation list.
        Mutation mutation = new Mutation();
        mutation.setColumn_or_supercolumn(new ColumnOrSuperColumn().setCounter_column(column));
        mutationList.add(mutation);
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

315
316
317
318
319
320
321
322
323
324
325
                                        tracerFactory.newTracer(CassandraOperationType.COUNTER_MUTATE),
                                        getKeyspaceName()) {
                                    @Override
                                    public Void internalExecute(Client client, ConnectionContext context) throws Exception {
                                        client.add(key, ThriftConverter.getColumnParent(columnFamily, null),
                                                new CounterColumn().setValue(amount).setName(column),
                                                ThriftConverter.ToThriftConsistencyLevel(writeConsistencyLevel));
                                        return null;
                                    }

                                    @Override
View Full Code Here

Examples of org.apache.cassandra.thrift.CounterColumn

72
73
74
75
76
77
78
79
80
81
82
83
84
    }

    @Override
    public ColumnListMutation<C> incrementCounterColumn(C columnName, long amount) {
        // 1. Set up the column with all the data
        CounterColumn column = new CounterColumn();
        column.setName(path.getSerializer().toByteBuffer(columnName));
        column.setValue(amount);

        // 2. Create the super column mutation if this is the first call
        if (superColumn == null) {
            superColumn = new CounterSuperColumn().setName(path.get(0));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.