CREATE TABLE tableName(
colName cloType,
...
PRIMARY KEY(keyInfo),
PERIOD FOR SYSTEM_TIME
)WITH(
type='oracle',
url='jdbcUrl',
userName='dbUserName',
password='dbPwd',
tableName='tableName',
cache ='LRU',
schema = 'MQTEST',
parallelism ='1',
partitionedJoin='false'
);
10g 11g
参数名称 | 含义 |
---|---|
tableName | oracle表名称 |
colName | 列名称 |
colType | 列类型 colType支持的类型 |
PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息 |
PRIMARY KEY(keyInfo) | 维表主键定义;多个列之间用逗号隔开 |
参数名称 | 含义 | 是否必填 | 默认值 |
---|---|---|---|
type | 表明维表的类型 oracle | 是 | |
url | 连接oracle数据库 jdbcUrl | 是 | |
userName | oracle连接用户名 | 是 | |
password | oracle连接密码 | 是 | |
tableName | oracle表名称 | 是 | |
schema | oracle 的schema | 否 | 当前登录用户 |
cache | 维表缓存策略(NONE/LRU) | 否 | NONE |
partitionedJoin | 是否在維表join之前先根据 設定的key 做一次keyby操作(可以減少维表的数据缓存量) | 否 | false |
缓存策略
- NONE: 不做内存缓存
- LRU:
- cacheSize: 缓存的条目数量
- cacheTTLMs:缓存的过期时间(ms)
- cacheMode: (unordered|ordered)异步加载是有序还是无序,默认有序。
- asyncCapacity:异步请求容量,默认1000
- asyncTimeout:异步请求超时时间,默认10000毫秒
create table sideTable(
channel varchar,
xccount int,
PRIMARY KEY(channel),
PERIOD FOR SYSTEM_TIME
)WITH(
type='oracle',
url='jdbc:oracle:thin:@xx.xx.xx.xx:1521:orcl',
userName='xx',
password='xx',
tableName='sidetest',
cache ='LRU',
cacheSize ='10000',
cacheTTLMs ='60000',
cacheMode='unordered',
asyncCapacity='1000',
asyncTimeout='10000'
parallelism ='1',
partitionedJoin='false',
schema = 'MQTEST'
);