Package org.apache.cassandra.db

Examples of org.apache.cassandra.db.ReadCommand

269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
                return;

            if (!handler.await(cfs.sampleLatencyNanos, TimeUnit.NANOSECONDS))
            {
                // Could be waiting on the data, or on enough digests.
                ReadCommand retryCommand = command;
                if (resolver.getData() != null)
                {
                    retryCommand = command.copy();
                    retryCommand.setDigestQuery(true);
                }

                InetAddress extraReplica = Iterables.getLast(targetReplicas);
                logger.trace("speculating read retry on {}", extraReplica);
                MessagingService.instance().sendRR(retryCommand.createMessage(), extraReplica, handler);
                speculated = true;

                cfs.metric.speculativeRetries.inc();
            }
        }
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
80
81
82
        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.addCallback(new DigestResponseHandler(), message.getMessageId());
            for (InetAddress endpoint : replicas_)
View Full Code Here
91
92
93
94
95
96
97
98
99
    }
  }

    private ReadCommand constructReadMessage(boolean isDigestQuery)
    {
        ReadCommand readCommand = readCommand_.copy();
        readCommand.setDigestQuery(isDigestQuery);
        return readCommand;
    }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
132
                    if (replicas_.contains(FBUtilities.getLocalAddress()))
                        responseHandler = new DataRepairHandler(row_, replicas_.size(), readResponseResolver);
                    else
                        responseHandler = new DataRepairHandler(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.addCallback(responseHandler, message.getMessageId());
                    for (InetAddress endpoint : replicas_)
                    {
View Full Code Here
184
185
186
187
188
189
190
191
192
193
194
195
                if (logger.isDebugEnabled())
                    logger.debug("Digest mismatch:", e);
               
                ReadRepairMetrics.repairedBackground.mark();
               
                ReadCommand readCommand = (ReadCommand) command;
                final RowDataResolver repairResolver = new RowDataResolver(readCommand.table, readCommand.key, readCommand.filter());
                IAsyncCallback repairHandler = new AsyncRepairCallback(repairResolver, endpoints.size());

                MessageOut<ReadCommand> message = ((ReadCommand) command).createMessage();
                for (InetAddress endpoint : endpoints)
                    MessagingService.instance().sendRR(message, endpoint, repairHandler);
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
169
170
171
        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.getMessagingInstance().sendRR(message, replicas_.toArray(new EndPoint[replicas_.size()]), new DigestResponseHandler());
    }
    catch (IOException ex)
View Full Code Here
174
175
176
177
178
179
180
181
182
    }
  }
   
    private ReadCommand constructReadMessage(boolean isDigestQuery)
    {
        ReadCommand readCommand = readCommand_.copy();
        readCommand.setDigestQuery(isDigestQuery);
        return readCommand;
    }
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
    {
      IResponseResolver<Row> readResponseResolver = new ReadResponseResolver();
            /* Add the local storage endpoint to the replicas_ list */
            replicas_.add(StorageService.getLocalStorageEndPoint());
      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.getMessagingInstance().sendRR(message, replicas_.toArray(new EndPoint[replicas_.size()]), responseHandler);
    }
View Full Code Here
191
192
193
194
195
196
197
198
199
200
201
202
                if (logger.isDebugEnabled())
                    logger.debug("Digest mismatch:", e);
               
                ReadRepairMetrics.repairedBackground.mark();
               
                ReadCommand readCommand = (ReadCommand) command;
                final RowDataResolver repairResolver = new RowDataResolver(readCommand.ksName, readCommand.key, readCommand.filter(), readCommand.timestamp);
                AsyncRepairCallback repairHandler = new AsyncRepairCallback(repairResolver, endpoints.size());

                MessageOut<ReadCommand> message = ((ReadCommand) command).createMessage();
                for (InetAddress endpoint : endpoints)
                    MessagingService.instance().sendRR(message, endpoint, repairHandler);
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
193
                if (logger.isDebugEnabled())
                    logger.debug("Digest mismatch:", e);
               
                ReadRepairMetrics.repairedBackground.mark();
               
                ReadCommand readCommand = (ReadCommand) command;
                final RowDataResolver repairResolver = new RowDataResolver(readCommand.ksName, readCommand.key, readCommand.filter(), readCommand.timestamp);
                AsyncRepairCallback repairHandler = new AsyncRepairCallback(repairResolver, endpoints.size());

                MessageOut<ReadCommand> message = ((ReadCommand) command).createMessage();
                for (InetAddress endpoint : endpoints)
                    MessagingService.instance().sendRR(message, endpoint, repairHandler);
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.