导入Hive数据 数据集 环境配置 前提条件 操作步骤 步骤 1：在Nebula Graph中创建Schema 步骤 2：使用Spark SQL确认Hive SQL语句 步骤 3：修改配置文件 步骤 4：向Nebula Graph导入数据 步骤 5：（可选）验证数据 步骤 6：（如有）在Nebula Graph中重建索引 导入Hiv...

导入Hive数据 数据集 环境配置 前提条件 操作步骤 步骤 1：在Nebula Graph中创建Schema 步骤 2：使用Spark SQL确认Hive SQL语句 步骤 3：修改配置文件 步骤 4：向Nebula Graph导入数据 步骤 5：（可选）验证数据 步骤 6：（如有）在Nebula Graph中重建索引 导入Hiv...

并行执行 设置并行性 算子级别 运行环境级别 客户级别 系统级别 设置最大并行度 并行执行 本节介绍如何在Flink中配置程序的并行执行。 Flink程序由多个任务（转换/ 算子，数据源和接收器）组成。 任务被分成几个并行实例以供执行，每个并行实例处理任务输入数据的子集。 任务的并行实例数称为 并行性 。 如果要使用 保存点 ...

使用 Docker Compose 快速构建 TiDB 集群 准备环境 快速部署 自定义集群 访问 Spark shell 并加载 TiSpark 使用 Docker Compose 快速构建 TiDB 集群 本文档介绍如何在单机上通过 Docker Compose 快速一键部署一套 TiDB 测试集群。Docker Compose 可以通...

Akka 中文指南 快速入门指南 目录 Akka 中文指南 更轻松地构建强大的反应式、并发和分布式应用程序 Akka 是一个用 Scala 编写的库，用于在 JVM 平台上简化编写具有可容错的、高可伸缩性的 Java 和 Scala 的 Actor 模型应用，其同时提供了Java 和 Scala 的开发接口。Akka 允...

Flink节点 Flink节点 拖动工具栏中的任务节点到画板中，如下图所示： 程序类型：支持JAVA、Scala和Python三种语言 主函数的class：是Flink程序的入口Main Class的全路径 主jar包：是Flink的jar包 部署方式：支持cluster、local三种模式 slot数量：可以设置slot数 taskMana...

正则表达式是用来找出数据中的指定模式（或缺少该模式）的字符串。.r 方法可使任意字符串变成一个正则表达式。 import scala . util . matching . Regex val numberPattern : Regex = "[0-9]" . r numberPattern . findFirstMatch...

Graph API Graph Representation Graph Creation Graph Properties Graph Transformations Graph Mutations Neighborhood Methods Graph Validation Graph API Graph Representation...

Graph API Graph Representation Graph Creation Graph Properties Graph Transformations Graph Mutations Neighborhood Methods Graph Validation Graph API Graph Representation...

Graph API Graph Representation Graph Creation Graph Properties Graph Transformations Graph Mutations Neighborhood Methods Graph Validation Graph API Graph Representation...