gJavaExample 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 sparknormal-examples/SparkStructuredStreamingPythonExample

查看更多 →

使用Kafka客户端创建两个Topic，用于输入Topic和输出Topic。 开发一个Kafka Streams完成单词统计功能，通过读取输入Topic中的消息，统计每条消息中的单词个数，从输出Topic消费数据，将统计结果以Key-Value的形式输出。 创建 MRS 集群 购买一个包含有Kafka组件的MRS集群，详情请参见购买自定义集群。

查看更多 →

登录 内容审核 服务管理控制台。 在左侧导航栏中选择“内容审核 V3>识别统计> 文本审核 ”，可以查看识别统计详情，如图5所示。您可以设置时间范围，策略（事件类型）来观察这段时间内的调用次数变化情况。 图5 识别统计 识别结果统计：显示一段时间范围，内容审核的调用总数，拒绝数，疑似数和通过数，

查看更多 →

配置SparkSQL的分块个数 配置场景 SparkSQL在进行shuffle操作时默认的分块数为200。在数据量特别大的场景下，使用默认的分块数就会造成单个数据块过大。如果一个任务产生的单个shuffle数据块大于2G，该数据块在被fetch的时候还会报类似错误： Adjusted

查看更多 →

Streaming样例程序（Scala） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

2018-10-31 支持配置分词，通过配置分词可将日志内容按照分词符切分为多个单词，在日志搜索时可使用切分后的单词进行搜索。了解详情 2018-10-24 支持创建统计规则，通过统计规则能够周期性统计关键字在日志文件中出现的条数，并生成指标数据。了解详情 2018-9-26 支持日志转储，

查看更多 →

Streaming样例程序（Java） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

Streaming样例程序（Python） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：SecurityKafkaWordCount。 当Streaming

查看更多 →

Streaming样例程序（Java） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

为什么“安全总览”和全量日志统计的日志个数不一致？ 当攻击源、匹配规则、负载位置、URL等信息一致时，全量日志只记录一条日志。因此，全量日志显示的日志个数可能会低于“安全总览”显示的日志个数。 有关查看防护日志的详细操作，请参见查看防护日志。 父主题： 防护日志

查看更多 →

Streaming样例程序（Scala） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

多个数据源编排 一个数据API可以包含多个数据源，因此一次API请求可以涉及多个数据源，例如取第一个数据源查询结果作为第二个数据源的参数。 以MySQL为例说明，假设数据API有数据源1和数据源2，user01是数据源1的数据表和user02是数据源2的数据表，两张表的结构如下：

查看更多 →

导出单个数据库 导出数据库 导出模式 导出表 父主题： 使用gs_dump和gs_dumpall命令导出元数据

查看更多 →

} 下面代码片段在com.huawei.storm.example.wordcount.WordCountBolt类中，作用在于统计收到的每个单词的数量。 @Override public void execute(Tuple tuple, BasicOutputCollector

查看更多 →

下面代码片段在com.huawei.storm.example.wordcount包的“WordCountBolt”类的execute方法中，作用在于统计收到的每个单词的数量。 @Override public void execute(Tuple tuple, BasicOutputCollector

查看更多 →

Scala样例代码 功能介绍 在Spark应用中，通过使用StructuredStreaming调用kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

Streaming样例程序（Python） 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：SecurityKafkaWordCount。 当Streaming

查看更多 →

gJavaExample 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 sparksecurity-examples/SparkStructuredStreamingPythonExample

查看更多 →

数据权限通知数据目录当前模型的样本量接口 获取被调用接口的统计信息 统计数据集订阅量TOP5 父主题： 数据集

查看更多 →

指标统计 为了使您能够全面的了解设备接入情况，您可以在“设备指标统计”中查看相关状态的设备信息。 操作步骤 登录VIS管理控制台。 选择“指标统计”>“设备指标统计”，查询相关状态的设备信息。 如果需要查询某个具体的设备信息时，可以通过搜索具体的设备ID，直接查看该设备相关信息。

查看更多 →

统计答卷结果 操作步骤 以租户管理员角色登录AICC，选择“问卷调查 > 答卷统计”，进入答卷统计页面。 图1 答卷统计 根据查询条件，单击“查询”，查询问卷答卷详情。 单击，支持查询问题选项答题详情。 父主题： 管理问卷

查看更多 →