Method count

sdk/python/feast/infra/ray_shared_utils.py:173–181

Execute count remotely and return result.

(self)

        return RemoteDatasetProxy(new_ref)

    def count(self) -> int:
        """Execute count remotely and return result."""

        @ray.remote
        def _remote_count(dataset):
            return dataset.count()

        result_ref = _remote_count.remote(self._dataset_ref)
        return ray.get(result_ref)

    def take(self, n=20) -> list:
        """Execute take remotely and return result."""