Skip to content

Commit 2b661c4

Browse files
jjbrosnanjjbrosnan
committed
Remove int_ from tables query as well
1 parent 5a2b736 commit 2b661c4

File tree

1 file changed

+49
-49
lines changed

1 file changed

+49
-49
lines changed

‎data/storage/notebooks/tables.py‎

Lines changed: 49 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -4,52 +4,52 @@
44

55
trades = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Trade', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
66
('Symbol', dht.string),
7-
('Sequence', dht.int_),
7+
('Sequence', dht.int64),
88
('Price', dht.double),
99
('ExchangeCode', dht.string),
10-
('Size', dht.int_),
11-
('Tick', dht.int_),
10+
('Size', dht.int64),
11+
('Tick', dht.int64),
1212
('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),
1616
('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)
2020
]),table_type = TableType.append()).sort_descending(["KafkaOffset"])
2121

2222
quotes = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Quote', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
2323
('Symbol', dht.string),
24-
('Sequence', dht.int_),
24+
('Sequence', dht.int64),
2525
('Timestamp', dht.Instant),
2626
('BidTime', dht.Instant),
2727
('BidExchangeCode', dht.string),
2828
('BidPrice', dht.double),
29-
('BidSize', dht.int_),
29+
('BidSize', dht.int64),
3030
('AskTime', dht.Instant),
3131
('AskExchangeCode', dht.string),
3232
('AskPrice', dht.double),
33-
('AskSize', dht.int_),
34-
('Scope', dht.int_)
33+
('AskSize', dht.int64),
34+
('Scope', dht.int64)
3535
]),table_type = TableType.append()).sort_descending(["KafkaOffset"])
3636

3737

3838
candle = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Candle', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
3939
('Symbol', dht.string),
40-
('EventFlags', dht.int_),
40+
('EventFlags', dht.int64),
4141
('Index', dht.int64),
4242
('Timestamp', dht.Instant),
43-
('Sequence', dht.int_),
44-
('Count', dht.int_),
43+
('Sequence', dht.int64),
44+
('Count', dht.int64),
4545
('Open', dht.double),
4646
('High', dht.double),
4747
('Low', dht.double),
4848
('Close', dht.double),
49-
('Volume', dht.int_),
49+
('Volume', dht.int64),
5050
('VWap', dht.double),
51-
('BidVolume', dht.int_),
52-
('AskVolume', dht.int_),
51+
('BidVolume', dht.int64),
52+
('AskVolume', dht.int64),
5353
('OpenInterest', dht.string),
5454
('ImpVolatility', dht.string)
5555
]),table_type = TableType.append()).sort_descending(["KafkaOffset"])
@@ -60,52 +60,52 @@
6060
('Symbol', dht.string),
6161
('Beta', dht.double),
6262
('EPS', dht.double),
63-
('DivFreq', dht.int_),
63+
('DivFreq', dht.int64),
6464
('ExdDivAmount', dht.double),
65-
('ExdDivDate', dht.int_),
65+
('ExdDivDate', dht.int64),
6666
('52HighPrice', dht.double),
6767
('52LowPrice', dht.double),
68-
('Shares', dht.int_),
68+
('Shares', dht.int64),
6969
('FreeFloat', dht.string),
7070
('HighLimitPrice', dht.double),
7171
('LowLimitPrice', dht.double),
7272
('HaltStartTime', dht.Instant),
7373
('HaltEndTime', dht.Instant),
7474
('Description', dht.string),
75-
('RawFlags', dht.int_),
75+
('RawFlags', dht.int64),
7676
('StatusReason', dht.string),
77-
('TradingStatus', dht.int_),
78-
('ShortSaleRestriction', dht.int_)
77+
('TradingStatus', dht.int64),
78+
('ShortSaleRestriction', dht.int64)
7979
]),table_type = TableType.append()).sort_descending(["KafkaOffset"])
8080

8181

