Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (athena.apache.org: domain of jbellis@gmail.com designates
 209.85.212.44 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :content-type:content-transfer-encoding;
        b=wuTcgR3Xn5VvFTDZr9vxgNqgBCiWvueBGXH5Kz1uH4q8JiYTet0wI1rzf6U/1030vu
         lNkA/BYZYZ4rUBUpoU5QkNECRGq84wpR+Mup6n4/qe2ATaa8H8Nf3xIv8c0jHuykkpuY
         GnynfoN4BDm17DuY4A4w/qhc1FX1YY2Imlll8=
MIME-Version: 1.0
In-Reply-To: <AANLkTik4KPJe7oyjzA5AZQpcbC8Z3soOfb9R4_4AVent@mail.gmail.com>
References: <AANLkTik4KPJe7oyjzA5AZQpcbC8Z3soOfb9R4_4AVent@mail.gmail.com>
From: Jonathan Ellis <jbellis@gmail.com>
Date: Tue, 7 Sep 2010 14:54:36 -0500
Message-ID: <AANLkTim6hzJZEOczAfQXCphXY9+ewPnP48NGLvjzu_nT@mail.gmail.com>
Subject: Re: batch_mutate silently failing in Cassandra
To: user@cassandra.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

I would try to get a single hard-coded column to insert, before doing
something more complex.

You can also enable debug logging on the server and see if that
matches what you want the client to be doing.

On Tue, Sep 7, 2010 at 9:11 AM, Lucas Nodine <lucasnodine@gmail.com> wrote:
> Hello all,
>
> I have=A0posted the following to Stackoverflow, but thought that I would =
also
> try the list.=A0 If you have any suggestions, please let me know
>
> I am working with Cassandra 0.6.5 using the thrift interface. I am trying=
 to
> use the batch_mutate method call, however, when I execute it, I receive n=
o
> error message. This leads me to believe it worked. When I check using the
> CLI, there is nothing there. Is there something wrong with my code or for=
mat
> of the mutation_map that anyone can see? Any ideas?
>
> Thanks in advance,
>
> LN
>
> public void Update(string keyspace, Common.NetworkPackage.MetaAsset ma)
> {
> =A0 Dictionary<string, Dictionary<string, List<Mutation>>> package;
> =A0 Dictionary<string, List<Mutation>> packageEntry;
> =A0 Dictionary<string, object>.Enumerator en;
> =A0 List<Mutation> mutList;
> =A0 Mutation mut;
> =A0 DateTime now =3D DateTime.Now;
>
> =A0 if(!ma.Fields.ContainsKey("$guid"))
> =A0 =A0 throw new ArgumentException("The field $guid is not present");
>
> =A0 mutList =3D new List<Mutation>();
> =A0 en =3D ma.Fields.GetEnumerator();
>
> =A0 while(en.MoveNext())
> =A0 {
> =A0 =A0 if (en.Current.Value =3D=3D null)
> =A0 =A0 =A0 continue;
> =A0 =A0 mut =3D new Mutation();
> =A0 =A0 mut.Column_or_supercolumn =3D new ColumnOrSuperColumn();
> =A0 =A0 mut.Column_or_supercolumn.Column =3D new Column();
> =A0 =A0 mut.Column_or_supercolumn.Column.Name =3D _utf8.GetBytes(en.Curre=
nt.Key);
>
> =A0 =A0 if (en.Current.Value =3D=3D null)
> =A0 =A0 =A0 mut.Column_or_supercolumn.Column.Value =3D null;
> =A0 =A0 else
> =A0 =A0 =A0 mut.Column_or_supercolumn.Column.Value =3D ToBytes(en.Current=
.Value);
>
> =A0 =A0 mut.Column_or_supercolumn.Column.Timestamp =3D Utilities.Timestam=
p(now);
>
> =A0 =A0 mutList.Add(mut);
> =A0 }
>
> =A0 packageEntry =3D new Dictionary<string, List<Mutation>>();
> =A0 packageEntry.Add("MetaAsset", mutList);
>
> =A0 package =3D new Dictionary<string, Dictionary<string, List<Mutation>>=
>();
> =A0 package.Add((string)ma.Fields["$guid"], packageEntry);
>
> =A0 Console.WriteLine(Utilities.ExportBulkMutate("LawOffice", package));
>
> =A0 _client.batch_mutate(keyspace, package, ConsistencyLevel.QUORUM);
> }
>
> The above code produces (columns are name:value @ timestamp, value consis=
ts
> of a type:and a representation of the actual value):
>
> LawOffice : {
> =A0Row=3D08469fba50f448be8943614abd059d10 : {
> =A0 =A0CF=3DMetaAsset : {
> =A0 =A0 $guid : String:08469fba50f448be8943614abd059d10 @ 93
> =A0 =A0 $creator : String:Lucas @ 93
> =A0 =A0 $previousversion : String:00000000000000000000000000000000 @ 93
> =A0 =A0 $nextversion : String:00000000000000000000000000000000 @ 93
> =A0 =A0 $etag : String:0 @ 93
> =A0 =A0 $length : Int32:123456789 @ 93
> =A0 =A0 $extension : String:.odt @ 93
> =A0 =A0 $created : DateTime:90 @ 93
> =A0 =A0 $modified : DateTime:90 @ 93
> =A0 =A0 $lastaccess : DateTime:90 @ 93
> =A0 =A0 $title : String:Title @ 93
> =A0 =A0 $tags : List`1:tag1,tag2,tag3 @ 93
> =A0 =A0}
> =A0}
> }
>
>


--=20
Jonathan Ellis
Project Chair, Apache Cassandra
co-founder of Riptano, the source for professional Cassandra support
http://riptano.com