Searching in java-datastream/google-cloud-datastream