Skip to content

Laziness in AllenNLP#

By default, a DatasetReader returns instances as a list containing every instance in the dataset. There are several reasons why you might not want this behavior:

  • your dataset is too large to fit into memory
  • you want each iteration through the dataset to do some sort of sampling
  • you want to start training on your data immediately rather than wait for the whole dataset to be processed and indexed. (In this case you'd want to first use the make-vocab command to create your vocabulary so that training really does start immediately.)

In these cases you'll want your DatasetReader to be "lazy"; that is, to create and yield up instances as needed rather than all at once.

This tutorial will show both you how to create DatasetReaders that allow this lazy behavior, and how to handle this laziness when training a model.

You specify laziness in the DatasetReader constructor#

If you look at the constructor for the base DatasetReader class, you can see that it takes a single parameter:

    def __init__(self, lazy: bool = False) -> None:
        self.lazy = lazy

This means that if you want your DatasetReader subclass to allow for laziness, its constructor needs to pass a lazy value to the DatasetReader constructor, and its from_params method needs to allow for such a parameter. All of the dataset readers included with AllenNLP are built this way.

For example, look at the SnliReader.

Its constructor takes a lazy parameter and passes it to the superclass constructor:

    def __init__(self,
                 tokenizer: Tokenizer = None,
                 token_indexers: Dict[str, TokenIndexer] = None,
                 lazy: bool = False) -> None:
        self._tokenizer = tokenizer or SpacyTokenizer()
        self._token_indexers = token_indexers or {'tokens': SingleIdTokenIndexer()}

Any dataset reader that you want to handle lazy datasets should behave likewise.

Laziness in

The primary public interface of the DatasetReader is its read method, which is implemented in the base class (and which I've stripped down to its essence):

    def read(self, file_path: str) -> Iterable[Instance]:
        if self.lazy:
            return _LazyInstances(lambda: iter(self._read(file_path)))
            return ensure_list(self._read(file_path))

In both cases, it calls the private _read method, which you have to implement, and which itself returns an Iterable[Instance]. More on that below.

If the dataset reader was instantiated with lazy=False, it just makes sure that the returned instances are in a list and returns that list. That list is loaded into memory and (because it's a list) can be iterated over repeatedly after the initial call to .read().

The more interesting case is when the dataset reader was instantiated with lazy=True. In that case we return a _LazyInstances initialized with a lambda function that calls _read(). _LazyInstances is just a simple wrapper to produce lazy iterables (again, I stripped it down to just its essence):

class _LazyInstances(Iterable):
    def __init__(self, instance_generator: Callable[[], Iterator[Instance]]) -> None:
        self.instance_generator = instance_generator

    def __iter__(self) -> Iterator[Instance]:
        return self.instance_generator()

What this means is that the result is an iterable that calls the provided function each time it's iterated over. With the lambda we passed it, it will call self._read(file_path) each time it's iterated over.

In other words, if you implement your own dataset reader and do something like the following:

reader = MyDatasetReader(lazy=True)
instances ='my_instances.txt')
for epoch in range(10):
    for instance in instances:

Then each epoch's for instance in instances results in a new call to MyDatasetReader._read(), and your instances will be read from disk 10 times.

Laziness in YourDatasetReader._read()#

When you implement a DatasetReader subclass, you have to override the private method

    def _read(self, file_path: str) -> Iterable[Instance]:

with the logic to generate the all the Instances in your dataset.

Your implementation could return a list, but you should strongly consider implementing _read as a generator that yields one instance at a time; otherwise your dataset reader can't be used in a lazy way. (Indeed, if your _read() implementation returns a list you'll get an error if you try to set lazy=True in your dataset reader.)

This means that you should not do something like

    def _read(self, file_path: str) -> Iterable[Instance]:
        """Don't write your _read function this way"""
        instances = []
        # logic to iterate over file
            # some kind of for loop
            # instance = ...
        return instances

but should instead do

    def _read(self, file_path: str) -> Iterable[Instance]:
        """Do write your _read function this way"""
        # logic to iterate over file
            # some kind of for loop
            # instance = ...
            yield instance

In the lazy=False case, will materialize your instances to a list before returning them anyway.

Laziness in experiment.json#

If you implemented your dataset reader as specified above, laziness just requires adding "lazy": true to your dataset reader config:

  "dataset_reader": {
    "type": "snli",
    "lazy": true,
    "token_indexers": {
      "tokens": {
        "type": "single_id",
        "lowercase_tokens": true

Laziness in DataLoader#

AllenNLP uses the pytorch DataLoader abstraction to iterate over datasets using configurable batching, shuffling, and so on. Currently the DataLoader does not allow the use of custom samplers when using a lazy dataset. However, you can get a good approximation to e.g bucketing by simply sorting by sentence length in your dataset reader, for example.