Package org.apache.cassandra.db

Examples of org.apache.cassandra.db.ReadCommand

170
171
172
173
174
175
176
177
178
179
180
    {
        long startTime = System.currentTimeMillis();
    try
    {
      validateTable(tablename);
      ColumnFamily cfamily = readColumnFamily(new ReadCommand(tablename, key, columnFamily, columnNames));
      if (cfamily == null)
      {
        logger_.info("ERROR ColumnFamily " + columnFamily + " is missing.....: "
              +"   key:" + key
              + "  ColumnFamily:" + columnFamily);
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
  {
        long startTime = System.currentTimeMillis();
    try
    {
          String[] values = RowMutation.getColumnAndColumnFamily(columnFamily_column);
      ColumnFamily cfamily = readColumnFamily(new ReadCommand(tablename, key, columnFamily_column, start, count));
      if (cfamily == null)
      {
        logger_.info("ERROR ColumnFamily " + columnFamily_column + " is missing.....: "  + "   key:" + key + "  ColumnFamily:" + values[0]);
        throw new CassandraException("Either the key " + key + " is not present or the columns requested" + columnFamily_column + "are not present.");
      }
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
    public column_t get_column(String tablename, String key, String columnFamily_column) throws CassandraException,TException
    {
    try
    {
          String[] values = RowMutation.getColumnAndColumnFamily(columnFamily_column);
      ColumnFamily cfamily = readColumnFamily(new ReadCommand(tablename, key, columnFamily_column, -1, Integer.MAX_VALUE));
      if (cfamily == null || values.length < 2)
      {
        logger_.info("ERROR ColumnFamily  is missing.....: "
              +"   key:" + key
              + "  ColumnFamily:" + values[0]);
View Full Code Here
302
303
304
305
306
307
308
309
310
311
312
  {
      int count = -1;
    try
    {
          String[] values = RowMutation.getColumnAndColumnFamily(columnFamily_column);
      ColumnFamily cfamily = readColumnFamily(new ReadCommand(tablename, key, columnFamily_column, -1, Integer.MAX_VALUE));
      if (cfamily == null)
      {
        logger_.info("ERROR ColumnFamily  is missing.....: "
              +"   key:" + key
              + "  ColumnFamily:" + values[0]);
View Full Code Here
390
391
392
393
394
395
396
397
398
399
400
        long startTime = System.currentTimeMillis();
   
    try
    {
      validateTable(tablename);
      ColumnFamily cfamily = readColumnFamily(new ReadCommand(tablename, key, columnFamily, superColumnNames));
      if (cfamily == null)
      {
        logger_.info("ERROR ColumnFamily " + columnFamily + " is missing.....: "+"   key:" + key
              + "  ColumnFamily:" + columnFamily);
        throw new CassandraException("Either the key " + key + " is not present or the column family requested" + columnFamily + "is not present.");
View Full Code Here
439
440
441
442
443
444
445
446
447
448
449
    public List<superColumn_t> get_slice_super(String tablename, String key, String columnFamily_superColumnName, int start, int count) throws CassandraException
    {
    try
    {
          String[] values = RowMutation.getColumnAndColumnFamily(columnFamily_superColumnName);
      ColumnFamily cfamily = readColumnFamily(new ReadCommand(tablename, key, columnFamily_superColumnName, start, count));
      if (cfamily == null)
      {
        logger_.info("ERROR ColumnFamily  is missing.....: "
              +"   key:" + key
              + "  ColumnFamily:" + values[0]);
View Full Code Here
471
472
473
474
475
476
477
478
479
480
481
    public superColumn_t get_superColumn(String tablename, String key, String columnFamily_column) throws CassandraException
    {
    try
    {
          String[] values = RowMutation.getColumnAndColumnFamily(columnFamily_column);
      ColumnFamily cfamily = readColumnFamily(new ReadCommand(tablename, key, columnFamily_column, -1, Integer.MAX_VALUE));
      if (cfamily == null)
      {
        logger_.info("ERROR ColumnFamily  is missing.....: "
              +"   key:" + key
              + "  ColumnFamily:" + values[0]);
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
152
153
154
        readCommand_ = readCommand;
    }

  public void run()
  {
        ReadCommand readCommandDigestOnly = constructReadMessage(true);
    try
    {
      Message message = readCommandDigestOnly.makeReadMessage();
            if (logger_.isDebugEnabled())
              logger_.debug("Reading consistency digest for " + readCommand_.key + " from " + message.getMessageId() + "@[" + StringUtils.join(replicas_, ", ") + "]");
            MessagingService.instance().sendRR(message, replicas_.toArray(new InetAddress[replicas_.size()]), new DigestResponseHandler());
    }
    catch (IOException ex)
View Full Code Here
157
158
159
160
161
162
163
164
165
    }
  }
   
    private ReadCommand constructReadMessage(boolean isDigestQuery)
    {
        ReadCommand readCommand = readCommand_.copy();
        readCommand.setDigestQuery(isDigestQuery);
        return readCommand;
    }
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
    {
      IResponseResolver<Row> readResponseResolver = new ReadResponseResolver();
            /* Add the local storage endpoint to the replicas_ list */
            replicas_.add(FBUtilities.getLocalAddress());
      IAsyncCallback responseHandler = new DataRepairHandler(ConsistencyManager.this.replicas_.size(), readResponseResolver); 
            ReadCommand readCommand = constructReadMessage(false);
            Message message = readCommand.makeReadMessage();
            if (logger_.isDebugEnabled())
              logger_.debug("Performing read repair for " + readCommand_.key + " to " + message.getMessageId() + "@[" + StringUtils.join(replicas_, ", ") + "]");
      MessagingService.instance().sendRR(message, replicas_.toArray(new InetAddress[replicas_.size()]), responseHandler);
    }
View Full Code Here
TOP

Related Classes of org.apache.cassandra.db.ReadCommand

  • com.netflix.jmeter.connections.fatclient.FatClientOperation
  • lucandra.cluster.CassandraIndexManager
  • lucandra.LucandraTermEnum
  • lucandra.TermFreqVector
  • org.apache.cassandra.cql.common.ColumnRangeQueryRSD
  • org.apache.cassandra.cql.common.SuperColumnRangeQueryRSD
  • org.apache.cassandra.cql.common.UniqueKeyQueryRSD
  • org.apache.cassandra.hadoop.trackers.TrackerManager
  • org.apache.cassandra.io.util.FastByteArrayOutputStream
  • org.apache.cassandra.net.Message
    • 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.