Searching in flink-java