Skip to content

Instantly share code, notes, and snippets.

View colin-ho's full-sized avatar

Colin Ho colin-ho

View GitHub Profile
@colin-ho
colin-ho / sashimi.py
Last active April 21, 2025 20:10
Sashimi
https://claude.ai/chat/723087ee-5aac-4028-b4ad-c37f07df145c
@colin-ho
colin-ho / main.py
Created November 7, 2024 23:50
Daft Streaming Engine Demo
import daft
import memray
def daft_in_memory_operation_one_partition(nums: int):
daft.context.set_runner_native()
for _ in range(0, nums):
df = daft.read_parquet("/nyc_taxi_2022/*")
df_filter = daft.sql("select VendorID, sum(total_amount) as total_amount from df group by VendorID")
df_filter.show(100)