Package s2.flink.table.upsert