YARN Java API接口介绍 关于YARN的详细API可以直接参考官方网站上的描述： http://hadoop.apache.org/docs/r3.1.1/api/index.html 常用接口 YARN常用的Java类有如下几个。 ApplicationClientProtocol

查看更多 →

slide指的是窗口的滑动时间。 说明： WindowedStream和AllWindowedStream代表不同的两种流。 接口中只有一个参数则是TumblingWindow；有两个或两个以上的参数则是SlidingWindow。 def countWindow(size: Long, slide:

查看更多 →

e形式的JavaRDD类。提供的方法有groupByKey，reduceByKey等。 Broadcast：广播变量类。广播变量允许保留一个只读的变量，缓存在每一台机器上，而非每个任务保存一份复制。 StorageLevel：数据存储级别。有内存（MEMORY_ONLY），磁盘（

查看更多 →

资质提交支持API接口吗？ 消息&短信服务申请资质暂未提供接口，请在短信控制台提交申请，具体操作请参见短信资质管理。 父主题： 资质相关

查看更多 →

使用API接口创建流 前提条件 获取API接口 创建连接器 创建流 运行流 父主题： 进阶能力

查看更多 →

{ "role": "assistant", "content": "你好，有什么我可以帮助你的吗？" }, "finish_reason": "stop",

查看更多 →

Alluxio API接口介绍 Java API Alluxio接口遵循标准的Alluxio Parent API标准，详情请见https://docs.alluxio.io/os/javadoc/2.0/index.html。 HTTP REST API Master REST

查看更多 →

Kafka Java API接口介绍 Kafka相关接口同开源社区保持一致。 Kafka Java API接口介绍可直接参考开源社区。 详情请参见http://kafka.apache.org/documentation.html#api。 父主题： Kafka接口介绍

查看更多 →

常用Oozie API接口介绍 Oozie Shell接口介绍 Oozie Java接口介绍 Oozie REST接口介绍 父主题： Oozie应用开发常见问题

查看更多 →

e形式的JavaRDD类。提供的方法有groupByKey，reduceByKey等。 Broadcast：广播变量类。广播变量允许保留一个只读的变量，缓存在每一台机器上，而非每个任务保存一份复制。 StorageLevel：数据存储级别。有内存（MEMORY_ONLY），磁盘（

查看更多 →

join(other, numPartitions) 当有两个KV的dataset(K,V)和(K,W)，返回的是(K,(V,W))的dataset,numPartitions为并发的任务数。 cogroup(other, numPartitions) 将当有两个key-value对的dataset(K

查看更多 →

YARN Java API接口介绍 关于YARN的详细API可以直接参考官方网站上的描述：http://hadoop.apache.org/docs/r3.1.1/api/index.html 常用接口 YARN常用的Java类有如下几个。 ApplicationClientProtocol

查看更多 →

isSparkContextDown.get() == true 可判断sparkContext已完全stop。 Spark Streaming常用接口 Spark Streaming中常见的类有： StreamingContext：是Spark Streaming功能的主入口，负责提供创建DStreams的方法，入参中需要设置批次的时间间隔。

查看更多 →

HBase常用接口介绍 HBase常用的Java类有以下几个： 接口类Admin，HBase客户端应用的核心类，主要封装了HBase管理类操作的API，例如建表，删表等操作，部分常见接口参见表表1。 接口类Table，HBase读写操作类，主要封装了HBase表的读写操作的API，部分常见接口参见表表2。

查看更多 →

HBase JDBC API接口介绍 Phoenix实现了大部分的java.sql接口，SQL语法紧跟ANSI SQL标准。 其支持处理函数可参见： http://phoenix.apache.org/language/functions.html 其支持语法可参见： http://phoenix

查看更多 →

HBase JDBC API接口介绍 Phoenix实现了大部分的java.sql接口，SQL语法紧跟ANSI SQL标准。 其支持处理函数可参见： http://phoenix.apache.org/language/functions.html 其支持语法可参见： http://phoenix

查看更多 →

HDFS C API接口介绍 功能简介 C语言应用开发代码样例中所涉及的文件操作主要包括创建文件、读写文件、追加文件、删除文件。完整和详细的接口请直接参考官网上的描述以了解其使用方法：http://hadoop.apache.org/docs/r3.1.1/hadoop-proj

查看更多 →

isSparkContextDown.get() == true 可判断sparkContext已完全stop。 Spark Streaming常用接口 Spark Streaming中常见的类有： StreamingContext：是Spark Streaming功能的主入口，负责提供创建DStreams的方法，入参中需要设置批次的时间间隔。

查看更多 →

join(other, numPartitions) 当有两个KV的dataset(K,V)和(K,W)，返回的是(K,(V,W))的dataset,numPartitions为并发的任务数。 cogroup(other, numPartitions) 将当有两个key-value对的dataset(K

查看更多 →

HDFS C API接口介绍 功能简介 C语言应用开发代码样例中所涉及的文件操作主要包括创建文件、读写文件、追加文件、删除文件。完整和详细的接口请直接参考官网上的描述以了解其使用方法： http://hadoop.apache.org/docs/r3.1.1/hadoop-pro

查看更多 →

slide指的是窗口的滑动时间。 说明： WindowedStream和AllWindowedStream代表不同的两种流。 接口中只有一个参数则是TumblingWindow；有两个或两个以上的参数则是SlidingWindow。 def countWindow(size: Long, slide:

查看更多 →