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.
