if (output.response) { response = (BOSPutBucketAclResponse*)output.response; NSLog(@"pub bucket acl success!
目前用户想对存储在 BOS 的 object 内容进行筛选过滤,只能先通过 GetObject 接口下载单个 object ,然后再在本地对数据分析过滤;而 SelectObject 接口将把筛选过滤工作集成到 BOS 服务层,从而减少客户从 BOS 下载数据的网络带宽和延迟,同时也能节省客户筛选数据消耗的 CPU 和内存等资源,从而降低客户访问BOS中数据所需的应用程序成本。
if ( output . response ) { response = ( BOSCopyObjectResponse * ) output . response ; NSLog ( @ copy obj success!
if (output.response) { // 任务执行成功。 } if (output.error) { // 任务执行失败。 } if (output.progress) { // 任务执行进度。 } }); [task waitUtilFinished]; // 可以同步方式,等待任务执行完毕。
if (output.response) { response = (BOSListBucketResponse*)output.response; } if (output.error) { } }); [task waitUtilFinished]; // 获取Owner BOSBucketOwner* owner = response.owner; NSLog(@"the buckets
Flink 使用指南 Flink flink-bos-hadoop 是百度云对象存储系统 BOS 针对 Flink 的文件系统实现,并且支持了 recoverwriter 接口,Flink 可以基于该文件系统实现读写 BOS 上的数据以及作为流应用的状态后端。 安装 1.Flink 环境准备 以 1.15.0 版本为例。
查看统计结果 $ hdfs dfs -ls bos://test-bucket/output/wordcount/ -rw-rw-rw- 1 0 2020 -06-12 16 :55 bos://test-bucket/output/wordcount/_SUCCESS -rw-rw-rw- 1 61 2020 -06-12 16 :55 bos://test-bucket/output/wordcount
查看统计结果 $ hdfs dfs -ls bos://test-bucket/output/wordcount/ -rw-rw-rw- 1 0 2020 -06-12 16 :55 bos://test-bucket/output/wordcount/_SUCCESS -rw-rw-rw- 1 61 2020 -06-12 16 :55 bos://test-bucket/output/wordcount
同上,固定格式,payload内容为空 标志着该次select请求的结束,headers字段包括error-code,error-message,message-type,bytes-scanned等信息 message具体格式详细说明: prelude部分一共8个byte,前4byte表示message总长度,后4byte表示headers部分总长度, chunk总长度(prelude前4byte存储的值
选取JSON文件 Java SDK选取JSON文件请参考以下代码: 20") .withInputSerialization(new InputSerialization() .withCompressionType("NONE") .withJsonType("LINES")) .withOutputSerialization(new OutputSerialization