returns the recordreader to clean state . concode_field_sep FileSystem fileSystem concode_elem_sep Sleeper mockSleeper concode_elem_sep Path shardPath concode_elem_sep TaskAttemptContext mockTaskContext concode_elem_sep ShardedInputSplit inputSplit concode_elem_sep long estimatedNumRecords concode_elem_sep String RECORD_1 concode_elem_sep String RECORD_2 concode_elem_sep Path basePath concode_elem_sep JsonParser jsonParser concode_elem_sep ExpectedException expectedException concode_elem_sep String RECORD_0 concode_elem_sep DynamicFileListRecordReader<LongWritable,JsonObject> recordReader concode_elem_sep Configuration config concode_field_sep void testMultipleDataFilesInSingleList concode_elem_sep void testCloseBeforeEnd concode_elem_sep void testBadFilename concode_elem_sep void testSingleDataFile concode_elem_sep DynamicFileListRecordReader<LongWritable,JsonObject> createReader concode_elem_sep void tearDown concode_elem_sep void testEmptyFileIsOnlyFileAndZeroIndex concode_elem_sep void testEmptyFileIndexLessThanOtherFileBadKnownFile concode_elem_sep void testMultipleFilesThenHangBeforeEmptyFileAppears concode_elem_sep void testGetCurrentBeforeFirstRecord concode_elem_sep void testGetProgressZeroEstimatedRecords concode_elem_sep void testThreeBatchesEndFileInMiddleBatch concode_elem_sep void testInitializeCreatesShardDirectory concode_elem_sep void testEmptyFileIsOnlyFileAndNotZeroIndex concode_elem_sep void setUp concode_elem_sep void testEmptyFileIndexLessThanOtherFileBadNewFile concode_elem_sep void testEmptyFileThenDataFile concode_elem_sep void checkNextKeyValueWouldBlock concode_elem_sep void writeFile
void function ( ) { inputSplit = new ShardedInputSplit ( shardPath , estimatedNumRecords ) ; recordReader = createReader ( ) ; recordReader . initialize ( inputSplit , mockTaskContext ) ; recordReader . setSleeper ( mockSleeper ) ; }