phoenix5-flume/src/it/java/org/apache/phoenix/flume/CsvEventSerializerIT.java [396:446]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private void setConfig(final String configName, final String configValue) {
		if (sinkContext == null){
			throw new NullPointerException();
		}
		if (configName == null){
			throw new NullPointerException();
		}
		if (configValue == null){
			throw new NullPointerException();
		}
		sinkContext.put(configName, configValue);
	}

	private int countRows(final String fullTableName) throws SQLException {
		if (fullTableName == null){
			throw new NullPointerException();
		}
		Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
		final Connection conn = DriverManager.getConnection(getUrl(), props);
		ResultSet rs = null;
		try {
			rs = conn.createStatement().executeQuery("select count(*) from " + fullTableName);
			int rowsCount = 0;
			while (rs.next()) {
				rowsCount = rs.getInt(1);
			}
			return rowsCount;

		} finally {
			if (rs != null) {
				rs.close();
			}
			if (conn != null) {
				conn.close();
			}
		}

	}

	private void dropTable(final String fullTableName) throws SQLException {
		if (fullTableName == null){
			throw new NullPointerException();
		}

		Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
		final Connection conn = DriverManager.getConnection(getUrl(), props);
		try {
			conn.createStatement().execute("drop table if exists " + fullTableName);
		} finally {
			if (conn != null) {
				conn.close();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



phoenix5-flume/src/it/java/org/apache/phoenix/flume/JsonEventSerializerIT.java [521:570]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private void setConfig(final String configName, final String configValue) {
		if (sinkContext == null){
			throw new NullPointerException();
		}
		if (configName == null){
			throw new NullPointerException();
		}
		if (configValue == null){
			throw new NullPointerException();
		}
		sinkContext.put(configName, configValue);
	}

	private int countRows(final String fullTableName) throws SQLException {
		if (fullTableName == null){
			throw new NullPointerException();
		}
		Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
		final Connection conn = DriverManager.getConnection(getUrl(), props);
		ResultSet rs = null;
		try {
			rs = conn.createStatement().executeQuery("select count(*) from " + fullTableName);
			int rowsCount = 0;
			while (rs.next()) {
				rowsCount = rs.getInt(1);
			}
			return rowsCount;

		} finally {
			if (rs != null) {
				rs.close();
			}
			if (conn != null) {
				conn.close();
			}
		}

	}

	private void dropTable(final String fullTableName) throws SQLException {
		if (fullTableName == null){
			throw new NullPointerException();
		}
		Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
		final Connection conn = DriverManager.getConnection(getUrl(), props);
		try {
			conn.createStatement().execute("drop table if exists " + fullTableName);
		} finally {
			if (conn != null) {
				conn.close();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -