infosphere-spl - 如何验证提交时间值？

Question

SPL 支持提交时间值，这些值通过函数调用 getSubmissionTimeValue() 和/或 getSubmissionTimeListValue() 检索。由于 SPL 程序中没有main()函数，我如何在运算符中验证这些值？

Answer 1

在param子句或logic state子句中，通过 SPL 函数分配变量。在 SPL 函数中执行验证。

stream<blob incoming_data, uint32 source_port> DataStream
as UDPReceiver = UDPSource() {
   param
      address : getConfig('exporter'); // IP address or host name

stream<blob incoming_data, uint32 source_port> NextStream
as Parser = Custom(DataStream) {
   logic
      state: {
          MyInfoMap _my_info_map = getInfoAsMap();

上面，SPL 函数 getConfig() 和 getInfoAsMap() 将检索提交时间值并验证它们。