Skip to content

Commit 2abfd5d

Browse files
twalthrtwalthr
committed
Upper to lower
1 parent 401ee9a commit 2abfd5d

File tree

2 files changed

+285
-259
lines changed

2 files changed

+285
-259
lines changed

‎client-image/conf/sql-client-conf.yaml

Lines changed: 69 additions & 69 deletions
Original file line numberDiff line numberDiff line change
@@ -33,22 +33,22 @@ catalogs:
3333
hive-conf-dir: /opt/hive-conf
3434

3535
tables:
36-
- name: PROD_RATES_HISTORY
36+
- name: prod_rates_history
3737
type: source-table
3838
update-mode: append
3939
schema:
40-
- name: RS_TIMESTAMP
40+
- name: rs_timestamp
4141
data-type: TIMESTAMP(3)
4242
rowtime:
4343
timestamps:
4444
type: from-field
45-
from: RS_RAW_TIMESTAMP
45+
from: rs_raw_timestamp
4646
watermarks:
4747
type: "periodic-bounded"
4848
delay: 5000
49-
- name: RS_SYMBOL
49+
- name: rs_symbol
5050
data-type: STRING
51-
- name: RS_RATE
51+
- name: rs_rate
5252
data-type: DOUBLE
5353
connector:
5454
type: kafka
@@ -66,15 +66,15 @@ tables:
6666
type: csv
6767
field-delimiter: '|'
6868

69-
- name: PROD_RATES_HISTORY_SINK
69+
- name: prod_rates_history_sink
7070
type: sink-table
7171
update-mode: append
7272
schema:
73-
- name: RS_TIMESTAMP
73+
- name: rs_timestamp
7474
data-type: TIMESTAMP(3)
75-
- name: RS_SYMBOL
75+
- name: rs_symbol
7676
data-type: STRING
77-
- name: RS_RATE
77+
- name: rs_rate
7878
data-type: DOUBLE
7979
connector:
8080
type: kafka
@@ -92,54 +92,54 @@ tables:
9292
type: csv
9393
field-delimiter: '|'
9494

95-
- name: PROD_RATES_TEMPORAL
95+
- name: prod_rates_temporal
9696
type: temporal-table
97-
history-table: PROD_RATES_HISTORY
98-
primary-key: RS_SYMBOL
99-
time-attribute: RS_TIMESTAMP
97+
history-table: prod_rates_history
98+
primary-key: rs_symbol
99+
time-attribute: rs_timestamp
100100

101-
- name: PROD_LINEITEM
101+
- name: prod_lineitem
102102
type: source-table
103103
update-mode: append
104104
schema:
105-
- name: L_ORDERKEY
105+
- name: l_orderkey
106106
data-type: INTEGER
107-
- name: L_PARTKEY
107+
- name: l_partkey
108108
data-type: INTEGER
109-
- name: L_SUPPKEY
109+
- name: l_suppkey
110110
data-type: INTEGER
111-
- name: L_LINENUMBER
111+
- name: l_linenumber
112112
data-type: INTEGER
113-
- name: L_QUANTITY
113+
- name: l_quantity
114114
data-type: DOUBLE
115-
- name: L_EXTENDEDPRICE
115+
- name: l_extendedprice
116116
data-type: DOUBLE
117-
- name: L_DISCOUNT
117+
- name: l_discount
118118
data-type: DOUBLE
119-
- name: L_TAX
119+
- name: l_tax
120120
data-type: DOUBLE
121-
- name: L_CURRENCY
121+
- name: l_currency
122122
data-type: STRING
123-
- name: L_RETURNFLAG
123+
- name: l_returnflag
124124
data-type: STRING
125-
- name: L_LINESTATUS
125+
- name: l_linestatus
126126
data-type: STRING
127-
- name: L_ORDERTIME
127+
- name: l_ordertime
128128
data-type: TIMESTAMP(3)
129129
rowtime:
130130
timestamps:
131131
type: from-field
132-
from: L_RAW_ORDERTIME
132+
from: l_raw_ordertime
133133
watermarks:
134134
type: "periodic-bounded"
135135
delay: 5000
136-
- name: L_SHIPINSTRUCT
136+
- name: l_shipinstruct
137137
data-type: STRING
138-
- name: L_SHIPMODE
138+
- name: l_shipmode
139139
data-type: STRING
140-
- name: L_COMMENT
140+
- name: l_comment
141141
data-type: STRING
142-
- name: L_PROCTIME
142+
- name: l_proctime
143143
data-type: TIMESTAMP(3)
144144
proctime: true
145145
connector:
@@ -158,39 +158,39 @@ tables:
158158
type: csv
159159
field-delimiter: '|'
160160

161-
- name: PROD_LINEITEM_SINK
161+
- name: prod_lineitem_sink
162162
type: sink-table
163163
update-mode: append
164164
schema:
165-
- name: L_ORDERKEY
165+
- name: l_orderkey
166166
data-type: INTEGER
167-
- name: L_PARTKEY
167+
- name: l_partkey
168168
data-type: INTEGER
169-
- name: L_SUPPKEY
169+
- name: l_suppkey
170170
data-type: INTEGER
171-
- name: L_LINENUMBER
171+
- name: l_linenumber
172172
data-type: INTEGER
173-
- name: L_QUANTITY
173+
- name: l_quantity
174174
data-type: DOUBLE
175-
- name: L_EXTENDEDPRICE
175+
- name: l_extendedprice
176176
data-type: DOUBLE
177-
- name: L_DISCOUNT
177+
- name: l_discount
178178
data-type: DOUBLE
179-
- name: L_TAX
179+
- name: l_tax
180180
data-type: DOUBLE
181-
- name: L_CURRENCY
181+
- name: l_currency
182182
data-type: STRING
183-
- name: L_RETURNFLAG
183+
- name: l_returnflag
184184
data-type: STRING
185-
- name: L_LINESTATUS
185+
- name: l_linestatus
186186
data-type: STRING
187-
- name: L_ORDERTIME
187+
- name: l_ordertime
188188
data-type: TIMESTAMP(3)
189-
- name: L_SHIPINSTRUCT
189+
- name: l_shipinstruct
190190
data-type: STRING
191-
- name: L_SHIPMODE
191+
- name: l_shipmode
192192
data-type: STRING
193-
- name: L_COMMENT
193+
- name: l_comment
194194
data-type: STRING
195195
connector:
196196
type: kafka
@@ -208,21 +208,21 @@ tables:
208208
type: csv
209209
field-delimiter: '|'
210210

211-
- name: PROD_ORDERS
211+
- name: prod_orders
212212
type: source-table
213213
update-mode: append
214214
schema:
215-
- name: O_ORDERKEY
215+
- name: o_orderkey
216216
data-type: INTEGER
217-
- name: O_CUSTKEY
217+
- name: o_custkey
218218
data-type: INTEGER
219-
- name: O_ORDERSTATUS
219+
- name: o_orderstatus
220220
data-type: STRING
221-
- name: O_TOTALPRICE
221+
- name: o_totalprice
222222
data-type: DOUBLE
223-
- name: O_CURRENCY
223+
- name: o_currency
224224
data-type: STRING
225-
- name: O_ORDERTIME
225+
- name: o_ordertime
226226
data-type: TIMESTAMP(3)
227227
rowtime:
228228
timestamps:
@@ -231,13 +231,13 @@ tables:
231231
watermarks:
232232
type: "periodic-bounded"
233233
delay: 5000
234-
- name: O_ORDERPRIORITY
234+
- name: o_orderpriority
235235
data-type: STRING
236-
- name: O_CLERK
236+
- name: o_clerk
237237
data-type: STRING
238-
- name: O_SHIPPRIORITY
238+
- name: o_shippriority
239239
data-type: INTEGER
240-
- name: O_COMMENT
240+
- name: o_comment
241241
data-type: STRING
242242
connector:
243243
type: kafka
@@ -255,29 +255,29 @@ tables:
255255
type: csv
256256
field-delimiter: '|'
257257

258-
- name: PROD_ORDERS_SINK
258+
- name: prod_orders_sink
259259
type: sink-table
260260
update-mode: append
261261
schema:
262-
- name: O_ORDERKEY
262+
- name: o_orderkey
263263
data-type: INTEGER
264-
- name: O_CUSTKEY
264+
- name: o_custkey
265265
data-type: INTEGER
266-
- name: O_ORDERSTATUS
266+
- name: o_orderstatus
267267
data-type: STRING
268-
- name: O_TOTALPRICE
268+
- name: o_totalprice
269269
data-type: DOUBLE
270-
- name: O_CURRENCY
270+
- name: o_currency
271271
data-type: STRING
272-
- name: O_ORDERTIME
272+
- name: o_ordertime
273273
data-type: TIMESTAMP(3)
274-
- name: O_ORDERPRIORITY
274+
- name: o_orderpriority
275275
data-type: STRING
276-
- name: O_CLERK
276+
- name: o_clerk
277277
data-type: STRING
278-
- name: O_SHIPPRIORITY
278+
- name: o_shippriority
279279
data-type: INTEGER
280-
- name: O_COMMENT
280+
- name: o_comment
281281
data-type: STRING
282282
connector:
283283
type: kafka

0 commit comments

Comments
 (0)