test_class.declarator: jdbcInputFormat
test_class.original_string: JDBCInputFormat jdbcInputFormat;
test_class.type: JDBCInputFormat
test_class.var_name: jdbcInputFormat
test_class.declarator: conn
test_class.modifier: static
test_class.original_string: static Connection conn;
test_class.type: Connection
test_class.var_name: conn
test_class.declarator: dbData = {
  		{1001, ("Java for dummies"), ("Tan Ah Teck"), 11.11, 11},
  		{1002, ("More Java for dummies"), ("Tan Ah Teck"), 22.22, 22},
  		{1003, ("More Java for more dummies"), ("Mohammad Ali"), 33.33, 33},
  		{1004, ("A Cup of Java"), ("Kumar"), 44.44, 44},
  		{1005, ("A Teaspoon of Java"), ("Kevin Jones"), 55.55, 55}}
test_class.modifier: static final
test_class.original_string: static final Object[][] dbData = {
  		{1001, ("Java for dummies"), ("Tan Ah Teck"), 11.11, 11},
  		{1002, ("More Java for dummies"), ("Tan Ah Teck"), 22.22, 22},
  		{1003, ("More Java for more dummies"), ("Mohammad Ali"), 33.33, 33},
  		{1004, ("A Cup of Java"), ("Kumar"), 44.44, 44},
  		{1005, ("A Teaspoon of Java"), ("Kevin Jones"), 55.55, 55}};
test_class.type: Object[][]
test_class.var_name: dbData
test_class.file: flink-batch-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java
test_class.identifier: JDBCInputFormatTest
test_case.body: @Test
  	public void testJDBCInputFormat() throws IOException {
  		jdbcInputFormat = JDBCInputFormat.buildJDBCInputFormat()
  				.setDrivername("org.apache.derby.jdbc.EmbeddedDriver")
  				.setDBUrl("jdbc:derby:memory:ebookshop")
  				.setQuery("select * from books")
  				.setResultSetType(ResultSet.TYPE_SCROLL_INSENSITIVE)
  				.finish();
  		jdbcInputFormat.open(null);
  		Tuple5 tuple = new Tuple5();
  		int recordCount = 0;
  		while (!jdbcInputFormat.reachedEnd()) {
  			jdbcInputFormat.nextRecord(tuple);
  			Assert.assertEquals("Field 0 should be int", Integer.class, tuple.getField(0).getClass());
  			Assert.assertEquals("Field 1 should be String", String.class, tuple.getField(1).getClass());
  			Assert.assertEquals("Field 2 should be String", String.class, tuple.getField(2).getClass());
  			Assert.assertEquals("Field 3 should be float", Double.class, tuple.getField(3).getClass());
  			Assert.assertEquals("Field 4 should be int", Integer.class, tuple.getField(4).getClass());
  
  			for (int x = 0; x < 5; x++) {
  				Assert.assertEquals(dbData[recordCount][x], tuple.getField(x));
  			}
  			recordCount++;
  		}
  		Assert.assertEquals(5, recordCount);
  	}
