创建通道
private static void createStreamTunnelByOffset(TunnelClient client,String tableName,String tunnelName){ CreateTunnelRequest createTunnelRequest=new CreateTunnelRequest(tableName,tunnelName,TunnelType.Stream);创建增量类型...
主键列自增
function createTableWithAutoIncrementPk(){ var createParams={ tableMeta:{ tableName:tableName,primaryKey:[{ name:pk1,type:'STRING' },{ name:pk2,type:'INTEGER',option:'AUTO_INCREMENT'/自增列，指定option为AUTO_INCREMENT。...
列出多元索引列表
创建多元索引后，使用ListSearchIndex接口可以获取当前实例下或某个数据表关联的所有多元索引的列表信息。前提条件 已初始化OTSClient。具体操作，请参见 初始化。...Console.WriteLine("tablename:"+index.TableName);} }
DDL 问题
SQL 执行失败 错误信息：TableName[{tableName}]{SQL 错误信息} 解决方法：根据 {SQL 错误信息} 来解决问题，可能的情况有，表已经存在、索引名重复、表不存在、列已存在、列不存在、主键重复等，问题解决后点击 重试 继续执行。...
列出多元索引列表
示例 func ListSearchIndex(client*tablestore.TableStoreClient,tableName string){ request:=tablestore.ListSearchIndexRequest{} request.TableName=tableName/设置数据表名称。resp,err:=client.ListSearchIndex(request)/获取数据表...
操作权限控制
任务执行环境 实时场景 数据开发执行任务（开发环境执行任务）场景一：select col1 from tablename 用个人账号访问开发环境下该表。即用个人账号访问：projectname_dev.tablename。场景二：select col1 from projectname.tablename 用个人...
删除映射关系
示例 使用 DROP MAPPING TABLE `tableName`;语句删除tableName表的映射关系。request=array('query'=>'DROP MAPPING TABLE `tableName`;');response=$this->otsClient->sqlQuery($request);print json_encode($sqlRows,JSON_PRETTY_PRINT);
Unique示例
InputUtils.addTable(TableInfo.builder().tableName(args[0]).build(),job);OutputUtils.addTable(TableInfo.builder().tableName(args[1]).build(),job);JobClient.runJob(job);}/Key&Value Unique if(ops.equals("all")){ JobConf job=...
Aliyun:Serverless:TableStore:Table
Table","Properties":{"PrimaryKeyList":{"Ref":"PK"} } } } },"Outputs":{"TableName":{"Value":{"Fn:GetAtt":["MyInstanceMyTable","TableName"]} } } } YAML 格式 ROSTemplateFormatVersion:'2015-09-01' Transform:'Aliyun:Serverless-...
Java SDK快速入门
本文介绍如何使用Java SDK对智能召回引擎进行读写...BeWriteRequest deleteRequest=BeWriteRequest.builder().type(BeWriteType.DELETE).tableName(tableName).contents(deleteContents).build();writeResponse=client.write(deleteRequest);
管理MaxCompute Catalog
例如有MaxCompute物理表有二级分区ds和hh，可以使用如下语句写入数据：写入固定分区 INSERT INTO `<catalogName>`.`<projectName>`.`<tableName>`/*+OPTIONS('partition'='ds=20231024,hh=09')*/SELECT,'20231024','09' FROM `...
并发导出数据
ComputeSplitsRequest computeSplitsRequest=new ComputeSplitsRequest { TableName=TableName,SplitOptions=options };ComputeSplitsResponse computeSplitsResponse=otsClient.ComputeSplits(computeSplitsRequest);MatchAllQuery ...
JindoTable使用说明
jindo table-accessStat-d 7-n 20-cache 语法 jindo table-cache {-t}<dbName.tableName>[-p][-pin]功能 表示缓存指定表或分区的数据至集群本地磁盘上。表或分区的路径需要位于OSS或JindoFS。指定表时使用 database.table 的格式，指定分区...
JindoTable使用说明
jindo table-accessStat-d 7-n 20-cache 语法 jindo table-cache {-t}<dbName.tableName>[-p][-pin]功能 表示缓存指定表或分区的数据至集群本地磁盘上。表或分区的路径需要位于OSS或JindoFS。指定表时使用 database.table 的格式，指定分区...
JindoTable使用说明
jindo table-accessStat-d 7-n 20-cache 语法 jindo table-cache {-t}<dbName.tableName>[-p][-pin]功能 表示缓存指定表或分区的数据至集群本地磁盘上。表或分区的路径需要位于OSS或JindoFS。指定表时使用 database.table 的格式，指定分区...
JindoTable使用说明
jindo table-accessStat-d 7-n 20-cache 语法 jindo table-cache {-t}<dbName.tableName>[-p][-pin]功能 表示缓存指定表或分区的数据至集群本地磁盘上。表或分区的路径需要位于OSS或JindoFS。指定表时使用 database.table 的格式，指定分区...
删除投递任务
参数 参数 说明 tableName 数据表名称。taskName 投递任务名称。示例 private static void deleteDeliveryTask(SyncClient client){ String tableName="sampleTable;String taskName="sampledeliverytask;DeleteDeliveryTaskRequest ...
DescribeAllDataSources-查看数据源
database 示例 正常返回示例 JSON 格式 {"RequestId":"75EA41D7-025A-50A6-9287-359A91399F1E","Tables":{"Table":[{"TableName":"table","DBClusterId":"cc-bp108z124a8o7*","SchemaName":"database"}]},"Columns":{"Column":[{"Type":...
删除数据表
deleteReq:=new(tablestore.DeleteTableRequest)deleteReq.TableName=tableName_,err:=client.DeleteTable(deleteReq)if(err!nil){ fmt.Println("Failed to delete table with error:",err)} else { fmt.Println("Delete table finished")}...
Spark对接HBase
hbaseContext.foreachPartition(rdd,new VoidFunction[]>,Connection>>(){ public void call(Tuple2[]>,Connection>t)throws Exception { Table table=t._2().getTable(TableName.valueOf(tableName));BufferedMutator mutator=t._2()....
查询投递任务描述信息
示例 func DescribeTaskSample(client*tablestore.TableStoreClient,tableName,taskName string){ req:=tablestore.DescribeDeliveryTaskRequest{ TableName:tableName,TaskName:taskName,} resp,err:=client.DescribeDeliveryTask(req)if ...
查询多元索引描述信息
示例 func DescribeSearchIndex(client*tablestore.TableStoreClient,tableName string,indexName string){ request:=tablestore.DescribeSearchIndexRequest{} request.TableName=tableName/设置数据表名称。request.IndexName=indexName/...
GetTable-查询表信息
示例 正常返回示例 JSON 格式 {"RequestId":"1AD222E9-E606-4A42-BF6D-8A4442913CEF","Code":0,"Message":"\"\"","Success":true,"Table":{"TblId":123,"DbName":"example","TableName":"tableName","TableType":"external_table",...
从Flink导入数据至ClickHouse
Unit=args match { case("-help"|"-h"):_=>printUsageAndExit()case"-dbName":value:tail=>dbName=value parse(tail)case"-tableName":value:tail=>tableName=value parse(tail)case"-ckHost":value:tail=>ckHost=value parse(tail)case...
Spark访问EMR HBase数据
hbaseContext.foreachPartition(rdd,new VoidFunction[]>,Connection>>(){ public void call(Tuple2[]>,Connection>t)throws Exception { Table table=t._2().getTable(TableName.valueOf(tableName));BufferedMutator mutator=t._2()....
JindoTable使用说明
jindo table-accessStat-d 7-n 20-cache 语法 jindo table-cache {-t}<dbName.tableName>[-p][-pin]功能 表示缓存指定表或分区的数据至集群本地磁盘上。表或分区的路径需要位于OSS或JindoFS。指定表时使用 database.table 的格式；指定分区...
ModifyDataSource-修改指定实例的指定数据源信息
请求语法 PUT/v2/openapi/instances/{instanceId}/dataSources/{tableName} 请求参数 名称 类型 必填 描述 示例值 instanceId string 是 实例 ID。airec-cn-o400whm78004 tableName string 否 要修改数据源的数据表名称。behavior 返回参数...
JindoTable使用说明
jindo table-listTables-db db1-dumpmc 语法 jindo table-dumpmc {-i}<accessId>{-k}<accessKey>{-m}<numMaps>{-t}<tunnelUrl>{-project}<projectName>{-table}<tablename>{-p}<partitionSpec>{-f}|tfrecord>{-o}参数 描述 是否必选-i 阿里...
JindoTable使用说明
jindo table-listTables-db db1-dumpmc 语法 jindo table-dumpmc {-i}<accessId>{-k}<accessKey>{-m}<numMaps>{-t}<tunnelUrl>{-project}<projectName>{-table}<tablename>{-p}<partitionSpec>{-f}|tfrecord>{-o}参数 描述 是否必选-i 阿里...
JindoTable使用说明
jindo table-listTables-db db1-dumpmc 语法 jindo table-dumpmc {-i}<accessId>{-k}<accessKey>{-m}<numMaps>{-t}<tunnelUrl>{-project}<projectName>{-table}<tablename>{-p}<partitionSpec>{-f}|tfrecord>{-o}参数 描述 是否必选-i 阿里...
DescribeAllDataSource-枚举数据库列表
database 示例 正常返回示例 JSON 格式 {"RequestId":"05321590-BB65-4720-8CB6-8218E041CDD0","Tables":{"Table":[{"TableName":"table","DBClusterId":"cc-bp108z124a8o7*","SchemaName":"database"}]},"Columns":{"Column":[{"Type":...
局部事务
transPk:=new(tablestore.PrimaryKey)transPk.AddPrimaryKeyColumn("userid",userName)trans:=tablestore.StartLocalTransactionRequest{ TableName:TableName,PrimaryKey:transPk,} response,err:=client.StartLocalTransaction(trans)if ...
DescribeExpandLogicTableInfoList
575D-4A77-A4F8-24B7EF*</RequestId><Data><data><TableName>employee_split2</TableName><ShardTbKey>address</ShardTbKey><ShardDbKey>id</ShardDbKey></data></Data><Success>true</Success></DescribeExpandLogicTableInfoListReponse>...
查询索引描述信息
示例 使用 SHOW INDEX IN `tableName`;语句查询tableName表的索引描述信息。request=array('query'=>'SHOW INDEX IN `tableName`;',);response=$this->otsClient->sqlQuery($request);sqlRows=$response['sql_rows'];print json_encode($...
统计聚合
let params={ tableName:tableName,indexName:indexName,searchQuery:searchQuery,columnToGet:{/返回列设置，可设置为RETURN_SPECIFIED（自定义返回列）、RETURN_ALL（返回所有列）、RETURN_ALL_FROM_INDEX（返回多元索引中的所有列）、...
查询表的描述信息
示例 使用 DESCRIBE `tableName`;语句查询tableName表的描述信息。request=array('query'=>'DESCRIBE `tableName`;',);response=$this->otsClient->sqlQuery($request);sqlRows=$response['sql_rows'];print json_encode($sqlRows,JSON_...
DescribeDistributeTableList
TableName String sbtest1 表名。TableType String multi 表类型。TbKey String“”表key。DbKey String id 数据key。示例 请求示例 http(s):/[Endpoint]/?Action=DescribeDistributeTableList&RegionId=cn-hangzhou &DBInstanceName=pxc-*...
并发导出数据
let computeSplits=await new Promise((resolve,reject)=>{ client.computeSplits({ tableName:tableName,searchIndexSplitsOptions:{ indexName:indexName,} },function(err,data){ if(err){ console.log('computeSplits error:',err....
创建时序表
private static void createTimeseriesTable(TimeseriesClient client){ String tableName="test_timeseries_table;TimeseriesTableMeta timeseriesTableMeta=new TimeseriesTableMeta(tableName);int timeToLive=-1;timeseriesTableMeta....
拆分
PAI-name split-project algo_public-DinputTableName=wbpc-Doutput1TableName=wpbc_split1-Doutput2TableName=wpbc_split2-Dfraction=0.25;参数名称 是否必选 参数描述 默认值 inputTableName 是 输入表的表名。无 inputTablePartitions ...
- 产品推荐
- 这些文档可能帮助您