8282
summary = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Summary', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
8383
('Symbol', dht.string),
84-
('DayId', dht.int_),
84+
('DayId', dht.int64),
8585
('DayOpenPrice', dht.double),
8686
('DayHighPrice', dht.double),
8787
('DayLowPrice', dht.double),
8888
('DayClosePrice', dht.double),
89-
('PrevDayId', dht.int_),
89+
('PrevDayId', dht.int64),
9090
('PrevDayClosePrice', dht.double),
91-
('PrevDayVolume', dht.int_),
92-
('OpenInterest', dht.int_),
93-
('RawFlags', dht.int_),
91+
('PrevDayVolume', dht.int64),
92+
('OpenInterest', dht.int64),
93+
('RawFlags', dht.int64),
9494
('ExchangeCode', dht.string),
95-
('DayClosePriceType', dht.int_),
96-
('PrevDayClosePriceType', dht.int_),
97-
('Scope', dht.int_)
95+
('DayClosePriceType', dht.int64),
96+
('PrevDayClosePriceType', dht.int64),
97+
('Scope', dht.int64)
9898
]),table_type = TableType.append()).sort_descending(["KafkaOffset"])
9999

100100
order = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Order', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
101101
('Symbol', dht.string),
102-
('EventFlags', dht.int_),
102+
('EventFlags', dht.int64),
103103
('Index', dht.int64),
104104
('Timestamp', dht.Instant),
105-
('Sequence', dht.int_),
105+
('Sequence', dht.int64),
106106
('Price', dht.double),
107-
('Size', dht.int_),
108-
('Count', dht.int_),
107+
('Size', dht.int64),
108+
('Count', dht.int64),
109109
('Scope', dht.string),
110110
('Side', dht.string),
111111
('ExchangeCode', dht.string),
@@ -124,7 +124,7 @@
124124

125125
time_and_sale = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'TimeAndSale', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
126126
('Symbol', dht.string),
127-
('EventFlags', dht.int_),
127+
('EventFlags', dht.int64),
128128
('Index', dht.int64),
129129
('Timestamp', dht.Instant),
130130
('ExchangeCode', dht.string),
@@ -133,26 +133,26 @@
133133
('BidPrice', dht.double),
134134
('AskPrice', dht.double),
135135
('ExchangeSaleConditions', dht.string),
136-
('RawFlags', dht.int_),
136+
('RawFlags', dht.int64),
137137
('Buyer', dht.string),
138138
('Seller', dht.string),
139-
('Side', dht.int_),
140-
('Type', dht.int_),
141-
('IsValidTick', dht.int_),
142-
('IsEthTrade', dht.int_),
143-
('TradeThroughExempt', dht.int_),
144-
('IsSpreadLeg', dht.int_),
145-
('Scope', dht.int_)
139+
('Side', dht.int64),
140+
('Type', dht.int64),
141+
('IsValidTick', dht.int64),
142+
('IsEthTrade', dht.int64),
143+
('TradeThroughExempt', dht.int64),
144+
('IsSpreadLeg', dht.int64),
145+
('Scope', dht.int64)
146146
]),table_type = TableType.append()).sort_descending(["KafkaOffset"])
147147

148148

149149
series = ck.consume({'bootstrap.servers': 'redpanda:29092'} , 'Series', key_spec=KeyValueSpec.IGNORE, value_spec=ck.json_spec([
150150
('Symbol', dht.string),
151-
('EventFlags', dht.int_),
151+
('EventFlags', dht.int64),
152152
('Index', dht.int64),
153153
('Timestamp', dht.Instant),
154-
('Sequence', dht.int_),
155-
('Expiration', dht.int_),
154+
('Sequence', dht.int64),
155+
('Expiration', dht.int64),
156156
('Volatility', dht.double),
157157
('PutCallRatio', dht.double),
158158
('ForwardPrice', dht.double),

0 commit comments

Comments
 (0)