否 是否忽略回撤消息，默认为false。回撤消息将以null值写入kafka update-mode 否 支持：'append', 'retract'及'upsert'三种写入模式 connector.properties.* 否 配置kafka任意原生属性 示例 create table

查看更多 →

否 是否忽略回撤消息，默认为false。回撤消息将以null值写入kafka update-mode 否 支持：'append', 'retract'及'upsert'三种写入模式 connector.properties.* 否 配置kafka任意原生属性 示例 create table

查看更多 →

时，需配置，如'org.mycompany.MyPartitioner' 。 update-mode 否 支持：'append'、'retract'及'upsert'三种写入模式。 connector.properties.* 否 配置kafka任意原生属性 示例 将kafkaSink的数据输出到Kafka中

查看更多 →

时，需配置，如'org.mycompany.MyPartitioner' 。 update-mode 否 支持：'append'、'retract'及'upsert'三种写入模式。 connector.properties.* 否 配置kafka任意原生属性 示例 将kafkaSink的数据输出到Kafka中

查看更多 →

iValue; acc.count += 1; } // Restract撤回操作，和accumulate操作相反 public void retract(WeightedAvgAccum acc, long iValue) { acc.sum -= iValue; acc.count -=

查看更多 →

iValue; acc.count += 1; } // Restract撤回操作，和accumulate操作相反 public void retract(WeightedAvgAccum acc, long iValue) { acc.sum -= iValue; acc.count -=

查看更多 →

iValue; acc.count += 1; } // Restract撤回操作，和accumulate操作相反 public void retract(WeightedAvgAccum acc, long iValue) { acc.sum -= iValue; acc.count -=

查看更多 →

count += 1; } // Restract撤回操作，和accumulate操作相反 public void retract(WeightedAvgAccum acc, long iValue) { acc.sum -= iValue;

查看更多 →

iValue; acc.count += 1; } // Restract撤回操作，和accumulate操作相反 public void retract(WeightedAvgAccum acc, long iValue) { acc.sum -= iValue; acc.count -=

查看更多 →

iValue; acc.count += 1; } // Restract撤回操作，和accumulate操作相反 public void retract(WeightedAvgAccum acc, long iValue) { acc.sum -= iValue; acc.count -=

查看更多 →

iValue; acc.count += 1; } // Restract撤回操作，和accumulate操作相反 public void retract(WeightedAvgAccum acc, long iValue) { acc.sum -= iValue; acc.count -=

查看更多 →

当data-type设置为“sorted-set”数据类型的默认score。 ignore-retraction 否 false Boolean 是否忽略retract消息。 skip-null-values 否 true Boolean 是否跳过null。如果为false，则设置为字符串"null"。

查看更多 →

当data-type设置为“sorted-set”数据类型的默认score。 ignore-retraction 否 false Boolean 是否忽略retract消息。 skip-null-values 否 true Boolean 是否跳过null。若为false，则设置为字符串"null"。

查看更多 →

当data-type设置为“sorted-set”数据类型的默认score。 ignore-retraction 否 false Boolean 是否忽略retract消息。 skip-null-values 否 true Boolean 是否跳过null。若为false，则设置为字符串"null"。

查看更多 →