PLUR (Programming-Language Understanding and Repair) is a collection of source code datasets suitable for graph-based machine learning. We provide scripts for downloading, processing, and loading the datasets. This is done by offering a unified API and data structures for all datasets.
SRC_DIR=${PWD}/src
mkdir -p ${SRC_DIR} && cd ${SRC_DIR}
# For Cubert.
git clone https://github.com/google-research/google-research --depth=1
export PYTHONPATH=${PYTHONPATH}:${SRC_DIR}/google-research
git clone https://github.com/google-research/plur && cd plur
python -m pip install -r requirements.txt
python setup.py install
Test execution on small dataset
cd plur
python3 plur_data_generation.py --dataset_name=manysstubs4j_dataset \
--stage_1_dir=/tmp/manysstubs4j_dataset/stage_1 \
--stage_2_dir=/tmp/manysstubs4j_dataset/stage_2 \
--train_data_percentage=40 \
--validation_data_percentage=30 \
--test_data_percentage=30
Data generation is done by calling plur.plur_data_generation.create_dataset()
.
The data generation runs in two stages:
- Convert raw data to
plur.utils.GraphToOutputExample
. - Convert
plur.utils.GraphToOutputExample
toTFExample
.
Stage 1 is unique for each dataset, but stage 2 is the same for almost all datasets.
from plur.plur_data_generation import create_dataset
dataset_name = 'manysstubs4j_dataset'
dataset_stage_1_directory = '/tmp/manysstubs4j_dataset/stage_1'
stage_1_kwargs = dict()
dataset_stage_2_directory = '/tmp/manysstubs4j_dataset/stage_2'
stage_2_kwargs = dict()
create_dataset(dataset_name, dataset_stage_1_directory, dataset_stage_2_directory, stage_1_kwargs, stage_2_kwargs)
plur_data_generation.py
also provides a command line interface, but it offers less flexibility.
python3 plur_data_generation.py --stage_1_dir=/tmp/manysstubs4j_dataset/stage_1 --stage_2_dir=/tmp/manysstubs4j_dataset/stage_2
After the data is generated, you can use PlurDataLoader
to load the data. The data loader loads TFExample
s but returns them as numpy arrays.
from plur.plur_data_loader import PlurDataLoader
from plur.util import constants
dataset_stage_2_directory = '/tmp/manysstubs4j_dataset/stage_2'
split = constants.TRAIN_SPLIT_NAME
batch_size = 32
repeat_count = -1
drop_remainder = True
train_data_generator = PlurDataLoader(dataset_stage_2_directory, split, batch_size, repeat_count, drop_remainder)
for batch_data in train_data_generator:
# your training loop...
This is where users of the PLUR framework plug in their custom ML models and code to train and generate predictions for PLUR tasks.
We provide the models for GGNN
, Transformer
and GREAT
models from the PLUR
paper. See below for sample commands. For the full set of command line FLAGS,
see plur/model_design/train.py
.
Training
python3 train.py \
--data_dir=/tmp/manysstubs4j_dataset/stage_2 \
--exp_dir=/tmp/experiments/exp12345
Evaluation / Generating predictions
python3 train.py \
--data_dir=/tmp/manysstubs4j_dataset/stage_2 \
--exp_dir=/tmp/experiments/exp12345 \
--evaluate=true
Once the training is finished and you have generated natural text predictions on the test data, you can use plur_evaluator.py
to evaluate the performance. plur_evaluator.py
works in offline mode, meaning that it expects one or more files containing the ground truths, and matching files containing the predictions.
python3 plur_evaluator.py --dataset_name=manysstubs4j_dataset --target_file_pattern=/tmp/manysstubs4j_dataset/targets.txt --prediction_file_pattern=/tmp/manysstubs4j_dataset/predictions.txt
When using multiple evaluation "rounds", the evaluator may create multiple targets and predictions files, formatted as ...predictions-0-of-5.txt
; you can refer to all of these combined using a Glob file pattern such as ...predictions-?-of-5.txt
in the command above.
For more details about how plur_evaluator
works see plur/eval/README.md
.
If there is something fundamental you want to change in the dataset, you should apply them in stage 1 of data generation, otherwise apply them in stage 2. The idea is that stage 1 should only be run once per dataset (to create the plur.utils.GraphToOutputExample
), and stage 2 should be run each time you want to train on different data (to create the TFRecords).
All transformation and filtering functions are applied on plur.utils.GraphToOutputExample
, see plur.utils.GraphToOutputExample
for more information.
E.g. a transformation that can be run in stage 1 is that your model expects that graphs in the dataset have no loop, and you write your transformation function to remove loops. This will ensure that stage 2 will read data where the graph has no loops.
E.g. of filters that can be run in stage 2 is that you want to check your model performance on different graph sizes in terms of number of nodes. You write your own filter function to filter graphs with a large number of nodes.
from plur.plur_data_generation import create_dataset
dataset_name = 'manysstubs4j_dataset'
dataset_stage_1_directory = '/tmp/manysstubs4j_dataset/stage_1'
stage_1_kwargs = dict()
dataset_stage_2_directory = '/tmp/manysstubs4j_dataset/stage_2'
def _filter_graph_size(graph_to_output_example, graph_size=1024):
return len(graph_to_output_example.get_nodes()) <= graph_size
stage_2_kwargs = dict(
train_filter_funcs=(_filter_graph_size,),
validation_filter_funcs=(_filter_graph_size,)
)
create_dataset(dataset_name, dataset_stage_1_directory, dataset_stage_2_directory, stage_1_kwargs, stage_2_kwargs)
plur.plur_data_generation.create_dataset()
is just a thin wrapper around plur.stage_1.plur_dataset
and plur.stage_2.graph_to_output_example_to_tfexample
.
from plur.plur_data_generation import create_dataset
dataset_name = 'manysstubs4j_dataset'
dataset_stage_1_directory = '/tmp/manysstubs4j_dataset/stage_1'
stage_1_kwargs = dict()
dataset_stage_2_directory = '/tmp/manysstubs4j_dataset/stage_2'
stage_2_kwargs = dict()
create_dataset(dataset_name, dataset_stage_1_directory, dataset_stage_2_directory, stage_1_kwargs, stage_2_kwargs)
is equivalent to
from plur.stage_1.manysstubs4j_dataset import ManySStubs4jJDataset
from plur.stage_2.graph_to_output_example_to_tfexample import GraphToOutputExampleToTfexample
dataset_name = 'manysstubs4j_dataset'
dataset_stage_1_directory = '/tmp/manysstubs4j_dataset/stage_1'
dataset_stage_2_directory = '/tmp/manysstubs4j_dataset/stage_2'
dataset = ManySStubs4jJDataset(dataset_stage_1_directory)
dataset.stage_1_mkdirs()
dataset.download_dataset()
dataset.run_pipeline()
dataset = GraphToOutputExampleToTfexample(dataset_stage_1_directory, dataset_stage_2_directory, dataset_name)
dataset.stage_2_mkdirs()
dataset.run_pipeline()
You can check out plur.stage_1.manysstubs4j_dataset
for dataset specific arguments.
from plur.stage_1.manysstubs4j_dataset import ManySStubs4jJDataset
dataset_name = 'manysstubs4j_dataset'
dataset_stage_1_directory = '/tmp/manysstubs4j_dataset/stage_1'
dataset = ManySStubs4jJDataset(dataset_stage_1_directory, dataset_size='large')
dataset.stage_1_mkdirs()
dataset.download_dataset()
dataset.run_pipeline()
All datasets should inherit plur.stage_1.plur_dataset.PlurDataset
, and placed under plur/stage_1/
, which requires you to implement:
download_dataset()
: Code to download the dataset, we providedownload_dataset_using_git()
to download from git anddownload_dataset_using_requests()
to download from a URL, which also works with a Google Drive URL. Indownload_dataset_using_git()
we download the dataset from a specific commit id. Indownload_dataset_using_requests()
we check the sha1sum for the downloaded files. This is to ensure that the same version of PLUR downloads the same raw data.get_all_raw_data_paths()
: It should return a list of paths, where each path is a file containing the raw data in the datasets.raw_data_paths_to_raw_data_do_fn()
: It should return abeam.DoFn
class that overridesprocess()
. Theprocess()
should tell beam how to open the files returned byget_all_raw_data_paths()
. It is also here we define if the data belongs to any split (train/validation/test).raw_data_to_graph_to_output_example()
: This function transforms raw data fromraw_data_paths_to_raw_data_do_fn()
toGraphToOutputExample
.
Then add/change the following lines in plur/plur_data_generation.py
:
from plur.stage_1.foo_dataset import FooDataset
flags.DEFINE_enum(
'dataset_name',
'dummy_dataset',
(
'code2seq_dataset',
'convattn_dataset',
'dummy_dataset',
# [...]
'retrieve_and_edit_dataset',
'foo_dataset',
),
'Name of the dataset to generate data.')
# [...]
def get_dataset_class(dataset_name):
"""Get the dataset class based on dataset_name."""
if dataset_name == 'code2seq_dataset':
return Code2SeqDataset
elif dataset_name == 'convattn_dataset':
return ConvAttnDataset
elif dataset_name == 'dummy_dataset':
return DummyDataset
# [...]
elif dataset_name == 'retrieve_and_edit_dataset':
return RetrieveAndEditDataset
elif dataset_name == 'foo_dataset':
return FooDataset
else:
raise ValueError('{} is not supported.'.format(dataset_name))
The details of how evaluation is performed are in plur/eval/README.md
.
Licensed under the Apache 2.0 License.
This is not an officially supported Google product.
Please cite the PLUR paper, Chen et al. https://proceedings.neurips.cc//paper/2021/hash/c2937f3a1b3a177d2408574da0245a19-Abstract.html