Spark访问EMR HBase数据
try { List[]>list=new ArrayList();list.add(Bytes.toBytes("1"));list.add(Bytes.toBytes("5"));JavaRDD[]>rdd=jsc.parallelize(list);Configuration conf=HBaseConfiguration.create();JavaHBaseContext hbaseContext=new ...
设备标签
List,String>>paramsList=new ArrayList,String>>();Map,String>listItemMap=new HashMap,String>();listItemMap.put("attrKey","Temperature");listItemMap.put("attrValue","56.8");paramsList.add(listItemMap);requestModel.params=...
多线程上传示例
import java.util.ArrayList;import java.util.Date;import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import com.aliyun.odps.Column;import ...
超时控制
List<RpcBindingMethodInfo>rpcBindingMethodInfos=new ArrayList();rpcBindingMethodInfos.add(rpcBindingMethodInfo);boltBindingParam.setMethodInfos(rpcBindingMethodInfos);非 Spring 环境 API 方式 如果在非 Spring 环境下使用 ...
视频审核
import java.util.ArrayList;import java.util.Arrays;import java.util.LinkedHashMap;import java.util.List;import java.util.Map;import java.util.UUID;public class Main { public static void main(String[]args)throws Exception {...
多条件组合查询
List<Query>queryList2=new ArrayList();queryList2.add(termQuery);queryList2.add(termsQuery);BoolQuery boolQuery2=new BoolQuery();boolQuery2.setMustQueries(queryList2);总组合条件为(col2)or(col2=4 and(col3=5 or col3=6))。List...
多条件组合查询
List<Query>queryList3=new ArrayList();queryList3.add(boolQuery1);queryList3.add(boolQuery2);BoolQuery boolQuery=new BoolQuery();boolQuery.setShouldQueries(queryList3);searchQuery.setQuery(boolQuery);searchQuery....
作业上线问题
193)at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1374)at java.util.stream.AbstractPipeline.copyInto...
环境接口
multi nodes configuration List< SocketAddress >backupNodes=new ArrayList();backupNodes.add(InetSocketAddress.createUnresolved("101.132.187.0",58321));backupNodes.add(InetSocketAddress.createUnresolved("101.132.46.192",58322)...
开发代码示例
import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;import org.apache.http.HttpResponse;import org.apache.http.client.ClientProtocolException;import org.apache....
更新时间线元数据
private static void updateTimeseriesMeta(TimeseriesClient client){ List<TimeseriesMeta>timeseriesMetaList=new ArrayList();for(int i=0;i;i+){ Map,String>tags=new HashMap,String>();tags.put("region","hangzhou");tags.put("os...
实时导出监控数据
List<Matcher>matchers=new ArrayList();Matcher matcher=new Matcher();matcher.setLabel("userId");matcher.setValue("173651113438*");matcher.setOperator("EQUALS");matchers.add(matcher);cursorRequest.setMatchers(matchers);...
多线程下载示例
import java.util.ArrayList;import java.util.Date;import java.util.List;import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.ExecutorService;import java.util....
系统集群验证签名
List<ApiSecretKey>secretKeys=new ArrayList();secretKeys.add(apiSecretKey);filter.setApiSecretKeys(secretKeys);filter.setCheckSign(true);filter.setSignUriRegex("/j");开启验签加签的uri路径，表示对/j 开头的路径做加签验签，...
删除文件
List<DeleteVersionsRequest.KeyVersion>keyVersionsList=new ArrayList();keyVersionsList.add(new DeleteVersionsRequest.KeyVersion(objectName,yourObjectNameVersionId));keyVersionsList.add(new DeleteVersionsRequest.KeyVersion...
跨域设置
ArrayList<SetBucketCORSRequest.CORSRule>putCorsRules=new ArrayList();SetBucketCORSRequest.CORSRule corRule=new SetBucketCORSRequest.CORSRule();ArrayList<String>allowedOrigin=new ArrayList();指定允许跨域请求的来源。...
Java SDK使用手册
} public void putEventsSample(){ List<CloudEvent>cloudEventList=new ArrayList();cloudEventList.add(EventBuilder.builder().withId("a5074581-7e74-4e4c-868f-47e7afdf*").withSource(URI.create("acs.oss")).withType("oss:...
并发测试示例代码
ArrayList<Thread>threads=new ArrayList();for(int i=0;i;i){ Thread thread=new Thread(new Runnable(){ public void run(){ try { CloudQueue queue=client.getQueueRef(queueName);Message message=new Message();message....
Kudu
Set up a simple schema.List<ColumnSchema>columns=new ArrayList(3);columns.add(new ColumnSchema.ColumnSchemaBuilder("user_id",Type.INT32).key(true).build());columns.add(new ColumnSchema.ColumnSchemaBuilder("first_name",Type...
UDF示例：兼容Hive
}@Override public Object evaluate(DeferredObject[]deferredObjects)throws HiveException { List<Object>objectList=new ArrayList(deferredObjects.length);for(DeferredObject deferredObject:deferredObjects){ objectList.add...
样例代码
本文介绍如何快速使用EMR Java SDK完成常见操作，例如创建集群、创建作业和扩缩容节点组等。前提条件 请确保代码运行环境设置了环境变量ALIBABA_CLOUD_ACCESS_KEY_ID和ALIBABA_CLOUD_ACCESS_KEY_SECRET。具体配置方法，请参见 配置方案。...
协同消费
import java.util.ArrayList;import java.util.List;import org.slf4j.Logger;import org.slf4j.LoggerFactory;public class SimpleProducer { private static final Logger LOGGER=LoggerFactory.getLogger(SimpleProducer.class);public ...
操作表
List<ColumnSchema>columnSchemas=new ArrayList();columnSchemas.add(new ColumnSchema.ColumnSchemaBuilder("ID",Type.INT32).key(true).build());columnSchemas.add(new ColumnSchema.ColumnSchemaBuilder("score",Type.INT32).nullable...
模型应用
import java.util.ArrayList;import java.util.Arrays;import java.util.Collections;import java.util.List;public class ApplicationClientTest {/*官方模型调用应用、自训练模型应用示例*/public void testModelCompletions(){ String ...
按钮组
使用场景 当您需要一组按钮时，您可以选择使用 按钮组 组件。使用说明 基本属性 显示形态：支持 按钮型 和 链接型。最多显示个数：直接显示的按钮数量，超过的被折叠到更多中显示。按钮配置 的 编码：按钮标识，一个按钮对应一个编码，不能...
Dataphin管道任务从Oracle抽取数据到MySQL，运行报错...
Index:12,Size:12 at java.util.ArrayList.rangeCheck(ArrayList.java:657)at java.util.ArrayList.get(ArrayList.java:433)at com.alibaba.dt.dlink.core.trans.adaptor.BaseWriterStepAdaptor.columnMapping(BaseWriterStepAdaptor.java:...
获取热点数据
List<GetHotspotTagVO>response=new ArrayList();request.setPreviewToken(previewToken);request.setSubSceneUuid(subSceneId);request.setType(type);sdk 调用 GetHotspotTagResponse hotspotTag=lyjClient.getHotspotTag(request);响应...
删除文件
if(objectListing.getObjectSummaries().size()>0){ List<String>keys=new ArrayList();for(OSSObjectSummary s:objectListing.getObjectSummaries()){ System.out.println("key name:"+s.getKey());keys.add(s.getKey());} ...
异步化IO多线程上传示例
import java.util.ArrayList;import java.util.Date;import java.util.concurrent.*;import java.util.concurrent.atomic.AtomicBoolean;import com.aliyun.odps.Column;import com.aliyun.odps.Odps;import com.aliyun.odps.PartitionSpec...
并发导出数据
import java.util.ArrayList;import java.util.Arrays;import java.util.List;import com.alicloud.openservices.tablestore.SyncClient;import com.alicloud.openservices.tablestore.model.ComputeSplitsRequest;import ...
多协议发布
List<ServerConfig>serverConfigs=new ArrayList();serverConfigs.add(serverConfigA);serverConfigs.add(serverConfigB);providerConfig.setServer(serverConfigs);XML 方式 直接在标签中增加多个 binding 即可：...
复杂数据类型上传下载示例
List<Object>structData=new ArrayList();structData.add("Lily");structData.add(18);将数据传入record。record.setArray(0,arrayData);record.setMap(1,mapData);record.setStruct(2,new SimpleStruct((StructTypeInfo)schema.getColumn...
生命周期
ArrayList<BucketLifecycleRule>lifecycleRules=new ArrayList();lifecycleRules.add(rule1);lifecycleRules.add(rule2);request.setLifecycleRules(lifecycleRules);OSSAsyncTask task=oss.asyncPutBucketLifecycle(request,new ...
发送 HTTP 请求（Java）
List<ApiSecretKey>secretKeys=new ArrayList();若无需加签不需要添加secretKeys secretKeys.add(apiSecretKey);无需加签client apiClientNoAuth=new DefaultApiClient(gatewayUrl);需要加签client apiClient=new DefaultApiClient...
自定义人脸检索
人脸图片检索（URL）代码示例 import java.util.ArrayList;import java.util.Arrays;import java.util.Date;import java.util.HashMap;import java.util.LinkedHashMap;import java.util.List;import java.util.Map;import java.util.UUID;...
创建时序表
private List<TimeseriesAnalyticalStore>analyticalStores=new ArrayList();是否开启分析存储。private boolean enableAnalyticalStore=true;} 参数 参数 说明 TimeseriesTableMeta 时序表的结构信息，包含如下内容：timeseriesTableName...
在测试环境使用加密服务
List<Host>hosts=new ArrayList(){{ add(host1);}};String config="{"+"[LOGGER];logsw=debug,error;logPath=./;[HOST 1];hsmModel=GHSM;host=192.168.XX.XX;linkNum=-3;port=8019;timeout=5;};GHSMAPI api=GHSMAPI....
弹出菜单
效果图 接口说明/*数据构造，使用默认样式*@param context*@param itemArrayList*/public AUPopMenu(Context context,ArrayList<MessagePopItem>itemArrayList)/*adapter 构造，使用自定义样式*@param context*@param listAdapter*/public ...
使用密码机实例
List<Host>hosts=new ArrayList(){{ add(host1);}};String config="{"+"[LOGGER];logsw=debug,error;logPath=./;[HOST 1];hsmModel=GHSM;host=192.168.XX.XX;linkNum=-3;port=8019;timeout=5;};GHSMAPI api=GHSMAPI....
文档搜索 Demo
设置最大返回组数/添加Aggregate对象参数,支持设置一个或多个统计字段示例 aggregateClauses.add(agg);haQuery.setAggregate(aggregateClauses);设置聚合打散子句 ArrayList<HaQueryDistinctClause>DistinctClauses=new ArrayList();...
- 产品推荐
- 这些文档可能帮助您