|
4 | 4 |
|
5 | 5 | trades = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Trade', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([ |
6 | 6 | ('Symbol', dht.string), |
7 | | - ('Sequence', dht.int_), |
| 7 | + ('Sequence', dht.int64), |
8 | 8 | ('Price', dht.double), |
9 | 9 | ('ExchangeCode', dht.string), |
10 | | - ('Size', dht.int_), |
11 | | - ('Tick', dht.int_), |
| 10 | + ('Size', dht.int64), |
| 11 | + ('Tick', dht.int64), |
12 | 12 | ('Change', dht.double), |
13 | | - ('DayVolume', dht.int_), |
14 | | - ('DayTurnover', dht.int_), |
15 | | - ('Direction', dht.int_), |
| 13 | + ('DayVolume', dht.int64), |
| 14 | + ('DayTurnover', dht.int64), |
| 15 | + ('Direction', dht.int64), |
16 | 16 | ('Timestamp', dht.Instant), |
17 | | - ('RawFlags', dht.int_), |
18 | | - ('IsETH', dht.int_), |
19 | | - ('Scope', dht.int_) |
| 17 | + ('RawFlags', dht.int64), |
| 18 | + ('IsETH', dht.int64), |
| 19 | + ('Scope', dht.int64) |
20 | 20 | ]),table_type = TableType.append()).sort_descending(["KafkaOffset"]) |
21 | 21 |
|
22 | 22 | quotes = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Quote', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([ |
|
0 commit comments