Searching in flink-streaming-java