Funken Java Strukturierte Streaming -Filter ⇐ Java

[Anonymous]

Ich habe die folgenden Daten unten: < /p>
+-------+----------+------------+---------+---------------------+-----------+
|id |resource id|resource name|event-desc|event-date |ipaddress1 |
+-------+----------+------------+---------+---------------------+-----------+
|2010001|119 |Netopia |logout |+56975-05-07 23:01:37|25:34:21:44|
|2010001|119 |Netopia |login |+56975-05-07 23:01:37|25:34:21:44|
|2010001|119 |Netopia |logout |+56975-05-07 23:01:37|25:34:21:45|
|2010001|119 |Netopia |login |+56975-05-07 23:01:37|25:34:21:45|
|2010001|119 |Netopia |logout |+56975-05-07 23:01:37|25:34:21:44|
|2010001|119 |Netopia |logout |+56975-05-07 23:01:37|25:34:21:46|
+-------+----------+------------+---------+---------------------+-----------+
< /code>
Ich muss mehrere Filter auf denselben Datensatz anwenden und an Kafka übergeben. < /p>
Dataset mainData=df.select( "data.*").filter("data.eventdesc='logout'");
mainData=df.select( "data.*").filter("data.eventdesc='login'");
< /code>
In diesem Fall funktioniert nur der letzte Ausdruck. Irgendwelche Vorschläge, wie ich Daten für beide Bedingungen filtern und an Kafka senden kann?