Take the last `n` rows of every partition Typically used after `Partitions(..., [-1])` to take the last `n` rows of an entire collection.
| 2689 | |
| 2690 | |
| 2691 | class BlockwiseTail(Tail, Blockwise): |
| 2692 | """Take the last `n` rows of every partition |
| 2693 | |
| 2694 | Typically used after `Partitions(..., [-1])` to take |
| 2695 | the last `n` rows of an entire collection. |
| 2696 | """ |
| 2697 | |
| 2698 | _preserves_partitioning_information = True |
| 2699 | |
| 2700 | def _divisions(self): |
| 2701 | return self.frame.divisions |
| 2702 | |
| 2703 | def _task(self, name: Key, index: int) -> Task: |
| 2704 | return Task(name, M.tail, TaskRef((self.frame._name, index)), self.n) |
| 2705 | |
| 2706 | |
| 2707 | class BlockwiseTailIndex(BlockwiseTail): |