org.apache.streams.riak.test