Как мы обрабатываем два разных потока ввода в onTuple пользовательского() оператора IBM InfoSphere Streams?

Question

В пользовательском операторе я пытаюсь открыть один файл, который был отправлен при запуске, и пометить значения из файла и сравнить значения с входными потоками, которые являются другим файлом.

Answer 1

У вас может быть несколько предложений onTuple в логике вашего пользовательского оператора.

Вот пример. Здесь у нас есть два входных порта Beacon_1_out0 и Beacon_2_out0. Я добавил предложение onTuple для каждого входного порта и выполняю обработку данных, поступающих с каждого входного порта. Обработка каждого порта происходит независимо.

() as Custom_3 = Custom(Beacon_1_out0 ; Beacon_2_out0) 
     { 
      logic 

      onTuple Beacon_1_out0: 
      { 
       printStringLn((rstring)Beacon_1_out0); 
      } 

      onTuple Beacon_2_out0: 
      { 
       printStringLn((rstring)Beacon_1_out0); 
      } 
     } 

Если вы сравниваете данные из нескольких потоков, вы можете использовать оператор Join. Оператор Join должен позволить вам более легко сравнивать данные из нескольких входных потоков.