test_case.class_method_signature: JDBCInputFormatTest.testJDBCInputFormat()
test_case.full_signature: @Test public void testJDBCInputFormat()
test_case.identifier: testJDBCInputFormat
test_case.invocations: finish setResultSetType setQuery setDBUrl setDrivername buildJDBCInputFormat open reachedEnd nextRecord assertEquals getClass getField assertEquals getClass getField assertEquals getClass getField assertEquals getClass getField assertEquals getClass getField assertEquals getField assertEquals
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testJDBCInputFormat()
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: LOG = LoggerFactory.getLogger(JDBCInputFormat.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(JDBCInputFormat.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: username
focal_class.modifier: private
focal_class.original_string: private String username;
focal_class.type: String
focal_class.var_name: username
focal_class.declarator: password
focal_class.modifier: private
focal_class.original_string: private String password;
focal_class.type: String
focal_class.var_name: password
focal_class.declarator: drivername
focal_class.modifier: private
focal_class.original_string: private String drivername;
focal_class.type: String
focal_class.var_name: drivername
focal_class.declarator: dbURL
focal_class.modifier: private
focal_class.original_string: private String dbURL;
focal_class.type: String
focal_class.var_name: dbURL
focal_class.declarator: query
focal_class.modifier: private
focal_class.original_string: private String query;
focal_class.type: String
focal_class.var_name: query
focal_class.declarator: resultSetType
focal_class.modifier: private
focal_class.original_string: private int resultSetType;
focal_class.type: int
focal_class.var_name: resultSetType
focal_class.declarator: resultSetConcurrency
focal_class.modifier: private
focal_class.original_string: private int resultSetConcurrency;
focal_class.type: int
focal_class.var_name: resultSetConcurrency
focal_class.declarator: dbConn
focal_class.modifier: private transient
focal_class.original_string: private transient Connection dbConn;
focal_class.type: Connection
focal_class.var_name: dbConn
focal_class.declarator: statement
focal_class.modifier: private transient
focal_class.original_string: private transient Statement statement;
focal_class.type: Statement
focal_class.var_name: statement
focal_class.declarator: resultSet
focal_class.modifier: private transient
focal_class.original_string: private transient ResultSet resultSet;
focal_class.type: ResultSet
focal_class.var_name: resultSet
focal_class.declarator: columnTypes = null
focal_class.modifier: private
focal_class.original_string: private int[] columnTypes = null;
focal_class.type: int[]
focal_class.var_name: columnTypes
focal_class.file: flink-batch-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
focal_class.identifier: JDBCInputFormat
focal_class.interfaces: implements NonParallelInput
focal_class.class_method_signature: JDBCInputFormat.JDBCInputFormat()
focal_class.full_signature: public  JDBCInputFormat()
focal_class.identifier: JDBCInputFormat
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.signature:  JDBCInputFormat()
focal_class.class_method_signature: JDBCInputFormat.configure(Configuration parameters)
focal_class.full_signature: @Override public void configure(Configuration parameters)
focal_class.identifier: configure
focal_class.modifiers: @Override public
focal_class.parameters: (Configuration parameters)
focal_class.return: void
focal_class.signature: void configure(Configuration parameters)
focal_class.class_method_signature: JDBCInputFormat.open(InputSplit ignored)
focal_class.full_signature: @Override public void open(InputSplit ignored)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (InputSplit ignored)
focal_class.return: void
focal_class.signature: void open(InputSplit ignored)
focal_class.class_method_signature: JDBCInputFormat.establishConnection()
focal_class.full_signature: private void establishConnection()
focal_class.identifier: establishConnection
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void establishConnection()
focal_class.class_method_signature: JDBCInputFormat.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: JDBCInputFormat.reachedEnd()
focal_class.full_signature: @Override public boolean reachedEnd()
focal_class.identifier: reachedEnd
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean reachedEnd()
focal_class.class_method_signature: JDBCInputFormat.nextRecord(OUT tuple)
focal_class.full_signature: @Override public OUT nextRecord(OUT tuple)
focal_class.identifier: nextRecord
focal_class.modifiers: @Override public
focal_class.parameters: (OUT tuple)
focal_class.return: OUT
focal_class.signature: OUT nextRecord(OUT tuple)
focal_class.class_method_signature: JDBCInputFormat.extractTypes(OUT tuple)
focal_class.full_signature: private void extractTypes(OUT tuple)
focal_class.identifier: extractTypes
focal_class.modifiers: private
focal_class.parameters: (OUT tuple)
focal_class.return: void
focal_class.signature: void extractTypes(OUT tuple)
focal_class.class_method_signature: JDBCInputFormat.addValue(OUT reuse)
focal_class.full_signature: private void addValue(OUT reuse)
focal_class.identifier: addValue
focal_class.modifiers: private
focal_class.parameters: (OUT reuse)
focal_class.return: void
focal_class.signature: void addValue(OUT reuse)
focal_class.class_method_signature: JDBCInputFormat.getStatistics(BaseStatistics cachedStatistics)
focal_class.full_signature: @Override public BaseStatistics getStatistics(BaseStatistics cachedStatistics)
focal_class.identifier: getStatistics
focal_class.modifiers: @Override public
focal_class.parameters: (BaseStatistics cachedStatistics)
focal_class.return: BaseStatistics
focal_class.signature: BaseStatistics getStatistics(BaseStatistics cachedStatistics)
focal_class.class_method_signature: JDBCInputFormat.createInputSplits(int minNumSplits)
focal_class.full_signature: @Override public InputSplit[] createInputSplits(int minNumSplits)
focal_class.identifier: createInputSplits
focal_class.modifiers: @Override public
focal_class.parameters: (int minNumSplits)
focal_class.return: InputSplit[]
focal_class.signature: InputSplit[] createInputSplits(int minNumSplits)
focal_class.class_method_signature: JDBCInputFormat.getInputSplitAssigner(InputSplit[] inputSplits)
focal_class.full_signature: @Override public InputSplitAssigner getInputSplitAssigner(InputSplit[] inputSplits)
focal_class.identifier: getInputSplitAssigner
focal_class.modifiers: @Override public
focal_class.parameters: (InputSplit[] inputSplits)
focal_class.return: InputSplitAssigner
focal_class.signature: InputSplitAssigner getInputSplitAssigner(InputSplit[] inputSplits)
focal_class.class_method_signature: JDBCInputFormat.buildJDBCInputFormat()
focal_class.full_signature: public static JDBCInputFormatBuilder buildJDBCInputFormat()
focal_class.identifier: buildJDBCInputFormat
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: JDBCInputFormatBuilder
focal_class.signature: JDBCInputFormatBuilder buildJDBCInputFormat()
focal_class.superclass: extends RichInputFormat<OUT, InputSplit>
focal_method.body: public JDBCInputFormat() {
  	}
focal_method.class_method_signature: JDBCInputFormat.JDBCInputFormat()
focal_method.full_signature: public  JDBCInputFormat()
focal_method.identifier: JDBCInputFormat
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.signature:  JDBCInputFormat()