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.declarator: FIRST_PART = "That is the first part"
test_class.modifier: private static final
test_class.original_string: private static final String FIRST_PART = "That is the first part";
test_class.type: String
test_class.var_name: FIRST_PART
test_class.declarator: SECOND_PART = "That is the second part"
test_class.modifier: private static final
test_class.original_string: private static final String SECOND_PART = "That is the second part";
test_class.type: String
test_class.var_name: SECOND_PART
test_class.file: flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java
test_class.identifier: CsvInputFormatTest
test_case.body: @Test
  	public void testPojoTypeWithInvalidFieldMapping() throws Exception {
  		File tempFile = File.createTempFile("CsvReaderPojoType", "tmp");
  		tempFile.deleteOnExit();
  		tempFile.setWritable(true);
  
  		@SuppressWarnings("unchecked")
  		PojoTypeInfo<PojoItem> typeInfo = (PojoTypeInfo<PojoItem>) TypeExtractor.createTypeInfo(PojoItem.class);
  
  		try {
  			new PojoCsvInputFormat<PojoItem>(new Path(tempFile.toURI().toString()), typeInfo, new String[]{"field1", "field2"});
  			fail("The number of POJO fields cannot be same as that of selected CSV fields");
  		} catch (IllegalArgumentException e) {
  			// success
  		}
  
  		try {
  			new PojoCsvInputFormat<PojoItem>(new Path(tempFile.toURI().toString()), typeInfo, new String[]{"field1", "field2", null, "field4"});
  			fail("Fields mapping cannot contain null.");
  		} catch (NullPointerException e) {
  			// success
  		}
  
  		try {
  			new PojoCsvInputFormat<PojoItem>(new Path(tempFile.toURI().toString()), typeInfo, new String[]{"field1", "field2", "field3", "field5"});
  			fail("Invalid field name");
  		} catch (IllegalArgumentException e) {
  			// success
  		}
  	}
test_case.class_method_signature: CsvInputFormatTest.testPojoTypeWithInvalidFieldMapping()
test_case.full_signature: @Test public void testPojoTypeWithInvalidFieldMapping()
test_case.identifier: testPojoTypeWithInvalidFieldMapping
test_case.invocations: createTempFile deleteOnExit setWritable createTypeInfo toString toURI fail toString toURI fail toString toURI fail
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testPojoTypeWithInvalidFieldMapping()
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: DEFAULT_LINE_DELIMITER = "\n"
focal_class.modifier: public static final
focal_class.original_string: public static final String DEFAULT_LINE_DELIMITER = "\n";
focal_class.type: String
focal_class.var_name: DEFAULT_LINE_DELIMITER
focal_class.declarator: DEFAULT_FIELD_DELIMITER = ","
focal_class.modifier: public static final
focal_class.original_string: public static final String DEFAULT_FIELD_DELIMITER = ",";
focal_class.type: String
focal_class.var_name: DEFAULT_FIELD_DELIMITER
focal_class.declarator: parsedValues
focal_class.modifier: protected transient
focal_class.original_string: protected transient Object[] parsedValues;
focal_class.type: Object[]
focal_class.var_name: parsedValues
focal_class.file: flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java
focal_class.identifier: CsvInputFormat
focal_class.class_method_signature: CsvInputFormat.CsvInputFormat(Path filePath)
focal_class.full_signature: protected  CsvInputFormat(Path filePath)
focal_class.identifier: CsvInputFormat
focal_class.modifiers: protected
focal_class.parameters: (Path filePath)
focal_class.signature:  CsvInputFormat(Path filePath)
focal_class.class_method_signature: CsvInputFormat.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: CsvInputFormat.nextRecord(OUT record)
focal_class.full_signature: @Override public OUT nextRecord(OUT record)
focal_class.identifier: nextRecord
focal_class.modifiers: @Override public
focal_class.parameters: (OUT record)
focal_class.return: OUT
focal_class.signature: OUT nextRecord(OUT record)
focal_class.class_method_signature: CsvInputFormat.readRecord(OUT reuse, byte[] bytes, int offset, int numBytes)
focal_class.full_signature: @Override public OUT readRecord(OUT reuse, byte[] bytes, int offset, int numBytes)
focal_class.identifier: readRecord
focal_class.modifiers: @Override public
focal_class.parameters: (OUT reuse, byte[] bytes, int offset, int numBytes)
focal_class.return: OUT
focal_class.signature: OUT readRecord(OUT reuse, byte[] bytes, int offset, int numBytes)
focal_class.class_method_signature: CsvInputFormat.fillRecord(OUT reuse, Object[] parsedValues)
focal_class.full_signature: protected abstract OUT fillRecord(OUT reuse, Object[] parsedValues)
focal_class.identifier: fillRecord
focal_class.modifiers: protected abstract
focal_class.parameters: (OUT reuse, Object[] parsedValues)
focal_class.return: OUT
focal_class.signature: OUT fillRecord(OUT reuse, Object[] parsedValues)
focal_class.class_method_signature: CsvInputFormat.getFieldTypes()
focal_class.full_signature: public Class<?>[] getFieldTypes()
focal_class.identifier: getFieldTypes
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Class<?>[]
focal_class.signature: Class<?>[] getFieldTypes()
focal_class.class_method_signature: CsvInputFormat.createDefaultMask(int size)
focal_class.full_signature: protected static boolean[] createDefaultMask(int size)
focal_class.identifier: createDefaultMask
focal_class.modifiers: protected static
focal_class.parameters: (int size)
focal_class.return: boolean[]
focal_class.signature: boolean[] createDefaultMask(int size)
focal_class.class_method_signature: CsvInputFormat.toBooleanMask(int[] sourceFieldIndices)
focal_class.full_signature: protected static boolean[] toBooleanMask(int[] sourceFieldIndices)
focal_class.identifier: toBooleanMask
focal_class.modifiers: protected static
focal_class.parameters: (int[] sourceFieldIndices)
focal_class.return: boolean[]
focal_class.signature: boolean[] toBooleanMask(int[] sourceFieldIndices)
focal_class.class_method_signature: CsvInputFormat.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.superclass: extends GenericCsvInputFormat<OUT>
focal_method.body: @Override
  	public String toString() {
  		return "CSV Input (" + StringUtils.showControlCharacters(String.valueOf(getFieldDelimiter())) + ") " + getFilePath();
  	}
focal_method.class_method_signature: CsvInputFormat.toString()
focal_method.full_signature: @Override public String toString()
focal_method.identifier: toString
focal_method.invocations: showControlCharacters valueOf getFieldDelimiter getFilePath
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: String
focal_method.signature: String toString()