Spark 2.3.0: невозможно найти функцию MapGroupsWithStateFunction - PullRequest
0 голосов
/ 04 июня 2018

Вот снимок зависимости, о которой я упоминал в своем файле 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> 
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...