Azure / Azure/azureml-examples

Reading delta table using Dataset type File(Machine learning studio)

Open
#3,028 0 comments 0 reactions 0 assignees View on GitHub
bug
Dominant language
Jupyter Notebook
Stars
2k
Forks
1.7k
Avg merge
18h 18m
Merged PRs (30d)
2

Description

### Operating System

Windows

### Version Information

N/A

### Steps to reproduce

Folder structure:
/
└── my_data
├── _delta_log
├── part-0000-xxx.parquet
└── part-0001-xxx.parquet
Relative path for dataset_name set up in dataset type(from azure ML v1 APIs) file: my_data/*.parquet

from azureml.core import Workspace,Dataset
import pandas as pd
ws = Workspace.from_config()
dataset = Dataset.get_by_name(ws, "Dataset_name")
downloaded_parquets = dataset.download()
df_list = list()
for file in downloaded_parquets:
df_list.append(pd.read_parquet(file, engine='pyarrow'))
df = pd.concat(df_list)
df.head(6)

### Expected behavior

id name
3 USA
1 FR
2 UK
5 SPAIN

### Actual behavior

id name
1 FR
4 INDIA
5 Crude
2 UK
3 USA
5 SPAIN

The actual data it is showing is all the data that was added, doesn't show the most recent version

### Addition information

_No response_
```[tasklist]
### Tasks
```

Contributor guide

Open the contributing guide

Research direction

Start by reproducing the Python example with the Azure ML Dataset named in the issue and the my_data/*.parquet path. Inspect how Dataset.download handles the folder's Parquet files and _delta_log; done means the resulting dataframe reflects the most recent table version rather than all added rows.

Written by the indexing model from the issue text.

Assessment

Tech stack
azure, pandas, python
Domain
cloud, data
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.