Skip to content

Commit 4839a90

Browse files
committed
chore: Fill out planned nodes in impl_arrow
- Mostly ordered by priority/ease to implement - `@singledispatch` matches by **mro**, so the order is here doesn't impact that
1 parent ca1f822 commit 4839a90

File tree

1 file changed

+110
-0
lines changed

1 file changed

+110
-0
lines changed

narwhals/_plan/impl_arrow.py

Lines changed: 110 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,3 +54,113 @@ def lit(
5454
return [t.cast("NativeSeries", ca)]
5555
else:
5656
raise NotImplementedError(type(node.value))
57+
58+
59+
@evaluate.register(expr.Alias)
60+
def alias(node: expr.Alias, frame: NativeFrame) -> Evaluated:
61+
raise NotImplementedError(type(node))
62+
63+
64+
@evaluate.register(expr.Len)
65+
def len_(node: expr.Len, frame: NativeFrame) -> Evaluated:
66+
raise NotImplementedError(type(node))
67+
68+
69+
@evaluate.register(expr.Nth)
70+
def nth(node: expr.Nth, frame: NativeFrame) -> Evaluated:
71+
raise NotImplementedError(type(node))
72+
73+
74+
@evaluate.register(expr.IndexColumns)
75+
def index_columns(node: expr.IndexColumns, frame: NativeFrame) -> Evaluated:
76+
raise NotImplementedError(type(node))
77+
78+
79+
@evaluate.register(expr.All)
80+
def all_(node: expr.All, frame: NativeFrame) -> Evaluated:
81+
raise NotImplementedError(type(node))
82+
83+
84+
@evaluate.register(expr.Exclude)
85+
def exclude(node: expr.Exclude, frame: NativeFrame) -> Evaluated:
86+
raise NotImplementedError(type(node))
87+
88+
89+
@evaluate.register(expr.Cast)
90+
def cast_(node: expr.Cast, frame: NativeFrame) -> Evaluated:
91+
raise NotImplementedError(type(node))
92+
93+
94+
@evaluate.register(expr.Ternary)
95+
def ternary(node: expr.Ternary, frame: NativeFrame) -> Evaluated:
96+
raise NotImplementedError(type(node))
97+
98+
99+
@evaluate.register(expr.Agg)
100+
def agg(node: expr.Agg, frame: NativeFrame) -> Evaluated:
101+
raise NotImplementedError(type(node))
102+
103+
104+
@evaluate.register(expr.OrderableAgg)
105+
def orderable_agg(node: expr.OrderableAgg, frame: NativeFrame) -> Evaluated:
106+
raise NotImplementedError(type(node))
107+
108+
109+
@evaluate.register(expr.BinaryExpr)
110+
def binary_expr(node: expr.BinaryExpr, frame: NativeFrame) -> Evaluated:
111+
raise NotImplementedError(type(node))
112+
113+
114+
@evaluate.register(expr.FunctionExpr)
115+
def function_expr(node: expr.FunctionExpr[t.Any], frame: NativeFrame) -> Evaluated:
116+
raise NotImplementedError(type(node))
117+
118+
119+
@evaluate.register(expr.RollingExpr)
120+
def rolling_expr(node: expr.RollingExpr[t.Any], frame: NativeFrame) -> Evaluated:
121+
raise NotImplementedError(type(node))
122+
123+
124+
@evaluate.register(expr.WindowExpr)
125+
def window_expr(node: expr.WindowExpr, frame: NativeFrame) -> Evaluated:
126+
raise NotImplementedError(type(node))
127+
128+
129+
@evaluate.register(expr.RootSelector)
130+
def selector(node: expr.RootSelector, frame: NativeFrame) -> Evaluated:
131+
raise NotImplementedError(type(node))
132+
133+
134+
@evaluate.register(expr.BinarySelector)
135+
def binary_selector(node: expr.BinarySelector, frame: NativeFrame) -> Evaluated:
136+
raise NotImplementedError(type(node))
137+
138+
139+
@evaluate.register(expr.RenameAlias)
140+
def rename_alias(node: expr.RenameAlias, frame: NativeFrame) -> Evaluated:
141+
raise NotImplementedError(type(node))
142+
143+
144+
@evaluate.register(expr.Sort)
145+
def sort(node: expr.Sort, frame: NativeFrame) -> Evaluated:
146+
raise NotImplementedError(type(node))
147+
148+
149+
@evaluate.register(expr.SortBy)
150+
def sort_by(node: expr.SortBy, frame: NativeFrame) -> Evaluated:
151+
raise NotImplementedError(type(node))
152+
153+
154+
@evaluate.register(expr.Filter)
155+
def filter_(node: expr.Filter, frame: NativeFrame) -> Evaluated:
156+
raise NotImplementedError(type(node))
157+
158+
159+
@evaluate.register(expr.AnonymousExpr)
160+
def anonymous_expr(node: expr.AnonymousExpr, frame: NativeFrame) -> Evaluated:
161+
raise NotImplementedError(type(node))
162+
163+
164+
@evaluate.register(expr.KeepName)
165+
def keep_name(node: expr.KeepName, frame: NativeFrame) -> Evaluated:
166+
raise NotImplementedError(type(node))

0 commit comments

Comments
 (0)