Searched refs:_get_datapipe (Results 1 – 1 of 1) sorted by relevance
599 def _get_datapipe(self, range=10, dataframe_size=7): member in TestDataFramesPipes612 dp_numbers = self._get_datapipe().map(lambda x: (x[0], x[1], x[1] + 3 * x[0]))625 dp_numbers = self._get_datapipe(range=1000)644 dp_numbers = self._get_datapipe(range=100)