Searching in sdks/python/apache_beam/examples/inference/online_clustering