本文整理了Java中org.apache.cassandra.transport.messages.QueryMessage类的一些代码示例，展示了QueryMessage类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryMessage类的具体详情如下：
包路径：org.apache.cassandra.transport.messages.QueryMessage
类名称：QueryMessage

QueryMessage介绍

[英]A CQL query
[中]CQL查询

代码示例

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

public ResultMessage execute(String query, List<ByteBuffer> values, ConsistencyLevel consistencyLevel)
{
  Message.Response msg = execute(new QueryMessage(query, QueryOptions.forInternalCalls(consistencyLevel, values)));
  assert msg instanceof ResultMessage;
  return (ResultMessage)msg;
}

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

if (isTracingRequested())
  state.createTracingSession(getCustomPayload());
Message.Response response = ClientState.getCQLQueryHandler().process(query, state, options, getCustomPayload(), queryStartNanoTime);
if (options.skipMetadata() && response instanceof ResultMessage.Rows)
  ((ResultMessage.Rows)response).result.metadata.setSkipMetadata();

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

if (isTracingRequested())

代码示例来源：origin: org.apache.cassandra/cassandra-all

if (isTracingRequested())
  state.createTracingSession(getCustomPayload());
Message.Response response = ClientState.getCQLQueryHandler().process(query, state, options, getCustomPayload(), queryStartNanoTime);
if (options.skipMetadata() && response instanceof ResultMessage.Rows)
  ((ResultMessage.Rows)response).result.metadata.setSkipMetadata();

代码示例来源：origin: jsevellec/cassandra-unit

if (isTracingRequested())
  state.createTracingSession(getCustomPayload());
Message.Response response = ClientState.getCQLQueryHandler().process(query, state, options, getCustomPayload(), queryStartNanoTime);
if (options.skipMetadata() && response instanceof ResultMessage.Rows)
  ((ResultMessage.Rows)response).result.metadata.setSkipMetadata();

代码示例来源：origin: org.apache.cassandra/cassandra-all

public ResultMessage execute(String query, List<ByteBuffer> values, ConsistencyLevel consistencyLevel)
{
  Message.Response msg = execute(new QueryMessage(query, QueryOptions.forInternalCalls(consistencyLevel, values)));
  assert msg instanceof ResultMessage;
  return (ResultMessage)msg;
}

代码示例来源：origin: jsevellec/cassandra-unit

public ResultMessage execute(String query, List<ByteBuffer> values, ConsistencyLevel consistencyLevel)
{
  Message.Response msg = execute(new QueryMessage(query, QueryOptions.forInternalCalls(consistencyLevel, values)));
  assert msg instanceof ResultMessage;
  return (ResultMessage)msg;
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

public ResultMessage execute(String query, List<ByteBuffer> values, ConsistencyLevel consistencyLevel)
{
  Message.Response msg = execute(new QueryMessage(query, QueryOptions.forInternalCalls(consistencyLevel, values)));
  assert msg instanceof ResultMessage;
  return (ResultMessage)msg;
}

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

return new QueryMessage(query, QueryOptions.create(ConsistencyLevel.ONE, Collections.<ByteBuffer>emptyList(), false, pageSize, null, null, version));

代码示例来源：origin: org.apache.cassandra/cassandra-all

return new QueryMessage(query, QueryOptions.create(ConsistencyLevel.ONE, Collections.<ByteBuffer>emptyList(), false, pageSize, null, null, version));

代码示例来源：origin: jsevellec/cassandra-unit

return new QueryMessage(query, QueryOptions.create(ConsistencyLevel.ONE, Collections.<ByteBuffer>emptyList(), false, pageSize, null, null, version));

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

return new QueryMessage(query, QueryOptions.create(ConsistencyLevel.ONE, Collections.<ByteBuffer>emptyList(), false, pageSize, null, null));