Method process

datastudio/operators/rewriters/split.py:39–45

Split is handled specially - we mark items for expansion. The actual splitting is done in expand_items().

(self, item: DataItem)

            logger.info(f"[{self.name}] Initialized")

    def process(self, item: DataItem) -> Result:
        """
        Split is handled specially - we mark items for expansion.

        The actual splitting is done in expand_items().
        """
        return Result(item_idx=item.idx)

    def process_batch(self, items: List[DataItem]) -> List[Result]:
        """Process batch - returns keep result for each item."""