Skip to content

Commit 9d7dda2

Browse files
committed
Revert changes that will end up coming in via PR apache#782
1 parent dd5e111 commit 9d7dda2

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

python/datafusion/substrait.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ def serialize(sql: str, ctx: SessionContext, path: str | pathlib.Path) -> None:
8181
ctx: SessionContext to use.
8282
path: Path to write the Substrait plan to.
8383
"""
84-
return substrait_internal.Serde.serialize(sql, ctx.ctx, str(path))
84+
return substrait_internal.serde.serialize(sql, ctx.ctx, str(path))
8585

8686
@staticmethod
8787
def serialize_to_plan(sql: str, ctx: SessionContext) -> Plan:
@@ -94,7 +94,7 @@ def serialize_to_plan(sql: str, ctx: SessionContext) -> Plan:
9494
Returns:
9595
Substrait plan.
9696
"""
97-
return Plan(substrait_internal.Serde.serialize_to_plan(sql, ctx.ctx))
97+
return Plan(substrait_internal.serde.serialize_to_plan(sql, ctx.ctx))
9898

9999
@staticmethod
100100
def serialize_bytes(sql: str, ctx: SessionContext) -> bytes:
@@ -107,7 +107,7 @@ def serialize_bytes(sql: str, ctx: SessionContext) -> bytes:
107107
Returns:
108108
Substrait plan as bytes.
109109
"""
110-
return substrait_internal.Serde.serialize_bytes(sql, ctx.ctx)
110+
return substrait_internal.serde.serialize_bytes(sql, ctx.ctx)
111111

112112
@staticmethod
113113
def deserialize(path: str | pathlib.Path) -> Plan:
@@ -119,7 +119,7 @@ def deserialize(path: str | pathlib.Path) -> Plan:
119119
Returns:
120120
Substrait plan.
121121
"""
122-
return Plan(substrait_internal.Serde.deserialize(str(path)))
122+
return Plan(substrait_internal.serde.deserialize(str(path)))
123123

124124
@staticmethod
125125
def deserialize_bytes(proto_bytes: bytes) -> Plan:
@@ -131,7 +131,7 @@ def deserialize_bytes(proto_bytes: bytes) -> Plan:
131131
Returns:
132132
Substrait plan.
133133
"""
134-
return Plan(substrait_internal.Serde.deserialize_bytes(proto_bytes))
134+
return Plan(substrait_internal.serde.deserialize_bytes(proto_bytes))
135135

136136

137137
@deprecated("Use `Serde` instead.")
@@ -156,7 +156,7 @@ def to_substrait_plan(logical_plan: LogicalPlan, ctx: SessionContext) -> Plan:
156156
Substrait plan.
157157
"""
158158
return Plan(
159-
substrait_internal.Producer.to_substrait_plan(logical_plan, ctx.ctx)
159+
substrait_internal.producer.to_substrait_plan(logical_plan, ctx.ctx)
160160
)
161161

162162

@@ -181,7 +181,7 @@ def from_substrait_plan(ctx: SessionContext, plan: Plan) -> LogicalPlan:
181181
Returns:
182182
LogicalPlan.
183183
"""
184-
return substrait_internal.Consumer.from_substrait_plan(
184+
return substrait_internal.consumer.from_substrait_plan(
185185
ctx.ctx, plan.plan_internal
186186
)
187187

0 commit comments

Comments
 (0)