forked from DTStack/chunjun
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'feat_1.12_pluginMerge_oracle_tmp' into 'feat_1.12_plugi…
…nMerge' Feat 1.12 plugin merge oracle tmp See merge request dt-insight-engine/flinkx!424
- Loading branch information
Showing
4 changed files
with
460 additions
and
553 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,103 @@ | ||
# Oracle Lookup | ||
|
||
## 一、介绍 | ||
Oracle维表,支持全量和异步方式<br /> | ||
全量缓存:将维表数据全部加载到内存中,建议数据量不大使用。<br /> | ||
异步缓存:使用异步方式查询数据,并将查询到的数据使用lru缓存到内存中,建议数据量大使用。 | ||
|
||
## 二、支持版本 | ||
Oracle 9 及以上 | ||
|
||
|
||
## 三、插件名称 | ||
| SQL | oracle-x | | ||
| --- | --- | | ||
|
||
## 四、参数说明 | ||
- **connector** | ||
- 描述:oracle-x | ||
- 必选:是 | ||
- 参数类型:String | ||
- 默认值:无 | ||
<br /> | ||
|
||
- **url** | ||
- 描述:jdbc:oracle:thin:@0.0.0.1:1521:orcl | ||
- 必选:是 | ||
- 参数类型:String | ||
- 默认值:无 | ||
<br /> | ||
|
||
- **table-name** | ||
- 描述:表名 | ||
- 必选:是 | ||
- 参数类型:String | ||
- 默认值:无: | ||
<br /> | ||
|
||
- **username** | ||
- 描述:username | ||
- 必选:是 | ||
- 参数类型:String | ||
- 默认值:无 | ||
<br /> | ||
|
||
- **password** | ||
- 描述:password | ||
- 必选:是 | ||
- 参数类型:String | ||
- 默认值:无 | ||
<br /> | ||
|
||
- **lookup.cache-type** | ||
- 描述:维表缓存类型(NONE、LRU、ALL),默认LRU | ||
- 必选:否 | ||
- 参数类型:string | ||
- 默认值:LRU | ||
<br /> | ||
|
||
- **lookup.cache-period** | ||
- 描述:ALL维表每隔多久加载一次数据,默认3600000毫秒(一个小时) | ||
- 必选:否 | ||
- 参数类型:string | ||
- 默认值:3600000 | ||
<br /> | ||
|
||
- **lookup.cache.max-rows** | ||
- 描述:lru维表缓存数据的条数,默认10000条 | ||
- 必选:否 | ||
- 参数类型:string | ||
- 默认值:10000 | ||
<br /> | ||
|
||
- **lookup.cache.ttl** | ||
- 描述:lru维表缓存数据的时间,默认60000毫秒(一分钟) | ||
- 必选:否 | ||
- 参数类型:string | ||
- 默认值:60000 | ||
<br /> | ||
|
||
- **lookup.fetchSize** | ||
- 描述:ALL维表每次从数据库加载的条数,默认1000条 | ||
- 必选:否 | ||
- 参数类型:string | ||
- 默认值:1000 | ||
<br /> | ||
|
||
- **lookup.parallelism** | ||
- 描述:维表并行度 | ||
- 必选:否 | ||
- 参数类型:string | ||
- 默认值:无 | ||
<br /> | ||
|
||
## 五、数据类型 | ||
| 支持 | SMALLINT、BINARY_DOUBLE、CHAR、VARCHAR、VARCHAR2、NCHAR、NVARCHAR2、INT、INTEGER、NUMBER、DECIMAL、FLOAT、DATE、RAW、LONG RAW、BINARY_FLOAT、TIMESTAMP、TIMESTAMP WITH LOCAL TIME ZONE、TIMESTAMP WITH TIME ZON、INTERVAL YEAR、INTERVAL DAY | | ||
| --- | --- | | ||
| 暂不支持 | BFILE、XMLTYPE、Collections、BLOB、CLOB、NCLOB | | ||
注意:由于 flink DecimalType 的 PRECISION(1~38) 与 SCALE(0~PRECISION) 限制,oracle 的数值类型的数据在转换时可能会丢失精度 | ||
|
||
|
||
|
||
## 六、脚本示例 | ||
见项目内`FlinkX : Local : Test`模块中的`demo`文件夹。 |
Oops, something went wrong.