fixes

ci/travis_script_plasma.sh

@@ -83,7 +83,9 @@ python_version_tests() {
   # Run Plasma tests
   pushd $TRAVIS_BUILD_DIR/python
     python -m pytest pyarrow/tests/test_plasma.py
-    VALGRIND=1 python -m pytest pyarrow/tests/test_plasma.py
+    if [ $TRAVIS_OS_NAME == "linux" ]; then
+      PLASMA_VALGRIND=1 python -m pytest pyarrow/tests/test_plasma.py
+    fi
   popd
 }
 

python/doc/source/api.rst

@@ -222,7 +222,10 @@ In-Memory Object Store
 .. autosummary::
    :toctree: generated/
 
+   ObjectID
    PlasmaClient
+   PlasmaBuffer
+   MutablePlasmaBufferMutablePlasmaBuffer
 
 .. currentmodule:: pyarrow.parquet
 

python/pyarrow/plasma.pyx

@@ -125,6 +125,9 @@ def make_object_id(object_id):
 
 
 cdef class ObjectID:
+    """
+    An ObjectID represents a string of bytes used to identify Plasma objects.
+    """
 
     cdef:
         CUniqueID data
@@ -147,6 +150,14 @@ cdef class ObjectID:
         return (make_object_id, (self.data.binary(),))
 
     def binary(self):
+        """
+        Return the binary representation of this ObjectID.
+
+        Returns
+        -------
+        bytes
+            Binary representation of the ObjectID.
+        """
         return self.data.binary()
 
 

python/pyarrow/tests/test_plasma.py

@@ -155,7 +155,7 @@ class TestPlasmaClient(object):
     def setup_method(self, test_method):
         # Start Plasma store.
         plasma_store_name, self.p = start_plasma_store(
-            use_valgrind=os.getenv("VALGRIND") == "1")
+            use_valgrind=os.getenv("PLASMA_VALGRIND") == "1")
         # Connect to Plasma.
         self.plasma_client = plasma.PlasmaClient()
         self.plasma_client.connect(plasma_store_name, "", 64)
@@ -167,7 +167,7 @@ class TestPlasmaClient(object):
         # Check that the Plasma store is still alive.
         assert self.p.poll() == None
         # Kill the plasma store process.
-        if os.getenv("VALGRIND") == "1":
+        if os.getenv("PLASMA_VALGRIND") == "1":
             self.p.send_signal(signal.SIGTERM)
             self.p.wait()
             if self.p.returncode != 0: