Skip to content

Commit 19050e2

Browse files
committed
wip: migrate into data.integration
1 parent 653fcb7 commit 19050e2

2 files changed

Lines changed: 6 additions & 3 deletions

File tree

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
from pyarrow import Table
2+
from pandas import DataFrame
3+
4+
5+
def toArrow(df: DataFrame) -> Table:
6+
return Table.from_pandas(df)

integration/davidkhala/data/integration/to/arrow.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,6 @@
11
from pyarrow import Table, BufferOutputStream
22

33

4-
def fromPandas(df: "pandas.DataFrame") -> Table:
5-
return Table.from_pandas(df)
6-
74

85
def bytesFrom(table: Table) -> bytes:
96
from pyarrow.parquet import write_table

0 commit comments

Comments
 (0)