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 <[email protected]> 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*
