README.md

gsonlines

Java library for reading/writing JSON lines data using the gson library under the hood for automatic deserialization/serialization of objects.

Automatically compresses/decompresses when the file name ends with .gz.

Maven

Add the following to your pom.xml:

    <dependency>
      <groupId>com.github.fracpete</groupId>
      <artifactId>gsonlines</artifactId>
      <version>0.0.2</version>
    </dependency>

Examples

Stream

The following example reads one line at a time and writes one line at a time as well:

import com.github.fracpete.gsonlines.StreamReader;
import com.github.fracpete.gsonlines.StreamWriter;

import java.io.File;
import java.util.Map;

public class Stream {

  public static void main(String[] args) throws Exception {
    File fin = new File("/some/where/in.jsonl.gz");
    File fout = new File("/some/where/out.jsonl.gz");
    StreamReader r = new StreamReader(fin);
    StreamWriter w = new StreamWriter(fout);
    while (r.hasNext()) {
      Map m = r.next(Map.class);
      // do something with the data
      w.write(m);
    }
    r.close();
    w.close();
  }
}

Batch

The following example reads all the lines in one go, processes them and then writes them again to another file:

import com.github.fracpete.gsonlines.ArrayReader;
import com.github.fracpete.gsonlines.ArrayWriter;

import java.io.File;
import java.util.Map;

public class Batch {

  public static void main(String[] args) throws Exception {
    File fin = new File("/some/where/in.jsonl");
    ArrayReader r = new ArrayReader(fin);
    Map[] data = r.read(Map.class);
    r.close();
    // do something with the data
    File fout = new File("/some/where/out.jsonl");
    ArrayWriter w = new ArrayWriter(fout);
    w.write(data);
    w.close();
  }
}