accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Gresock <jgres...@gmail.com>
Subject Re: Stream fed accumulo
Date Thu, 10 Apr 2014 12:21:10 GMT
Right, but you can set the byte[] buffer size to as large or small as you
want.  For example, if you use BufferedInputStream, it defaults to an 8K
buffer -- this would be similar.  This was a good solution for us, since
Accumulo doesn't inherently support streaming at the moment.


On Thu, Apr 10, 2014 at 8:04 AM, pdread <paul.read@siginttech.com> wrote:

>
> Your still passing byte[] to your mutations which means your process
> allocated space for that buffer. I was hoping for
>
> public void myPut(Stream mydata. String key, String type)
> {
>   Mutation mutation = new Mutation(generateRowId(key, type));
>   mutation.put(DATA_CF, encoder.encode(sequenceNum), visibility, timestamp,
> mydata);
> }
>
> Then under the covers the accumulo client streams the data to where ever
> the
> data goes. Maybe similar to how one would use the DataHandler in a REST
> service to pass a stream in a REST call.
>
> Thanks
>
> Paul
>
>
>
> --
> View this message in context:
> http://apache-accumulo.1065345.n5.nabble.com/Stream-fed-accumulo-tp8981p8985.html
> Sent from the Users mailing list archive at Nabble.com.
>



-- 
I know what it is to be in need, and I know what it is to have plenty.  I
have learned the secret of being content in any and every situation,
whether well fed or hungry, whether living in plenty or in want.  I can do
all this through him who gives me strength.    *-Philippians 4:12-13*

Mime
View raw message