tst/com/amazon/kinesis/streaming/agent/tailing/AbstractParserTest.java [654:668]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        int expectedRecordCount = generator.appendDataToFile(testFile, getTestBytes());
        flow = spy(flow);
        when(flow.getSkipHeaderLines()).thenReturn(skipHeaderLines);
        P parser = buildParser();
        parser = spy(parser);
        TrackedFile file = new TrackedFile(flow, testFile);
        file.open(0);
        assertTrue(parser.switchParsingToFile(file));
        List<R> records = parseAllRecords(parser, null);
        assertEquals(records.size(), expectedRecordCount);
        assertTrue(records.size() > 0);  // SANITYCHECK: Ensure we didn't shoot blanks
        assertSkipHeaderLinesRecordsMatchInputFiles(skipHeaderLines, records, testFile);
    }

    @Test
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tst/com/amazon/kinesis/streaming/agent/tailing/AbstractParserTest.java [678:693]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        int expectedRecordCount = generator.appendDataToFile(testFile, getTestBytes());

        flow = spy(flow);
        when(flow.getSkipHeaderLines()).thenReturn(skipHeaderLines);
        P parser = buildParser();
        parser = spy(parser);
        TrackedFile file = new TrackedFile(flow, testFile);
        file.open(0);
        assertTrue(parser.switchParsingToFile(file));
        List<R> records = parseAllRecords(parser, null);
        assertEquals(records.size(), expectedRecordCount);
        assertTrue(records.size() > 0);  // SANITYCHECK: Ensure we didn't shoot blanks
        assertSkipHeaderLinesRecordsMatchInputFiles(skipHeaderLines, records, testFile);
    }

    @Test
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -