我们的使用是,我们希望使用flink流的去复制作业,它从源读取它的数据(kafka主题),并将独特的记录写入hdfs文件接收器。因此,我决定使用flink键状态流来实现去复制。if (operatorState.value == null) { // we haven't seen the element yet operatorState.update(value._1) }虽然这种
我在一个表中有两个唯一键,我想编写一个查询,将我连接到两个唯一键,并在一条记录中显示它们。目前,查询向我返回2条记录,其中第一条记录中的唯一键= ID,第二条记录中的唯一键= PM。我希望有一个记录唯一键= ID,PMFROM syscat.columns C
JOIN SYSCAT.INDEXES I ON
我需要将一个表和数据(40M)从一个方案复制到另一个方案(prod to test)。然而,有一个唯一的键(不是这个表的PK )叫做record_Id col,它的数据类似于3.000*19E15。大约2M行有相同的数字(我相信这是因为非常大的数字),这在prod中是唯一的。当我试图复制它时,它违背了该列的唯一密钥。我正在使用toad的"export data to another schema“功能来复制数据。如何在不违反表的唯一键的情况下复制所有数据。
提前感谢!