-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathscratch
More file actions
44 lines (26 loc) · 1.96 KB
/
scratch
File metadata and controls
44 lines (26 loc) · 1.96 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
records = []
<left_table_name>_<left_counter>_table_location, <left_table_name>_field_terminator = ExecutionPlanUtilities.get_table_location("<left_table_name>")
<left_table_name>_<left_counter>_csv_files = ExecutionPlanUtilities.get_csv_files(<left_table_name>_<left_counter>_table_location)
<left_table_name>_<left_counter>_file_index = 0
<left_table_name>_<left_counter>_pos = 0
until <left_table_name>_<left_counter>_file_index == <left_table_name>_<left_counter>_csv_files.length
<left_table_name>_<left_counter>_line, <left_table_name>_<left_counter>_file_index, <left_table_name>_<left_counter>_pos =
ExecutionPlanUtilities.read_record(<left_table_name>_<left_counter>_table_location, <left_table_name>_<left_counter>_csv_files, <left_table_name>_<left_counter>_file_index, <left_table_name>_<left_counter>_pos, <left_table_name>_field_terminator)
record_<left_counter> = "" + <left_table_name>_<left_counter>_line.chomp
<left_table_name>_<left_counter>_joined_flag = false
prev_outer_table_location = "prev/"
prev_outer_field_terminator = ","
prev_outer_csv_files = ExecutionPlanUtilities.get_csv_files(prev_outer_table_location)
prev_outer_file_index = 0
prev_outer_pos = 0
until prev_outer_file_index == prev_outer_csv_files.length
prev_outer_line, prev_outer_file_index, prev_outer_pos = ExecutionPlanUtilities.read_record(prev_outer_table_location, prev_outer_csv_files, prev_outer_file_index, prev_outer_pos, prev_outer_field_terminator)
record = record_<left_counter> + "," + prev_outer_line.chomp
prev_outer_joined_flag = false
if <join_condition>
<left_table_name>_<left_counter>_joined_flag = true
records \<\< record
end
end
records \<\< <left_table_name>_<left_counter>_line.chomp + ("," * prev_outer_length) unless <left_table_name>_<left_counter>_joined_flag
end