flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [683:692]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		String[] output = new String[row.getArity()];
		for (int i = 0; i < row.getArity(); i++) {
			Object value = row.getField(i);
			Class<?> colType = schema.getTypes().get(i);
			try {
				if (value == null) {
					output[i] = "null";
					continue;
				} else {
					if(colType.equals(String.class)) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [904:913]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		String[] output = new String[row.getArity()];
		for (int i = 0; i < row.getArity(); i++) {
			Object value = row.getField(i);
			Class<?> colType = schema.getTypes().get(i);
			try {
				if (value == null) {
					output[i] = "null";
					continue;
				} else {
					if(colType.equals(String.class)) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -