refactor: Remove reproject node (#1065)

Author: TrevorBergeron

bigframes/core/__init__.py

@@ -394,20 +394,6 @@ def project_window_op(
             output_name,
         )
 
-    def _reproject_to_table(self) -> ArrayValue:
-        """
-        Internal operators that projects the internal representation into a
-        new ibis table expression where each value column is a direct
-        reference to a column in that table expression. Needed after
-        some operations such as window operations that cannot be used
-        recursively in projections.
-        """
-        return ArrayValue(
-            nodes.ReprojectOpNode(
-                child=self.node,
-            )
-        )
-
     def relational_join(
         self,
         other: ArrayValue,

bigframes/core/block_transforms.py

@@ -196,8 +196,7 @@ def interpolate(block: blocks.Block, method: str = "linear") -> blocks.Block:
         else:
             output_column_ids.append(column)
 
-    # Force reproject since used `skip_project_unsafe` perviously
-    block = block.select_columns(output_column_ids)._force_reproject()
+    block = block.select_columns(output_column_ids)
     return block.with_column_labels(original_labels)
 
 

bigframes/core/blocks.py

@@ -2433,15 +2433,6 @@ def join(
             # Always sort mult-index join
             return join_multi_indexed(self, other, how=how, sort=sort)
 
-    def _force_reproject(self) -> Block:
-        """Forces a reprojection of the underlying tables expression. Used to force predicate/order application before subsequent operations."""
-        return Block(
-            self._expr._reproject_to_table(),
-            index_columns=self.index_columns,
-            column_labels=self.column_labels,
-            index_labels=self.index.names,
-        )
-
     def is_monotonic_increasing(
         self, column_id: typing.Union[str, Sequence[str]]
     ) -> bool:

bigframes/core/compile/compiler.py

@@ -335,10 +335,6 @@ def compile_window(self, node: nodes.WindowOpNode, ordered: bool = True):
         )
         return result if ordered else result.to_unordered()
 
-    @_compile_node.register
-    def compile_reproject(self, node: nodes.ReprojectOpNode, ordered: bool = True):
-        return self.compile_node(node.child, ordered)._reproject_to_table()
-
     @_compile_node.register
     def compile_explode(self, node: nodes.ExplodeNode, ordered: bool = True):
         return self.compile_node(node.child, ordered).explode(node.column_ids)

bigframes/core/nodes.py

@@ -931,19 +931,6 @@ def prune(self, used_cols: COLUMN_SET) -> BigFrameNode:
         return self.transform_children(lambda x: x.prune(consumed_ids))
 
 
-# TODO: Remove this op
-@dataclass(frozen=True, eq=False)
-class ReprojectOpNode(UnaryNode):
-    @property
-    def variables_introduced(self) -> int:
-        return 0
-
-    @property
-    def relation_ops_created(self) -> int:
-        # This op is not a real transformation, just a hint to the sql generator
-        return 0
-
-
 @dataclass(frozen=True, eq=False)
 class RandomSampleNode(UnaryNode):
     fraction: float