accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pdread <paul.r...@siginttech.com>
Subject Re: Stream fed accumulo
Date Thu, 10 Apr 2014 12:04:47 GMT

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.

Mime
View raw message