@@ -238,37 +238,37 @@ def main(argv=None):
238
238
newlen = len (selectedPersonParams [2 ])
239
239
nameParams .extend ([nameParams [random .randint (0 , oldlen - 1 )] for j in range (newlen - oldlen )])
240
240
241
- # serialize all the parameters as JSON
242
- jsonWriters = {}
241
+ # serialize all the parameters as CSV
242
+ csvWriters = {}
243
243
# all the queries have Person as parameter
244
244
for i in range (1 ,15 ):
245
- jsonWriter = CSVSerializer ()
246
- jsonWriter .setOutputFile (outdir + "query_%d_param.txt" % (i ))
245
+ csvWriter = CSVSerializer ()
246
+ csvWriter .setOutputFile (outdir + "query_%d_param.txt" % (i ))
247
247
if i != 13 and i != 14 : # these three queries take two Persons as parameters
248
- jsonWriter .registerHandler (handlePersonParam , selectedPersonParams [i ], "Person" )
249
- jsonWriters [i ] = jsonWriter
248
+ csvWriter .registerHandler (handlePersonParam , selectedPersonParams [i ], "Person" )
249
+ csvWriters [i ] = csvWriter
250
250
251
251
# add output for Time parameter
252
252
for i in timeSelectionInput :
253
253
if i == 3 or i == 4 :
254
- jsonWriters [i ].registerHandler (handleTimeDurationParam , selectedTimeParams [i ], "Date0|Duration" )
254
+ csvWriters [i ].registerHandler (handleTimeDurationParam , selectedTimeParams [i ], "Date0|Duration" )
255
255
else :
256
- jsonWriters [i ].registerHandler (handleTimeParam , selectedTimeParams [i ], "Date0" )
256
+ csvWriters [i ].registerHandler (handleTimeParam , selectedTimeParams [i ], "Date0" )
257
257
258
258
# other, query-specific parameters
259
- jsonWriters [1 ].registerHandler (handleFirstNameParam , nameParams , "Name" )
260
- jsonWriters [3 ].registerHandler (handlePairCountryParam , zip (selectedCountryParams [3 ],secondCountry ),"Country1|Country2" )
261
- jsonWriters [6 ].registerHandler (handleTagParam , selectedTagParams [6 ],"Tag" )
262
- jsonWriters [10 ].registerHandler (handleHSParam , HS , "HS0|HS1" )
263
- jsonWriters [11 ].registerHandler (handleCountryParam , selectedCountryParams [11 ],"Country" )
264
- jsonWriters [11 ].registerHandler (handleWorkYearParam , selectedTimeParams [11 ],"Date0" )
265
- jsonWriters [12 ].registerHandler (handleTagTypeParam , selectedTagTypeParams [12 ],"TagType" )
266
- jsonWriters [13 ].registerHandler (handlePairPersonParam , zip (selectedPersonParams [13 ], secondPerson [13 ]),"Person1|Person2" )
267
- jsonWriters [14 ].registerHandler (handlePairPersonParam , zip (selectedPersonParams [14 ], secondPerson [14 ]),"Person1|Person2" )
268
-
269
-
270
- for j in jsonWriters :
271
- jsonWriters [j ].writeCSV ()
259
+ csvWriters [1 ].registerHandler (handleFirstNameParam , nameParams , "Name" )
260
+ csvWriters [3 ].registerHandler (handlePairCountryParam , zip (selectedCountryParams [3 ],secondCountry ),"Country1|Country2" )
261
+ csvWriters [6 ].registerHandler (handleTagParam , selectedTagParams [6 ],"Tag" )
262
+ csvWriters [10 ].registerHandler (handleHSParam , HS , "HS0|HS1" )
263
+ csvWriters [11 ].registerHandler (handleCountryParam , selectedCountryParams [11 ],"Country" )
264
+ csvWriters [11 ].registerHandler (handleWorkYearParam , selectedTimeParams [11 ],"Date0" )
265
+ csvWriters [12 ].registerHandler (handleTagTypeParam , selectedTagTypeParams [12 ],"TagType" )
266
+ csvWriters [13 ].registerHandler (handlePairPersonParam , zip (selectedPersonParams [13 ], secondPerson [13 ]),"Person1|Person2" )
267
+ csvWriters [14 ].registerHandler (handlePairPersonParam , zip (selectedPersonParams [14 ], secondPerson [14 ]),"Person1|Person2" )
268
+
269
+
270
+ for j in csvWriters :
271
+ csvWriters [j ].writeCSV ()
272
272
273
273
if __name__ == "__main__" :
274
274
sys .exit (main ())
0 commit comments