Вот снимок зависимости, о которой я упоминал в своем файле pom.xml. Однако я не могу найти MapGroupsWithStateFunction.
import org.apache.spark.api.java.function.MapGroupsWithStateFunction;// Он говорит, что это не может быть решено.
Я что-то здесь пропускаю?
<properties>
<spark.core.version>2.3.0</spark.core.version>
<kafka.version>1.1.0</kafka.version>
</properties>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_2.11</artifactId>
<version>${spark.core.version}</version>
</dependency>
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming_2.11</artifactId>
<version>${spark.core.version}</version>
</dependency>