flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [382:394]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				List<String> valueList = new ArrayList<String>();
				String[] fields;
				for (Row row : rows) {
					fields = writeFormat(schema, row, timeZone, reserveMs);
					valueList.add("(" + StringUtils.join(fields, ",") + ")");
				}

				StringBuilder sb = new StringBuilder();
				if (caseSensitive) {
					sb.append(insertClause).append("\"").append(targetSchema).append("\"").append(".").append("\"").append(tableName).append("\"").append(" (" + fieldNamesCaseSensitive + " ) values ");
				}
				else {
					sb.append(insertClause).append(targetSchema).append(".").append(tableName).append(" (" + fieldNames + " ) values ");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [407:419]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
				List<String> valueList = new ArrayList<String>();
				String[] fields;
				for (Row row : rows) {
					fields = writeFormat(schema, row, timeZone, reserveMs);
					valueList.add("(" + StringUtils.join(fields, ",") + ")");
				}

				StringBuilder sb = new StringBuilder();
				if (caseSensitive) {
					sb.append(insertClause).append("\"").append(targetSchema).append("\"").append(".").append("\"").append(tableName).append("\"").append(" (" + fieldNamesCaseSensitive + " ) values ");
				}
				else {
					sb.append(insertClause).append(targetSchema).append(".").append(tableName).append(" (" + fieldNames + " ) values ");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -