public SpoutOutputCollector getCollector() {
        return collector;
    }
@Test
    public void testSimpleSequenceFile() throws Exception {
        //1) create a couple files to consume
        source = new Path("/tmp/hdfsspout/source");
        fs.mkdirs(source);
        archive = new Path("/tmp/hdfsspout/archive");
        fs.mkdirs(archive);

        Path file1 = new Path(source + "/file1.seq");
        createSeqFile(fs, file1, 5);

        Path file2 = new Path(source + "/file2.seq");
        createSeqFile(fs, file2, 5);

        try (AutoCloseableHdfsSpout closeableSpout = makeSpout(Configs.SEQ, SequenceFileReader.defaultFields)) {
            HdfsSpout spout = closeableSpout.spout;
            Map<String, Object> conf = getCommonConfigs();
            openSpout(spout, 0, conf);

            // consume both files
            List<String> res = runSpout(spout, "r11");
            assertEquals(10, res.size());

            assertEquals(2, listDir(archive).size());

            Path f1 = new Path(archive + "/file1.seq");
            Path f2 = new Path(archive + "/file2.seq");

            checkCollectorOutput_seq((MockCollector) spout.getCollector(), f1, f2);
        }
    }