Skip to content

Instantly share code, notes, and snippets.

@kvnkho

kvnkho/fugue_partition.py

Created February 11, 2022 06:31
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save kvnkho/1d086d41971fa12bd848928e2cf6c13d to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save kvnkho/1d086d41971fa12bd848928e2cf6c13d to your computer and use it in GitHub Desktop.
Download ZIP
Raw
fugue_partition.py
with FugueWorkflow() as dag:
dag = dag.df(df)
dag.partition_by("col", presort="col2 desc").take(5)
dag.show()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment