This utility will help upgrade disk querytables between versions of StreamBase.
-
Update the schemas in
gen_disk_qt_upgrade.py
__main__
section. The generation methods support upgrading multiple tables in the same app simulatenously.-
Update the table definitions
example_table = { # TableName -> the table to upgrade 'TableName' : 'NamedPointTable', # Schema -> the table's schema in ssql form 'Schema' : '''( x int, y int, z int, name string)''', # pkey -> comma separated list of fields 'pkey' : 'name, x', # skeys -> list of comma separated lists of fields 'skeys' : ['y, z', 'z'] }
-
Update the list of tables and container names
tables = [example_table1, example_table2] container = 'table_container'
-
-
run
gen_disk_qt_upgrade.py
-
manually start two sbds
-
the old one should be started with the old version of StreamBase on port 10000
sbd -p 10000 --datadir data-old
-
the new one should be started with the new version of StreamBase on port 10001
sbd -p 10001 --datadir data-new
-
-
run the
driver.sh
shell script -
wait for the computer to finish computing (this will be quick for small tables)