@Override
    public boolean ensure(SegmentSchema schema) throws Exception {
        this.reader = new BufferedReader(new InputStreamReader(System.in));
        closed = false;
        return true;
    }
This class does not work properly, only used in tests.
indexr-server/src/main/java/io/indexr/server/rt/fetcher/ConsoleFetcher.java