本文整理汇总了Java中org.apache.cassandra.cql.QueryProcessor类的典型用法代码示例。如果您正苦于以下问题:Java QueryProcessor类的具体用法?Java QueryProcessor怎么用?Java QueryProcessor使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
QueryProcessor类属于org.apache.cassandra.cql包,在下文中一共展示了QueryProcessor类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: prepare_cql_query
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
public CqlPreparedResult prepare_cql_query(ByteBuffer query, Compression compression)
throws InvalidRequestException, TException
{
if (logger.isDebugEnabled())
logger.debug("prepare_cql_query");
validateCQLVersion(2);
maybeLogCQL2Warning();
String queryString = uncompress(query, compression);
ThriftClientState cState = state();
try
{
cState.validateLogin();
return QueryProcessor.prepare(queryString, cState);
}
catch (RequestValidationException e)
{
throw ThriftConversion.toThrift(e);
}
}
开发者ID:vcostet,项目名称:cassandra-kmean,代码行数:23,代码来源:CassandraServer.java
示例2: prepare_cql_query
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
public CqlPreparedResult prepare_cql_query(ByteBuffer query, Compression compression)
throws InvalidRequestException, TException
{
if (logger.isDebugEnabled())
logger.debug("prepare_cql_query");
validateCQLVersion(2);
maybeLogCQL2Warning();
try
{
ThriftClientState cState = state();
String queryString = uncompress(query,compression);
return QueryProcessor.prepare(queryString, cState);
}
catch (RequestValidationException e)
{
throw ThriftConversion.toThrift(e);
}
}
开发者ID:pgaref,项目名称:ACaZoo,代码行数:21,代码来源:CassandraServer.java
示例3: prepare_cql3_query
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
public CqlPreparedResult prepare_cql3_query(ByteBuffer query, Compression compression)
throws InvalidRequestException, TException
{
if (logger.isDebugEnabled())
logger.debug("prepare_cql3_query");
validateCQLVersion(3);
try
{
ThriftClientState cState = state();
String queryString = uncompress(query,compression);
return org.apache.cassandra.cql3.QueryProcessor.prepare(queryString, cState, true).toThriftPreparedResult();
}
catch (RequestValidationException e)
{
throw ThriftConversion.toThrift(e);
}
}
开发者ID:pgaref,项目名称:ACaZoo,代码行数:20,代码来源:CassandraServer.java
示例4: prepare_cql_query
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
public CqlPreparedResult prepare_cql_query(ByteBuffer query, Compression compression)
throws InvalidRequestException, TException
{
if (logger.isDebugEnabled())
logger.debug("prepare_cql_query");
validateCQLVersion(2);
try
{
ThriftClientState cState = state();
String queryString = uncompress(query,compression);
return QueryProcessor.prepare(queryString, cState);
}
catch (RequestValidationException e)
{
throw ThriftConversion.toThrift(e);
}
}
开发者ID:dprguiuc,项目名称:Cassandra-Wasef,代码行数:20,代码来源:CassandraServer.java
示例5: prepare_cql3_query
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
public CqlPreparedResult prepare_cql3_query(ByteBuffer query, Compression compression)
throws InvalidRequestException, TException
{
if (logger.isDebugEnabled())
logger.debug("prepare_cql3_query");
validateCQLVersion(3);
String queryString = uncompress(query, compression);
ThriftClientState cState = state();
try
{
cState.validateLogin();
return org.apache.cassandra.cql3.QueryProcessor.prepare(queryString, cState, true).toThriftPreparedResult();
}
catch (RequestValidationException e)
{
throw ThriftConversion.toThrift(e);
}
}
开发者ID:mafernandez-stratio,项目名称:cassandra-cqlMod,代码行数:22,代码来源:CassandraServer.java
示例6: prepare_cql_query
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
public CqlPreparedResult prepare_cql_query(ByteBuffer query, Compression compression)
throws InvalidRequestException, TException
{
if (logger.isDebugEnabled())
logger.debug("prepare_cql_query");
validateCQLVersion(2);
String queryString = uncompress(query,compression);
ThriftClientState cState = state();
try
{
cState.validateLogin();
return QueryProcessor.prepare(queryString, cState);
}
catch (RequestValidationException e)
{
throw ThriftConversion.toThrift(e);
}
}
开发者ID:wso2,项目名称:wso2-cassandra,代码行数:22,代码来源:CassandraServer.java
示例7: prepare_cql3_query
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
public CqlPreparedResult prepare_cql3_query(ByteBuffer query, Compression compression)
throws InvalidRequestException, TException
{
if (logger.isDebugEnabled())
logger.debug("prepare_cql3_query");
validateCQLVersion(3);
String queryString = uncompress(query,compression);
ThriftClientState cState = state();
try
{
cState.validateLogin();
return org.apache.cassandra.cql3.QueryProcessor.prepare(queryString, cState, true).toThriftPreparedResult();
}
catch (RequestValidationException e)
{
throw ThriftConversion.toThrift(e);
}
}
开发者ID:wso2,项目名称:wso2-cassandra,代码行数:22,代码来源:CassandraServer.java
示例8: validate
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
private void validate(Collection<RowMutation> tmutations) throws InvalidRequestException
{
for (RowMutation mutation : tmutations)
{
QueryProcessor.validateKey(mutation.key());
for (ColumnFamily tcf : mutation.getColumnFamilies())
for (ByteBuffer tName : tcf.getColumnNames())
QueryProcessor.validateColumn(tcf.metadata(), tName, tcf.getColumn(tName).value());
}
}
开发者ID:pgaref,项目名称:ACaZoo,代码行数:11,代码来源:TriggerExecutor.java
示例9: validate
import org.apache.cassandra.cql.QueryProcessor; //导入依赖的package包/类
private void validate(Collection<Mutation> tmutations) throws InvalidRequestException
{
for (Mutation mutation : tmutations)
{
QueryProcessor.validateKey(mutation.key());
for (ColumnFamily tcf : mutation.getColumnFamilies())
for (CellName tName : tcf.getColumnNames())
QueryProcessor.validateColumn(tcf.metadata(), tName, tcf.getColumn(tName).value());
}
}
开发者ID:mafernandez-stratio,项目名称:cassandra-cqlMod,代码行数:11,代码来源:TriggerExecutor.java
注:本文中的org.apache.cassandra.cql.QueryProcessor类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论