大鹏的个人空间 - OSCHINA - 中文开源技术交流社区

九州暮云

欢迎关注：大鹏的架构之路。每天进步一点点，专注Java与大数据技术分享。

772

经验值

627

开源豆

136

粉丝

关注

关注私信

专长领域： 服务器端开发, 软件开发管理

开发平台： Java EE, Scala, Linux/Unix

连击天

fork: star:

加载中

kafka-connect-hive sink插件实现了以ORC和Parquet两种方式向Hive表中写入数据。Connector定期从Kafka轮询数据并将其写入HDFS，来自每个Kafka主题的数据由提供的分区字段进行分区并划分为块，...

hdfs kafka connect hive orc noop parquet 数据存储 sink flush exists topic long offset task with

大数据

2019/02/25 11:46

4.9K

kafka-connect-hive是基于kafka-connect平台实现的hive数据读取和写入插件，主要由source、sink两部分组成，source部分完成hive表数据的读取任务，kafka-connect将这些数据写入到其他数据存储...

Apache ORC Hive Kafka

大数据

2019/02/15 17:33

5.7K

在本文中，我们将演示如何在Scala的集合上使用exists函数，该函数适用于Scala的可变（Mutable）和不可变（Immutable）集合。 exists函数接受谓词函数（predicate function），并将使用该函数...

Sequence Scala Element def

scala

2019/02/13 21:25

927

问题在Scala中如何进行数值转换？比如Int类型转换为Long类型，Int类型转换为Double类型等等。解决方案不同于Java中的”强制转换”方法，Scala为所有数值类型提供了to*方法来实现数值类型之...

Scala

scala

2019/02/13 20:40

439

for循环是一种重复控制结构，允许你高效地编写需要执行特定次数的循环。下面的示例以各种形式描述了Scala中的for循环。语法——带范围的for循环（for loop with ranges）在Scala里，最简单...

Scala def

scala

2019/02/13 20:08

654

问题 Scala没有++和--运算符，是否有一些类似的操作符或方法可以替代？解决方案因为val字段是不可变的，它们不能递增或递减，但是声明为var的Int字段是可变的，可以使用Scala的+=和−=方法...

Scala

scala

2019/02/13 17:51

1.5K

没有更多内容

加载失败，请刷新页面

没有更多内容

九州暮云

技能雷达

Gitee 贡献

博客数据统计

OSCHINA 社区

在线工具

攻略

公众号

视频号

问题反馈

九州暮云

渐入佳境

技能雷达

Gitee 贡献

博客数据统计

OSCHINA 社区

在线工具

攻略

公众号

视频号

问题反馈