Anybody in group got into such issues? -Vivek
On Fri, Oct 19, 2012 at 3:28 PM, Vivek Mishra <mishra.v...@gmail.com> wrote: > Ok. I did assume the same, here is what i have tried to fetch composite > columns via thrift and CQL query as well! > > Not sure why thrift API is returning me column name as empty! (Tried with > Cassandra 1.1.5) > > Here is the program: > > > /******************************************************************************* > * * Copyright 2012 Impetus Infotech. > * * > * * Licensed under the Apache License, Version 2.0 (the "License"); > * * you may not use this file except in compliance with the License. > * * You may obtain a copy of the License at > * * > * * http://www.apache.org/licenses/LICENSE-2.0 > * * > * * Unless required by applicable law or agreed to in writing, software > * * distributed under the License is distributed on an "AS IS" BASIS, > * * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or > implied. > * * See the License for the specific language governing permissions and > * * limitations under the License. > > > ******************************************************************************/ > package com.impetus.client.cassandra.thrift; > > import java.nio.ByteBuffer; > import java.util.ArrayList; > import java.util.Iterator; > import java.util.LinkedHashMap; > import java.util.List; > > import org.apache.cassandra.db.marshal.AbstractType; > import org.apache.cassandra.db.marshal.CompositeType; > import org.apache.cassandra.db.marshal.CompositeType.Builder; > import org.apache.cassandra.db.marshal.UTF8Type; > import org.apache.cassandra.locator.SimpleStrategy; > import org.apache.cassandra.thrift.Cassandra; > import org.apache.cassandra.thrift.CfDef; > import org.apache.cassandra.thrift.Column; > import org.apache.cassandra.thrift.ColumnOrSuperColumn; > import org.apache.cassandra.thrift.ColumnParent; > import org.apache.cassandra.thrift.Compression; > import org.apache.cassandra.thrift.ConsistencyLevel; > import org.apache.cassandra.thrift.CqlResult; > import org.apache.cassandra.thrift.CqlRow; > import org.apache.cassandra.thrift.KsDef; > import org.apache.cassandra.thrift.SlicePredicate; > import org.apache.cassandra.thrift.SliceRange; > import org.apache.cassandra.thrift.TBinaryProtocol; > import org.apache.thrift.transport.TFramedTransport; > import org.apache.thrift.transport.TSocket; > import org.scale7.cassandra.pelops.Bytes; > > /** > * @author vivek.mishra > * > */ > public class CompositeTypeRunner > { > public static void main(String[] args) throws Exception { > > TSocket socket = new TSocket("localhost", 9160); > TFramedTransport transport = new TFramedTransport(socket); > > Cassandra.Client client = new Cassandra.Client(new > TBinaryProtocol(transport)); > transport.open(); > client.set_cql_version("3.0.0"); > List<CfDef> cfDefs = new ArrayList<CfDef>(); > > /* CfDef cfDef = new CfDef(); > cfDef.setName("test"); > cfDef.keyspace = "bigdata"; > cfDef.setComparator_type("UTF8Type"); > cfDef.setDefault_validation_class("UTF8Type"); > // cfDef.setKey_validation_class("UTF8Type"); > > cfDefs.add(cfDef);*/ > > > KsDef ksDef = new KsDef("bigdata", SimpleStrategy.class.getName(), > cfDefs); > > if (ksDef.strategy_options == null) > { > ksDef.strategy_options = new LinkedHashMap<String, String>(); > } > > ksDef.strategy_options.put("replication_factor", "1"); > client.system_add_keyspace(ksDef); > client.set_keyspace("bigdata"); > > String cql_Query = "create columnfamily test1 (name text, age > text, address text, PRIMARY KEY(name,age))"; > > client.execute_cql_query(ByteBuffer.wrap(("USE > bigdata").getBytes("UTF-8")) , Compression.NONE); > > > client.execute_cql_query(ByteBuffer.wrap((cql_Query).getBytes("UTF-8")) , > Compression.NONE); > > /*ColumnParent parent = new ColumnParent("test1"); > > List<AbstractType<?>> keyTypes = new ArrayList<AbstractType<?>>(); > keyTypes.add(UTF8Type.instance); > keyTypes.add(UTF8Type.instance); > CompositeType compositeKey = CompositeType.getInstance(keyTypes); > > Builder builder = new Builder(compositeKey); > builder.add(ByteBuffer.wrap("1".getBytes())); > builder.add(ByteBuffer.wrap("2".getBytes())); > ByteBuffer rowid = builder.build(); > > Column column = new Column(); > column.setName("value".getBytes()); > column.setValue("aaa".getBytes()); > column.setTimestamp(System.currentTimeMillis()); > > client.insert(rowid, parent, column, ConsistencyLevel.ONE);*/ > > ColumnParent parent = new ColumnParent("test1"); > > List<AbstractType<?>> keyTypes = new ArrayList<AbstractType<?>>(); > keyTypes.add(UTF8Type.instance); > keyTypes.add(UTF8Type.instance); > CompositeType compositeKey = CompositeType.getInstance(keyTypes); > > Builder builder = new Builder(compositeKey); > builder.add(ByteBuffer.wrap("3".getBytes())); > builder.add(ByteBuffer.wrap("address".getBytes())); > ByteBuffer columnName = builder.build(); > > > Column column = new Column(); > column.setName(columnName); > column.setValue("4".getBytes()); > column.setTimestamp(System.currentTimeMillis()); > > client.insert(ByteBuffer.wrap("1".getBytes()), parent, column, > ConsistencyLevel.ONE); > > > SlicePredicate slicePredicate = new SlicePredicate(); > slicePredicate.setSlice_range(new > SliceRange(Bytes.EMPTY.getBytes(), Bytes.EMPTY.getBytes(), true, 10000)); > List<ColumnOrSuperColumn> columns = > client.get_slice(ByteBuffer.wrap("1".getBytes()), parent, slicePredicate, > ConsistencyLevel.ONE); > > for(ColumnOrSuperColumn col : columns) > { > if(col.column != null) > { > System.out.println(new String(col.getColumn().getName())); > // Printing "EMPTY" String! > System.out.println(new String(col.getColumn().getValue())); > } else if(col.super_column != null) > { > > } else if(col.counter_column != null) > { > > } else if(col.counter_super_column != null) > { > > } > } > > // On cql select query. > > String selectQuery = "Select * from test1"; > CqlResult result = > client.execute_cql_query(ByteBuffer.wrap(selectQuery.getBytes("UTF-8")), > Compression.NONE); > Iterator<CqlRow> rows = result.getRowsIterator(); > while(rows.hasNext()) > { > CqlRow row = rows.next(); > List<Column> cols = row.getColumns(); > for(Column c : cols) > { > System.out.println(new String(c.getName()) + "=>" + new > String(c.getValue())); > > } > } > } > } > > > Why there is a difference with data set return by CQL and via "slice > query"? I know about "interpolation" but wondering what is the best way to > interact with cassandra in near future? > > > -Vivek > > On Thu, Oct 18, 2012 at 4:28 PM, aaron morton <aa...@thelastpickle.com>wrote: > >> Yes, i understand that. Reason why i am asking is, with this i need to >> split >> them to get actual column name using ":" as a seperator. >> >> The ":" is a artefact of the cassandra-cli, nothing something you will >> have to deal with via the thrift API. Internally we do not store the values >> with ":" separators. >> >> Any idiomatic API will take care of parsing the raw wire format, see the >> pycassa example here... >> >> http://pycassa.github.com/pycassa/assorted/composite_types.html >> >> Cheers >> >> ----------------- >> Aaron Morton >> Freelance Developer >> @aaronmorton >> http://www.thelastpickle.com >> >> On 18/10/2012, at 2:58 AM, Sylvain Lebresne <sylv...@datastax.com> wrote: >> >> Yes, i understand that. Reason why i am asking is, with this i need to >> split >> them to get actual column name using ":" as a seperator. >> Though i did not try it yet, but wondering if column name is like >> "alliance:movement", then how do it compute it? >> >> >> You've lost me, sorry. >> >> -- >> Sylvain >> >> >> >> On Wed, Oct 17, 2012 at 1:04 PM, Sylvain Lebresne <sylv...@datastax.com> >> wrote: >> >> >> On Wed, Oct 17, 2012 at 3:17 AM, Vivek Mishra <mishra.v...@gmail.com> >> wrote: >> >> column name will be "2012-07-24:2:alliance_involvement" or >> "alliance_involvement"? >> >> >> The former. Though let's clarify that >> "2012-07-24:2:alliance_involvement" is the string representation of a >> composite name (i.e. one compatible with CompositeType) for display by >> the cli. What you will get is a composite containing 3 components, the >> first will be the string '2012-07-24', the second one will be the int >> 2 and the last one will be the string 'alliance_involvement'. >> >> -- >> Sylvain >> >> >> -Vivek >> >> On Tue, Oct 16, 2012 at 10:25 PM, Sylvain Lebresne >> <sylv...@datastax.com> >> wrote: >> >> >> On Tue, Oct 16, 2012 at 12:31 PM, Vivek Mishra <mishra.v...@gmail.com> >> wrote: >> >> Thanks Sylvain. I missed it. If i try to access these via thrift API, >> what >> will be the column names? >> >> >> I'm not sure I understand the question. The cli output is pretty much >> what you get via the thrift API. >> >> -- >> Sylvain >> >> >> >> >> >> >> >
