type: doc layout: reference category: "Introduction"

title: "Kotlin 用于数据科学"

Kotlin 用于数据科学

Kotlin for data science

数据科学在信息技术中具有特殊地位:它同时包含软件开发与科学研究两方面。作为一门学科,数据科学涵盖了广泛的领域:数据工程、 数据分析、机器学习、可视化等等。

为了涵盖所有这些不同领域,软件行业有许多用于数据科学的技术与工具。 其中包含框架、特定的 IDE(称为 notebook)、绘图工具以及专为数据分析与数学研究设计的编程语言。

通用语言也可以应用于数据科学领域,而 Kotlin 已经为数据科学所采用。 在此我们会介绍一些关于将 Kotlin 用于数据科学时的实用知识。

工具

现代软件开发人员很少会在纯文本编辑器中编写代码并在命令行运行。 相反,大家倾向于使用可以在一个工具中处理所有开发任务的集成开发环境(IDE,Integrated Development Environment)。 数据科学家也有类似的工具,称为 notebook。notebook 让用户可以进行研究并将其存储在单个环境中。 在一个 notebook 中,可以在代码旁编写叙述性文本、执行代码块及以任何所需格式(输出文本、表格、数据可视化等等)查看结果。

Kotlin 提供了与两个流行的 notebook 的集成:Jupyter 与 Apache Zeppelin,它们都支持编写及运行 Kotlin 代码块。

Jupyter 内核

开源项目 Jupyter 提供了著名的基于 web 的开发环境 Jupyter Notebook。 对于代码执行,Jupyter 使用内核的概念——独立运行的不同组件,并且这些组件根据请求执行代码, 例如,当在一个 notebook 中点击 Run 时。

Jupyter 团队维护了一个内核——运行 Python 代码的 IPython。 但是,还有其他社区维护的用于不同语言的各种内核。 其中包括用于 Jupyter notbook 的 Kotlin 内核。有了这个内核,就可以在 Jupyter notebook 中编写并运行 Kotlin 代码,以及使用以 Java 或 Kotlin 编写的第三方数据科学框架。

设置 Kotlin 内核

Kotlin 内核需要安装 Java 8。

请使用 Conda 安装该内核:

conda install kotlin-jupyter-kernel -c jetbrains

还有其他安装选项。例如,可以使用 pip 包管理工具或者安装该内核的非稳定版。可在这里获取更多关于安装过程的信息。

一旦内核安装完毕,就可以运行 Jupyter notebook 并切换到 Kotlin 内核。 仅此而已,然后就可以在 notebook 中编写并运行 Kotlin 了!

Kotlin in Jupyter notebook

可以在这里找到关于 Jupyter 的 Kotlin 内核的更多信息。

Zeppelin 解释器

Apache Zeppelin 是一个流行的基于 web 的交互式数据分析解决方案。 Zeppelin 为 Apache Spark 集群计算系统提供了强大的支持,这对于数据工程特别有用。Spark 提供了多种语言的高级 API。

Zeppelin 中的语言支持由解释器提供,解释器是让用户能够使用指定语言或者数据处理后端的插件。 对于不同的编程语言有许多社区维护的解释器。 我们提供了增加 Kotlin 支持的用于 Apache Zeppelin 的 Kotlin 解释器

设置带 Kotlin 解释器的 Zeppelin

目前,最新版本的 Zeppelin(0.8.2)并未内置 Kotlin 解释器。 不过,在 Zeppelin 的 master 分支中有。 因此,为了向 Zeppelin 添加 Kotlin 支持,需要从源代码构建自己的版本。

构建 Zeppelin 的定制版需要:

首先,从 Zeppelin 版本库中检出 master 分支:

git clone --depth=1 [email protected]:apache/zeppelin.git

或者

git clone --depth=1 https://github.com/apache/zeppelin.git

使用 Maven 构建 Zeppelin,请切换到 Zeppelin 目录并运行以下命令:

mvn clean package -DskipTests -Pspark-2.4 -Pscala-2.11

然后使用以下命令运行 Zeppelin:

./bin/zeppelin-daemon.sh start

现在可以在 http://localhost:8089 打开 Zeppelin UI 了。

如需了解如何在 Spark 集群中部署带 Kotlin 支持的 Zeppelin,请参见这个说明

相关库

对于软件工程来说,任何领域的重要组成部分都有相关领域框架的可用性。 对于数据科学,包括诸如机器学习、数据分析、可视化等领域。 幸运的是,已经有很多用 Kotlin 编写的数据科学框架。 更完美的是还有更多用 Java 编写的框架,因为可以在 Kotlin 代码中无缝调用 Java 框架。

以下是可能对数据科学有用的库的两个简短列表。

