Mailing-List: contact user-help@accumulo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@accumulo.apache.org
Received-SPF: pass (nike.apache.org: domain of texpilot@gmail.com designates
 209.85.215.176 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAGUtCHryW3RR9PF5BAD+psxE-dswL9FyOGVv5Mn_Wj00o2mxig@mail.gmail.com>
References: 
 <CAPnhrdszdM44OLKvN79toeXtjVf01JHOwnhOdnPYgLU10C9r+Q@mail.gmail.com>
	<CAMz+Dut_gntdOXzinBEwQphqc7OTNoutSgTVYKfwQ0-p8UGizw@mail.gmail.com>
	<CAPnhrdssnRPB15dxqb17KOuBY++oP-rD2Sw7MqKk4onBdrhRNg@mail.gmail.com>
	<CAGUtCHoeExbzoLurRDDXY+tLYv2SssEhDegVYA+jXuhOjw=jgQ@mail.gmail.com>
	<CAPnhrdsMcX4+e+WZZZ=GXpEVpLZCQBuBDcLNSt=DDw0M6S6dPw@mail.gmail.com>
	<CAGUtCHqAx4Zu1URBMhgTFbqO35bTFgKAVSkV9tE4NK94RUAdBw@mail.gmail.com>
	<CAPnhrdtH60UeHuzs0VjZaSj+9opdZwtgQf4ZgVxwSfr_+4M47g@mail.gmail.com>
	<CAGUtCHryW3RR9PF5BAD+psxE-dswL9FyOGVv5Mn_Wj00o2mxig@mail.gmail.com>
Date: Tue, 12 Nov 2013 11:36:51 -0600
Message-ID: 
 <CAPnhrdtJ3pEPEpXMjHQzudT7_t3=DgzLGfi3V7g=EctDOJ+LpA@mail.gmail.com>
Subject: Re: How to remove entire row at the server side?
From: "Terry P." <texpilot@gmail.com>
To: "user@accumulo.apache.org" <user@accumulo.apache.org>
Content-Type: multipart/alternative; boundary=089e01681c443a0f7104eafe4b76

--089e01681c443a0f7104eafe4b76
Content-Type: text/plain; charset=UTF-8

Keith, you are my hero!  From tests using various column family configs to
test various configs, it appears to be working like a charm.  Now I'm
working on the IteratorOptions part so the expirationTimestamp column
family name and datetime format can be set at the installation time of the
Iterator.

Many, many thanks Keith, your example really helps me understand row-based
iterators much better.

Thanks again to everyone else for your assistance as well.  Accumulo has
such a great community!

Kind regards,
Terry


On Fri, Nov 8, 2013 at 8:49 AM, Keith Turner <keith@deenlo.com> wrote:

>
>
>
> On Fri, Nov 8, 2013 at 12:26 AM, Terry P. <texpilot@gmail.com> wrote:
>
>> Hi Keith,
>> Given that what I need to filter on is only the expTs column family,
>> would it be faster to seek?  I don't know how to seek, but I also can't
>> figure out how to iterate inside the acceptRow method -- there's no scanner
>> as I normally use when reading and iterating over key/values.
>>
>
> I think in your case you should iterate,  because you are only advancing a
> few keys.   Some of the iterators in Accumulo try to iterator for a few
> keys, and if something is not found in 10 keys then seek.
>
> Could do something like the following.
>
>
>   ByteSequence expTsColFam = new ArrayByteSequence("expTs");
>
> @Override
>   public boolean acceptRow(SortedKeyValueIterator<Key, Value>
> rowIterator)  throws IOException {
>        while(rowIterator.hasTop()){
>             //this is faster becaue it compares against byte arrays in key
> directly w/o converting to string
>             int cmp
> = rowIterator.getTopKey().getColumnFamilyData().compareTo(expTsColFam);
>             if (cmp == 0) {
>                  ....
>             }else if(cmp > 0){
>                  //went past column family
>                  //can only do this w/ col fam since it next field in sort
> order after row
>                  break;
>             }
>             rowIterator.next();
>        }
>
>        return true;
>   }
>
>
>>
>>

--089e01681c443a0f7104eafe4b76
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div><div>Keith, you are my hero!=C2=A0 From tests us=
ing various column family configs to test various configs, it appears to be=
 working like a charm.=C2=A0 Now I&#39;m working on the IteratorOptions par=
t so the expirationTimestamp column family name and datetime format can be =
set at the installation time of the Iterator.<br>
<br></div>Many, many thanks Keith, your example really helps me understand =
row-based iterators much better.<br><br></div>Thanks again to everyone else=
 for your assistance as well.=C2=A0 Accumulo has such a great community!<br=
>
<br></div>Kind regards,<br>Terry<br><br><div><div><div><div class=3D"gmail_=
extra"><br><div class=3D"gmail_quote">On Fri, Nov 8, 2013 at 8:49 AM, Keith=
 Turner <span dir=3D"ltr">&lt;<a href=3D"mailto:keith@deenlo.com" target=3D=
"_blank">keith@deenlo.com</a>&gt;</span> wrote:<br>

<blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1p=
x #ccc solid;padding-left:1ex"><div dir=3D"ltr"><br><div class=3D"gmail_ext=
ra"><br><br><div class=3D"gmail_quote"><div>On Fri, Nov 8, 2013 at 12:26 AM=
, Terry P. <span dir=3D"ltr">&lt;<a href=3D"mailto:texpilot@gmail.com" targ=
et=3D"_blank">texpilot@gmail.com</a>&gt;</span> wrote:<br>


</div><blockquote class=3D"gmail_quote" style=3D"margin:0px 0px 0px 0.8ex;b=
order-left-width:1px;border-left-color:rgb(204,204,204);border-left-style:s=
olid;padding-left:1ex"><div dir=3D"ltr"><div>Hi Keith,<br></div><div>
Given that what I need to filter on is only the expTs column family, would =
it be faster to seek?=C2=A0 I don&#39;t know how to seek, but I also can=
9;t figure out how to iterate inside the acceptRow method -- there&#39;s no=
 scanner as I normally use when reading and iterating over key/values.=C2=
=A0 <br>


</div></div></blockquote><div><br></div><div>I think in your case you shoul=
d iterate, =C2=A0because you are only advancing a few keys. =C2=A0 Some of =
the iterators in Accumulo try to iterator for a few keys, and if something =
is not found in 10 keys then seek.</div>


<div><br></div><div>Could do something like the following. =C2=A0</div><div=
><br></div><div><br></div><div>=C2=A0 ByteSequence=C2=A0expTsColFam =3D new=
 ArrayByteSequence(&quot;expTs&quot;);</div><div><div><br></div><div><div>@=
Override</div>


<div>=C2=A0 public boolean acceptRow(SortedKeyValueIterator&lt;Key, Value&g=
t; rowIterator)=C2=A0=C2=A0throws IOException {</div></div></div><div>=C2=
=A0 =C2=A0 =C2=A0 =C2=A0while(rowIterator.hasTop()){</div><div>=C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 //this is faster becaue it compares against=
 byte arrays in key directly w/o converting to string</div>


<div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 int cmp =3D=C2=A0rowIterator=
.getTopKey().getColumnFamilyData().compareTo(expTsColFam);</div><div>=C2=A0=
 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0=C2=A0if (cmp =3D=3D 0) {</div><div>=C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0....</div><div>=
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }else if(cmp &gt; 0){</div>
<div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0//went p=
ast column family</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0//can only do this w/ col fam since it next field in sort =
order after row</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0break;</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }</=
div>
<div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 rowIterator.next();</div><di=
v>=C2=A0 =C2=A0 =C2=A0 =C2=A0}</div><div><br></div><div>=C2=A0 =C2=A0 =C2=
=A0 =C2=A0return true;</div><div><div><div>=C2=A0 }</div><div>=C2=A0</div><=
blockquote class=3D"gmail_quote" style=3D"margin:0px 0px 0px 0.8ex;border-l=
eft-width:1px;border-left-color:rgb(204,204,204);border-left-style:solid;pa=
dding-left:1ex">


<div dir=3D"ltr">
<br></div></blockquote></div></div></div></div></div></blockquote></div><br=
></div></div></div></div></div>

--089e01681c443a0f7104eafe4b76--