test_class.declarator: PATH = new Path("an/ignored/file/")
test_class.modifier: private static final
test_class.original_string: private static final Path PATH = new Path("an/ignored/file/");
test_class.type: Path
test_class.var_name: PATH
test_class.file: flink-java/src/test/java/org/apache/flink/api/java/io/PrimitiveInputFormatTest.java
test_class.identifier: PrimitiveInputFormatTest
test_case.body: @Test
  	public void testDoubleInputLinewise() throws IOException {
  		try {
  			final String fileContent = "1.21\n2.23\n";
  			final FileInputSplit split = createInputSplit(fileContent);
  
  			final PrimitiveInputFormat<Double> format = new PrimitiveInputFormat<Double>(PATH, Double.class);
  
  			format.configure(new Configuration());
  			format.open(split);
  
  			Double result = null;
  			result = format.nextRecord(result);
  			assertEquals(Double.valueOf(1.21), result);
  
  			result = format.nextRecord(result);
  			assertEquals(Double.valueOf(2.23), result);
  
  			result = format.nextRecord(result);
  			assertNull(result);
  			assertTrue(format.reachedEnd());
  		}
  		catch (Exception ex) {
  			fail("Test failed due to a " + ex.getClass().getName() + ": " + ex.getMessage());
  		}
  	}
test_case.class_method_signature: PrimitiveInputFormatTest.testDoubleInputLinewise()
test_case.full_signature: @Test public void testDoubleInputLinewise()
test_case.identifier: testDoubleInputLinewise
test_case.invocations: createInputSplit configure open nextRecord assertEquals valueOf nextRecord assertEquals valueOf nextRecord assertNull assertTrue reachedEnd fail getName getClass getMessage
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testDoubleInputLinewise()
focal_class.declarator: serialVersionUID = 1L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = 1L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: primitiveClass
focal_class.modifier: private
focal_class.original_string: private Class<OT> primitiveClass;
focal_class.type: Class<OT>
focal_class.var_name: primitiveClass
focal_class.declarator: CARRIAGE_RETURN = (byte) '\r'
focal_class.modifier: private static final
focal_class.original_string: private static final byte CARRIAGE_RETURN = (byte) '\r';
focal_class.type: byte
focal_class.var_name: CARRIAGE_RETURN
focal_class.declarator: NEW_LINE = (byte) '\n'
focal_class.modifier: private static final
focal_class.original_string: private static final byte NEW_LINE = (byte) '\n';
focal_class.type: byte
focal_class.var_name: NEW_LINE
focal_class.declarator: parser
focal_class.modifier: private transient
focal_class.original_string: private transient FieldParser<OT> parser;
focal_class.type: FieldParser<OT>
focal_class.var_name: parser
focal_class.file: flink-java/src/main/java/org/apache/flink/api/java/io/PrimitiveInputFormat.java
focal_class.identifier: PrimitiveInputFormat
focal_class.class_method_signature: PrimitiveInputFormat.PrimitiveInputFormat(Path filePath, Class<OT> primitiveClass)
focal_class.full_signature: public  PrimitiveInputFormat(Path filePath, Class<OT> primitiveClass)
focal_class.identifier: PrimitiveInputFormat
focal_class.modifiers: public
focal_class.parameters: (Path filePath, Class<OT> primitiveClass)
focal_class.signature:  PrimitiveInputFormat(Path filePath, Class<OT> primitiveClass)
focal_class.class_method_signature: PrimitiveInputFormat.PrimitiveInputFormat(Path filePath, String delimiter, Class<OT> primitiveClass)
focal_class.full_signature: public  PrimitiveInputFormat(Path filePath, String delimiter, Class<OT> primitiveClass)
focal_class.identifier: PrimitiveInputFormat
focal_class.modifiers: public
focal_class.parameters: (Path filePath, String delimiter, Class<OT> primitiveClass)
focal_class.signature:  PrimitiveInputFormat(Path filePath, String delimiter, Class<OT> primitiveClass)
focal_class.class_method_signature: PrimitiveInputFormat.open(FileInputSplit split)
focal_class.full_signature: @Override public void open(FileInputSplit split)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (FileInputSplit split)
focal_class.return: void
focal_class.signature: void open(FileInputSplit split)
focal_class.class_method_signature: PrimitiveInputFormat.readRecord(OT reuse, byte[] bytes, int offset, int numBytes)
focal_class.full_signature: @Override public OT readRecord(OT reuse, byte[] bytes, int offset, int numBytes)
focal_class.identifier: readRecord
focal_class.modifiers: @Override public
focal_class.parameters: (OT reuse, byte[] bytes, int offset, int numBytes)
focal_class.return: OT
focal_class.signature: OT readRecord(OT reuse, byte[] bytes, int offset, int numBytes)
focal_class.superclass: extends DelimitedInputFormat<OT>
focal_method.body: @Override
  	public void open(FileInputSplit split) throws IOException {
  		super.open(split);
  		Class<? extends FieldParser<OT>> parserType = FieldParser.getParserForType(primitiveClass);
  		if (parserType == null) {
  			throw new IllegalArgumentException("The type '" + primitiveClass.getName() + "' is not supported for the primitive input format.");
  		}
  		parser = InstantiationUtil.instantiate(parserType, FieldParser.class);
  	}
focal_method.class_method_signature: PrimitiveInputFormat.open(FileInputSplit split)
focal_method.full_signature: @Override public void open(FileInputSplit split)
focal_method.identifier: open
focal_method.invocations: open getParserForType getName instantiate
focal_method.modifiers: @Override public
focal_method.parameters: (FileInputSplit split)
focal_method.return: void
focal_method.signature: void open(FileInputSplit split)