This message contains interactive elements.

hi! to give you any pointers I'd need to know what is

Stream

and the generic type used when implementing the CoProcessFuncion in

MatchVulnerableAppCopy

hi @André Midea Jasiskis thanks for your response! this is the case class of the stream let's call it streamCaseClass:

(aId: String, bId: String, appIds: Vector[String])

catalogElement case class:

appId: String, appName: String, appVersion: String, vector: Vector[String]

and this is the generic types of the MatchVulnerableAppCopy:

class MatchVulnerableAppCopy()
  extends KeyedBroadcastProcessFunction[String, streamCaseClass, CatalogElement, (                            
                               String,
                               String,
                               Vector[String],
                               Map[String, Vector[(String, String)]]
)]

if you're calling connect from a keyed stream the process function takes a

KeyedCoProcessFunction

if your catalogBroadcast is actually a BroadcastStream then your function might be right. Hard to tell just from those snippets