public String constructPKFilterKey()

in flink_sink_adbpg_datastream/src/main/java/Adb4PgTableSink.java [791:802]

• 12 lines of code
• 5 McCabe index (conditional complexity)

	public String constructPKFilterKey(Row row) {
		if (null != primaryKeys && !primaryKeys.isEmpty()) {
			String pkFilter = "";
			for (String key : primaryKeys) {
				int index = schema.getFieldIndex(key);
				pkFilter += (null == row.getField(index) ? "null" : row.getField(index));
				pkFilter += "#";
			}
			return pkFilter;
		}
		return null;
	}