이전 다음

Cassandra 데이터 소스에서 검색할 데이터를 지정하는 방법

이 프로시저에서 CQL 조회의 다음 열린 절을 사용하십시오.

importPackage(Packages.java.util);
importPackage(Packages.me.prettyprint.cassandra.serializers);
importPackage(Packages.me.prettyprint.cassandra.service);
importPackage(Packages.me.prettyprint.hector.api);
importPackage(Packages.me.prettyprint.hector.api.beans);
importPackage(Packages.me.prettyprint.hector.api.factory);
importPackage(Packages.me.prettyprint.hector.api.query);
importPackage(Packages.me.prettyprint.cassandra.model);
var cluster = HFactory.getOrCreateCluster("Test Cluster",new CassandraHostConfigurator("192.168.218.246:9160"));
var keyspace = HFactory.createKeyspace("users", cluster);
var cqlQuery = new CqlQuery(keyspace, StringSerializer.get(), StringSerializer.get(), StringSerializer.get());
cqlQuery.setQuery("select * from User");
var resultCQL = cqlQuery.execute();
rowsIterator = resultCQL.get().iterator();

또한 다음의 페치 절도 사용하십시오.

if (rowsIterator.hasNext()) {
var myrow = rowsIterator.next();
var cols = myrow.getColumnSlice().getColumns();
for( ii=0; ii < cols.size(); ii++ ){
row[cols.get(ii).getName()] = cols.get(ii).getValue();
}
return true;
}else{
return false;
}
1  
2  
1  
2  
3  
3  
출력 열에서 추가를 선택하고 데이터 소스에서 검색할 필수 출력 열을 추가하십시오. 그림 2-2에 표시된 대로 각 출력 열에 대해 새 스크립트 데이터 세트 열에서 다음 값을 지정할 수 있습니다.
*
*
*
*
*
*
데이터 세트 열 특성의 지정이 완료되면 확인을 선택하십시오.

그림 2-2 출력 열 추가

그림 2-2  출력 열 추가
그림 2-3에 표시된 대로 지정된 출력 열이 새 데이터 세트에 표시됩니다. 이 예제에서 출력 열은 첫 번째, 마지막 및 수명입니다.

그림 2-3 검색할 출력 열 지정

그림 2-3  검색할 출력 열 지정
4  
5  
1  
그림 2-4에 표시된 대로 스크립트에서 열기를 선택하고 다음과 유사한 CQL 절을 지정하십시오.
importPackage(Packages.java.util);
importPackage(Packages.me.prettyprint.cassandra.serializers);
importPackage(Packages.me.prettyprint.cassandra.service);
importPackage(Packages.me.prettyprint.hector.api);
importPackage(Packages.me.prettyprint.hector.api.beans);
importPackage(Packages.me.prettyprint.hector.api.factory);
importPackage(Packages.me.prettyprint.hector.api.query);
importPackage(Packages.me.prettyprint.cassandra.model);
var cluster = HFactory.getOrCreateCluster("Test Cluster",new CassandraHostConfigurator("192.168.218.246:9160"));
var keyspace = HFactory.createKeyspace("users", cluster);
var cqlQuery = new CqlQuery(keyspace, StringSerializer.get(), StringSerializer.get(), StringSerializer.get());
cqlQuery.setQuery("select * from User");
var resultCQL = cqlQuery.execute();
rowsIterator = resultCQL.get().iterator();

그림 2-4 열린 절 지정

그림 2-4  열린 절 지정
2  
그림 2-5에 표시된 대로 스크립트에서 페치를 선택하고 다음과 유사한 CQL 절을 지정하십시오.
if (rowsIterator.hasNext()) {
var myrow = rowsIterator.next();
var cols = myrow.getColumnSlice().getColumns();
for( ii=0; ii < cols.size(); ii++ ){
row[cols.get(ii).getName()] = cols.get(ii).getValue();
}
return true;
}else{
return false;
}

그림 2-5 페치 절 지정

그림 2-5  페치 절 지정
3  

(c) Copyright Actuate Corporation 2013