Oozie Java接口介绍 Java API主要由org.apache.oozie.client.OozieClient提供。 表1 接口介绍 方法 说明 public String run(Properties conf) 运行job public void start(String

查看更多 →

Oozie Java接口介绍 Java API主要由org.apache.oozie.client.OozieClient提供。 表1 接口介绍 方法 说明 public String run(Properties conf) 运行job public void start(String

查看更多 →

Oozie Java接口介绍 Java API主要由org.apache.oozie.client.OozieClient提供。 表1 接口介绍 方法 说明 public String run(Properties conf) 运行job public void start(String

查看更多 →

要添加到表中的表索引 返回类型：viod addIndicesWithData(TableName tablename,TableIndices tableIndices) 参数：TableName 用户想要添加指定索引的表的名称 参数：TableIndices 要添加到表中的表索引

查看更多 →

T> f) 对RDD中的元素调用Function2。 java.util.List<T> collect() 返回包含RDD中所有元素的一个数组。 long count() 返回的是dataset中的element的个数。 T first() 返回的是dataset中的第一个元素。 java

查看更多 →

int numRegions) 创建一个有指定数量region的表，其中第一个region的endKey为参数中的startKey，最后一个region的StartKey为参数中的endKey。如果region的数量过多，该方法可能调用超时。 void createTable(final

查看更多 →

esRequest request) Client通过此接口从RM获取集群中的所有节点信息。 getContainerReport(GetContainerReportRequest request) Client通过此接口从RM获取某个Container的报告信息。 getCo

查看更多 →

数据输出写入到Socket连接中。 hostName为主机名称。 port为端口。 public DataStreamSink<T> writeUsingOutputFormat(OutputFormat<T> format) 数据输出到普通文件中，例如二进制文件。 public

查看更多 →

int numRegions) 创建一个有指定数量region的表，其中第一个region的endKey为参数中的startKey，最后一个region的StartKey为参数中的endKey。如果region的数量过多，该方法可能调用超时。 void createTable(final

查看更多 →

Path getPath() 通过该接口可查看指定HDFS中某个目录下所有文件。 表3 类DFSColocationAdmin常用接口说明 接口 说明 public Map<String, List<DatanodeInfo>> createColocationGroup(String

查看更多 →

onCompletion(RecordMetadata metadata, Exception exception); 回调函数接口方法，通过实现Callback中的此方法来进行异步发送结果的处理。 Consumer重要接口 表3 Consumer重要参数 参数 描述 备注 bootstrap.servers Broker地址列表。

查看更多 →

T> f) 对RDD中的元素调用Function2。 java.util.List<T> collect() 返回包含RDD中所有元素的一个数组。 long count() 返回的是dataset中的element的个数。 T first() 返回的是dataset中的第一个元素。 java

查看更多 →

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

查看更多 →

int numRegions) 创建一个有指定数量region的表，其中第一个region的endKey为参数中的startKey，最后一个region的StartKey为参数中的endKey。如果region的数量过多，该方法可能调用超时。 void createTable(final

查看更多 →

面变慢。 基于API的Glob路径模式以获取LocatedFileStatus和从FileStatus打开文件 在DistributedFileSystem中添加了以下API，以获取具有块位置的FileStatus，并从FileStatus对象打开文件。这些API将减少从客户端到Namenode的RPC调用的数量。

查看更多 →

T> f) 对RDD中的元素调用Function2。 java.util.List<T> collect() 返回包含RDD中所有元素的一个数组。 long count() 返回的是dataset中的element的个数。 T first() 返回的是dataset中的第一个元素。 java

查看更多 →

esRequest request) Client通过此接口从RM获取集群中的所有节点信息。 getContainerReport(GetContainerReportRequest request) Client通过此接口从RM获取某个Container的报告信息。 getCo

查看更多 →

面变慢。 基于API的Glob路径模式以获取LocatedFileStatus和从FileStatus打开文件 在DistributedFileSystem中添加了以下API，以获取具有块位置的FileStatus，并从FileStatus对象打开文件。这些API将减少从客户端到Namenode的RPC调用的数量。

查看更多 →

T> f) 对RDD中的元素调用Function2。 java.util.List<T> collect() 返回包含RDD中所有元素的一个数组。 long count() 返回的是dataset中的element的个数。 T first() 返回的是dataset中的第一个元素。 java

查看更多 →

int numRegions) 创建一个有指定数量region的表，其中第一个region的endKey为参数中的startKey，最后一个region的StartKey为参数中的endKey。如果region的数量过多，该方法可能调用超时。 void createTable(final

查看更多 →

Path getPath() 通过该接口可查看指定HDFS中某个目录下所有文件。 表3 类DFSColocationAdmin常用接口说明 接口 说明 public Map<String, List<DatanodeInfo>> createColocationGroup(String

查看更多 →