stream processing, similarity search