Please Suggest

Thanks

Anurag

On = Fri, Mar 25, 2011 at 12:10 AM, Narendra Sharma <narendra.sharma@gmail.com> wrote:

Hope you find followi= ng useful. It uses raw thirft. In case you find difficulty in build and/or = running the code, please reply back.

private Cassandra.Client createClient(String host, int = port) {

=A0=A0 =A0TTransport framedTransport= =3D new TFramedTransport(new TSocket(host, port));
=A0=A0 =A0TProtocol framedProtocol =3D new TBin= aryProtocol(framedTransport);

=A0=A0 =A0Cassandra.Client client = =3D new Cassandra.Client(framedProtocol);
=A0=A0 =A0framedTransport.open();

=A0=A0 =A0client.set_keyspace("= Keyspace");
=A0=A0 = =A0return client;
}

private Mutation getMutation(SuperColumn sc) {

ColumnOrSuperColumn csc = =3D new ColumnOrSuperColumn();

csc.setSuper_column(sc);<= /span>

csc.setSuper_columnIsSet(= true);

Mutation m =3D new Mutati= on();

m.setColumn_or_supercolum= n(csc);

m.setColumn_or_supercolum= nIsSet(true);

return m;
}
=A0=A0 =A0
p= rivate Mutation getMutation(Column c) {

ColumnOrSuperColumn csc = =3D new ColumnOrSuperColumn();

csc.setColumn(c);<= /div>
csc.setColumnIsSet(true);=

Mutation m =3D new Mutati= on();

m.setColumn_or_supercolum= n(csc);

m.setColumn_or_supercolum= nIsSet(true);

return m;
}

private Column createCo= lumn(String name, String value, long time) {
= Column c =3D new Column();

c.setName(name.getBytes()= );

c.setValue(value.getBytes= ());

c.setTimestamp(time);

return c;
}

Cassandra.Client client =3D createClient(host, port);

long timeStamp =3D System.currentTim= eMillis();

//For Standard CF

Column col1 =3D createColumn("n= ame1", "value1", timeStamp);

Column col2 =3D createColumn("name2", "v= alue2", timeStamp);

Map<String, List<Mutation>> mutations =3D n= ew HashMap<String, List<Mutation>>();

List<Mutation> mutation =3D ne= w ArrayList<Mutation>();

mutation.add(getMutation(col1));

mutation.add(getMutation(col2));

mutations.put("StandardCF", mutation= );

Map<ByteBuffer, Map<String, Li= st<Mutation>>> mutationMap =3D new HashMap<ByteBuffer, Map&l= t;String, List<Mutation>>>();

mutationMap.put(ByteBuffer.wrap(getB= ytes("rowkey")), mutations);

client.batch_mutate(mutationMap, CL);

//for Super CF

SuperColumn info =3D new SuperColumn= ();

info.setName("i= nfo");

List<Column> cols =3D new Arra= yList<Column>();

c= ols.add(createColumn("name1", "val1", timeStamp));

cols.add(createColumn("name2&qu= ot;, "val2", timeStamp));

info.setColumns(cols);

Map<String, List<Mutation>> mutations =3D new HashMap<Strin= g, List<Mutation>>();

List<Mutation> mutation =3D ne= w ArrayList<Mutation>();

mutation.add(getMutation(info));

mutations.put("SuperCF", mutation);

Map<ByteBuffer, Map<String,= List<Mutation>>> mutationMap =3D new HashMap<ByteBuffer, Ma= p<String, List<Mutation>>>();

mutationMap.put(ByteBuffer.wrap(getB= ytes("row-key")), mutations);

client.batch_mutate(mutationMap, CL);

Thanks,

Naren

On Thu, = Mar 24, 2011 at 10:01 PM, Anurag Gujral <anurag.gujral@gmail.com= > wrote:

I am in need of sample code(basically cassan= dra client) in java using batch_mutate=A0
If someone has please reply b= ack

Thanks
Anurag

--001485f92c164d9489049f4e5eb7--