我们有以下流处理需求。 transform(condition check - If (true) then generate MULTIPLE ADDITIONAL messages else just transform the incoming message) ->If condition is true for message B(D,E,F are the additional messages produced)
A,B,C -> A,D,E,F,C ->
我正在处理一个现有的数据库实现(SQL和MySQL)。现在,我需要将一列的数据类型从smallint更改为mediumint。虽然这不是问题,但问题是在实现中处理更新的方式。在每次启动时,程序执行一条简单的MySQL语句(如SELECT xyz FROM 'tablename')来测试是否需要更新。所以我需要一条语句,如果列的数据类型是smallint,它就会抛出一个错误。我只能将一个大于65535的整数写入数据库,但这当然不是一个选项。如果没有这种可能性,并且我确实