Поток данных Google: как анализировать большой файл с допустимым массивом JSON из FileIO.ReadableFile

В моем конвейере преобразование FileIO.readMatches() считывает большой файл JSON (около 300-400 МБ) с допустимым массивом JSON и возвращает объект FileIO.ReadableFile для следующего преобразования. Моя задача — прочитать каждый объект JSON из этого массива JSON, добавить новые свойства и вывести в следующее преобразование.

На данный момент мой код для разбора файла JSON выглядит так:

        // file is a FileIO.ReadableFile object 
        InputStream bis = new ByteArrayInputStream(file.readFullyAsBytes());
        // Im using gson library to parse JSON
        JsonReader reader = new JsonReader(new InputStreamReader(bis, "UTF-8"));
        JsonParser jsonParser = new JsonParser();
        reader.beginArray();
        while (reader.hasNext()) {
            JsonObject jsonObject = jsonParser.parse(reader).getAsJsonObject();
            jsonObject.addProperty("Somename", "Somedata");
            // processContext is a ProcessContext object
            processContext.output(jsonObject.toString());
        }
        reader.close();

В этом случае все содержимое файла будет в моей памяти, что дает возможность получить java.lang.OutOfMemoryError. Я ищу решение для чтения по одному всех объектов JSON, не сохраняя весь файл в памяти. Возможным решением является использование метода open() из объекта FileIO.ReadableFile, который возвращает канал ReadableByteChannel, но я не уверен, как использовать этот канал для чтения конкретного объекта JSON из этого канала.

Обновленное решение Это мое обновленное решение, которое считывает файл построчно.

    ReadableByteChannel readableByteChannel = null;
    InputStream inputStream = null;
    BufferedReader bufferedReader = null;
    try {
        // file is a FileIO.ReadableFile 
        readableByteChannel = file.open();
        inputStream = Channels.newInputStream(readableByteChannel);
        bufferedReader = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
        String line;
        while ((line = bufferedReader.readLine()) != null) {
            if (line.length() > 1) {
                // my final output should contain both filename and line
                processContext.output(fileName + file);
            }
        }
    } catch (IOException ex) {
        logger.error("Exception during reading the file: {}", ex);
    } finally {
        IOUtils.closeQuietly(bufferedReader);
        IOUtils.closeQuietly(inputStream);
    }

Я вижу, что это решение не работает с потоком данных, работающим на машине n1-standard-1, выдает исключение java.lang.OutOfMemoryError: GC overhead limit exceeded и правильно работает на машине n1-standard-2.