Kotlin 库

  • kotlin-statistics 是一个为探索性统计与生产统计中提供扩展函数的库。它支持基本的数字列表/序列/数组函数(从 sumskewness)、 切片操作符(诸如 countBysimpleRegressionBy)、分箱(binning)操作符、离散 PDF 采样、 朴素贝叶斯分类器、聚类、线性回归等等。

  • kmath 是一个受 NumPy 启发的库。 这个库支持代数结构与运算、类数组结构、数学表达式、直方图、 流运算、commons-mathkoma 的包装等等。

  • krangl 是一个受 R 语言的 dplyr 与 Python 的 pandas 启发的库。这个库提供了采用函数式风格 API 进行数据操作的功能;它还包括过滤、转换、聚合与重塑表格数据的函数。

  • lets-plot 是一个用 Kotlin 编写的统计数据绘图库。 Lets-Plot 是多平台的,不仅可以用于 JVM,还可以用于 JS 与 Python。更多信息请参见下文

  • kravis 是另一个用于表格数据可视化的库,其灵感来自于 Python 的 ggplot

Java 库

因为 Kotlin 提供了与 Java 互操作的头等支持,所以也可以在用于数据科学的 Kotlin 代码中使用 Java 库。 以下是这些库的一些示例:

  • DeepLearning4J——一个 Java 深度学习库

  • ND4J——用于 JVM 的高效矩阵数学库

  • Dex——一个基于 Java 的数据可视化工具

  • Smile——一个全面的机器学习、自然语言处理、线性代数、 图、插值与可视化系统

    • Smile-NLP-kt——以 Kotlin 扩展函数与接口格式重写了 Smile 的自然语言处理部分的 Scala 隐式内容。
  • Apache Commons Math——一个 Java 通用数学、统计与机器学习库

  • OptaPlanner——一个用于优化规划问题的求解器实用程序

  • Charts——一个正在开发中的科学 JavaFX 图表库

  • CoreNLP——一个自然语言处理工具包

  • Apache Mahout——一个回归、聚类与推荐的分布式框架

  • Weka——一组用于数据挖掘任务的机器学习算法

如果这个列表还不能满足需求,可以在 Thomas Nield 的 Kotlin 数据科学资源摘要中找到更多选项。

Lets-Plot for Kotlin

Lets-Plot for KotlinLets-Plot 库的 Kotlin API, Lets-Plot 是一个完全用 Kotlin 编写的开源的统计数据绘图库。Lets-Plot 建立在分层图形的概念上, 该概念首先在 Leland Wilkinson 的著作 The Grammar of Graphics 中描述,后来在 R 语言的 ggplot2 包中实现。

Lets-Plot for Kotlin 与用于 Jupyter notebook 的 Kotlin 内核紧密集成。 安装并启用 Kotlin 内核后,将以下行添加到 Jupyter notebook 中:

%use lets-plot

就是这样,现在就可以调用 Lets-Plot 中的函数并查看结果了。

Lets-Plot diagram

NumPy 的 Kotlin 绑定

KNumpyNumPy 的 Kotlin 绑定)是一个能让 Kotlin 代码调用 NumPy 函数的 Kotlin 库。 NumPy是使用 Python 进行科学计算的一个流行软件包。它为多维数组处理、线性代数、傅立叶变换、随机数以及其他数学任务提供了强大的功能。

KNumpy 为 NumPy 函数提供了静态类型的包装。由于 Kotlin 的函数式能力, KNumpy 的 API 与对应的 NumPy API 非常相似。这让有 NumPy 经验的开发人员可以轻松切换到 KNumpy。 以下是两份等价代码的示例:

# Python

import numpy as np
a = np.arange(15).reshape(3, 5)

print(a.shape == (3, 5))        # True
print(a.ndim == 2)              # True
print(a.dtype.name)             # 'int64'

b = (np.arange(15) ** 2).reshape(3, 5)
// Kotlin 

import org.jetbrains.numkt.*

fun main() {
    val a = arange(15).reshape(3, 5)

    println(a.shape.contentEquals(intArrayOf(3, 5))) // true
    println(a.ndim == 2)                             // true
    println(a.dtype)                                 // class java.lang.Integer

    // 创建一个整型数组,我们将每个元素取平方,然后重塑为 (3, 5)
    val b = (arange(15) `**` 2).reshape(3, 5)
}

与 Python 不同的是,Kotlin 是一种静态类型语言。这样使用 KNumpy 就可以避免运行时的类型错误: Kotlin 编译器会在更早的阶段检测到相应问题。

# Python

import numpy as np

# ...

a = np.ones((3, 3), dtype=int) * 3
b = np.random.random((3, 3))

b *= a # 成功
a *= b # 运行时 TypeError
// Kotlin 

// ……

val a = ones<Int>(3, 3) * 3
val b = Random.random(3, 3)

b *= a // 成功
a *= b // 编译错误: 
// Type mismatch: inferred type is KtNDArray<Double> but KtNDArray<Int> was expected

results matching ""

    No results matching ""