import com.streametry.json.*;
public class LargeDataProcessing {
public static void main(String[] args) {
JsonReader reader = new JsonReader("input.json");
JsonTransformer transformer = new JsonTransformer()
.filter("$.age > 18")
.map("$.name", new NameMapper());
MultiThreadStreamProcessor processor = new MultiThreadStreamProcessor();
processor.setThreadCount(4);
processor.register(transformer);
processor.process(reader, new OutputWriter("output.txt"));
}
}
class NameMapper implements JsonMapper<String> {
public String map(JsonValue value) {
return "Name: " + value.asString();
}
}
