Distributed Series 🎉

.coveragerc

@@ -7,8 +7,6 @@ omit =
     # Skip tests
     modin/pandas/test/*
     modin/experimental/pandas/test/*
-    # This is not distributed yet
-    modin/pandas/series.py
     # Plotting is not tested
     modin/pandas/plotting.py
     # Skip Dask until it is fully a part of the testing suite

.travis.yml

@@ -87,6 +87,7 @@ script:
   - if [[ "$MODIN_DF_TEST" == "ONE" ]]; then python -m pytest -n auto --disable-pytest-warnings --cov-config=.coveragerc --cov=modin modin/pandas/test/test_dataframe.py::TestDFPartOne --cov-append; fi
   - if [[ "$MODIN_DF_TEST" == "TWO" ]]; then python -m pytest -n auto --disable-pytest-warnings --cov-config=.coveragerc --cov=modin modin/pandas/test/test_dataframe.py::TestDFPartTwo --cov-append; fi
   - if [[ "$MODIN_DF_TEST" == "ALL" ]]; then python -m pytest -n auto --disable-pytest-warnings --cov-config=.coveragerc --cov=modin modin/pandas/test/test_dataframe.py --cov-append; fi
+  - python -m pytest --disable-pytest-warnings --cov-config=.coveragerc --cov=modin modin/pandas/test/test_series.py --cov-append
   - python -m pytest --disable-pytest-warnings --cov-config=.coveragerc --cov=modin modin/pandas/test/test_concat.py --cov-append
   - python -m pytest --disable-pytest-warnings --cov-config=.coveragerc --cov=modin modin/pandas/test/test_groupby.py --cov-append
   - python -m pytest --disable-pytest-warnings --cov-config=.coveragerc --cov=modin modin/pandas/test/test_reshape.py --cov-append

modin/backends/base/query_compiler.py

@@ -66,10 +66,10 @@ def _set_columns(self, new_columns):
     # END dtypes and indexing abstract methods
 
     # Metadata modification abstract methods
-    def add_prefix(self, prefix):
+    def add_prefix(self, prefix, axis=1):
         raise NotImplementedError("Must be implemented in children classes")
 
-    def add_suffix(self, suffix):
+    def add_suffix(self, suffix, axis=1):
         raise NotImplementedError("Must be implemented in children classes")
 
     # END Metadata modification abstract methods
@@ -200,213 +200,37 @@ def inter_manager_operations(self, other, how_to_join, func):
         """
         raise NotImplementedError("Must be implemented in children classes")
 
-    def add(self, other, **kwargs):
-        """Adds this manager with other object (manager or scalar).
+    def binary_op(self, op, other, **kwargs):
+        """Perform an operation between two objects.
 
+        Note: The list of operations is as follows:
+            - add
+            - eq
+            - floordiv
+            - ge
+            - gt
+            - le
+            - lt
+            - mod
+            - mul
+            - ne
+            - pow
+            - rfloordiv
+            - rmod
+            - rpow
+            - rsub
+            - rtruediv
+            - sub
+            - truediv
+            - __and__
+            - __or__
+            - __xor__
         Args:
-            other: The other object (manager or scalar).
+            op: The operation. See list of operations above
+            other: The object to operate against.
 
         Returns:
-            New DataManager with added data and new index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def div(self, other, **kwargs):
-        """Divides this manager with other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with divided data and new index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def eq(self, other, **kwargs):
-        """Compares equality (==) with other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with compared data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def floordiv(self, other, **kwargs):
-        """Floordivs this manager with other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with floordiv-ed data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def ge(self, other, **kwargs):
-        """Compares this manager >= than other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with compared data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def gt(self, other, **kwargs):
-        """Compares this manager > than other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with compared data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def le(self, other, **kwargs):
-        """Compares this manager < than other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with compared data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def lt(self, other, **kwargs):
-        """Compares this manager <= than other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with compared data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def mod(self, other, **kwargs):
-        """Mods this manager against other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with mod-ed data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def mul(self, other, **kwargs):
-        """Multiplies this manager against other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with multiplied data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def ne(self, other, **kwargs):
-        """Compares this manager != to other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with compared data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def pow(self, other, **kwargs):
-        """Exponential power of this manager to other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with pow-ed data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def rdiv(self, other, **kwargs):
-        """Divides other object (manager or scalar) with this manager.
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with divided data and new index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def rfloordiv(self, other, **kwargs):
-        """Floordivs this manager with other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with floordiv-ed data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def rmod(self, other, **kwargs):
-        """Mods this manager with other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with mod data and index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def rpow(self, other, **kwargs):
-        """Exponential power of other object (manager or scalar) to this manager.
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with pow-ed data and new index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def rsub(self, other, **kwargs):
-        """Subtracts other object (manager or scalar) from this manager.
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with subtracted data and new index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def sub(self, other, **kwargs):
-        """Subtracts this manager from other object (manager or scalar).
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with subtracted data and new index.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
-    def truediv(self, other, **kwargs):
-        """Divides this manager with other object (manager or scalar).
-           Functionally same as div
-
-        Args:
-            other: The other object (manager or scalar).
-
-        Returns:
-            New DataManager with divided data and new index.
+            A new QueryCompiler object.
         """
         raise NotImplementedError("Must be implemented in children classes")
 
@@ -868,17 +692,6 @@ def back(self, n):
     # END head/tail/front/back
 
     # Abstract __getitem__ methods
-    def getitem_single_key(self, key):
-        """Get item for a single target index.
-
-        Args:
-            key: Target index by which to retrieve data.
-
-        Returns:
-            A new Query Compiler.
-        """
-        raise NotImplementedError("Must be implemented in children classes")
-
     def getitem_column_array(self, key):
         """Get column data for target labels.