accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Gresock <>
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 <> 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:
> Sent from the Users mailing list archive at

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*

View raw message