accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pdread <>
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,

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. 



View this message in context:
Sent from the Users mailing list archive at

View raw message