-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy path.byebug_history
154 lines (154 loc) · 4.23 KB
/
.byebug_history
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
c
prunable_partitions.count
past_partitions.count
prunable_partitions.count
past_partitions.count
past_partitions
partition_tables.count
partition_tablespast_partitions
prunable_partitions.count
prunable_partitions
c
[1,2,3,4,5,6][..-(retain_number + 1)]
[1,2,3,4,5][..-(retain_number + 1)]
[1,2,3,4][..-(retain_number + 1)]
[1,2,3,4]..-(retain_number + 1)
[1,2,3,4]-(retain_number + 1)
-(retain_number + 1)
retain_number = 4
[1,2,3].first(-1)
[1,2,3][..-1]
[1,2,3][..-2]
[1,2,3][..-3]
[1,2,3][..-4]
[1,2,3][..-2]
[1,2,3] - [2]
[1,2] - [2]
[1,2] - [1]
[1,2] - []
past_partitions.sort.last(2)
past_partitions.sort.last
past_partitions.sort
past_partitions.count
past_partitions
past_partitions = partition_tables.select { |name| name < current_partition_name }
current_partition_name = build_partition_name(Time.current, Time.current + 1.hour)
build_partition_name(Time.current, Time.current + 1.hour)
sorted_partition_tables.last
sorted_partition_tables.first
sorted_partition_tables = partition_tables.sort
sorted_partition_tables
partition_tables = partition_tables.sort
partition_tables.count
partition_tables = @partition_adapter.get_all_supported_partition_tables
c
OutgoingEvent.partition_manager.active_ranges
c
OutgoingEvent.partition_manager.active_ranges
OutgoingEvent.partition_manager.active_ranges[0]
partitioned_value
OutgoingEvent.partition_manager.active_ranges[0].cover? partitioned_value
OutgoingEvent.partition_manager.active_ranges[0]
OutgoingEvent.partition_manager.active_ranges
a.rangify
a = OutgoingEvent.partition_manager.active_ranges
OutgoingEvent.partition_manager.active_ranges
OutgoingEvent.partition_manager.active_ranges.rangify
OutgoingEvent.partition_manager.active_ranges
OutgoingEvent.partition_manager.active_ranges.max
OutgoingEvent.partition_manager.active_ranges
OutgoingEvent.active_ranges
OutgoingEvent.active_partitions_cover?(partitioned_value)
c
partitioned_value
from_time..to_time
from_time = latest_coverage + (diff.floor * default_premake_period)
to_time = from_time + default_premake_period
diff = (partitioned_value - latest_coverage) / default_premake_period
latest_coverage = latest_partition_coverage_time()
partitioned_value = partitioned_value.utc
partitioned_value
from_time..to_time
to_time = from_time + default_premake_period
from_time = latest_coverage + (diff.floor * default_premake_period)
diff = (partitioned_value - latest_coverage) / default_premake_period
-3.9.floor
(partitioned_value - latest_coverage)/default_premake_period
default_premake_period = 1.day
self.default_premake_period
default_premake_period
default_premake_perioddefault_premake_period
default_premake_period
(partitioned_value - latest_coverage)/default_premake_period
(partitioned_value - latest_coverage)
(partitioned_value - latest_coverage).floor
partitioned_value - latest_coverage
partitioned_value
latest_coverage = latest_partition_coverage_time()
c
@connection.execute sql
c
@connection.execute sql.delete("SQL")
sql
@connection.execute sql
@connection
puts sql
sql
c
e.message
c
unix_to
unix_from
Time.at(1719997200)
get_all_supported_partition_tables
sql_to
sql_from
partition_name
sql = <<~SQL
CREATE TABLE IF NOT EXISTS #{partition_name}
PARTITION OF #{@table_name}
FOR VALUES FROM ('#{sql_from}') TO ('#{sql_to}');
SQL
@connection.execute <<~SQL
CREATE TABLE IF NOT EXISTS #{partition_name}
PARTITION OF #{@table_name}
FOR VALUES FROM ('#{sql_from}') TO ('#{sql_to}');
SQL
partition_name
c
build_partition_name(from, to)
c
build_partition_name(from, to)
c
build_partition_name(from, to)
c
build_partition_name(from, to)
c
get_all_supported_partition_tables.each {|t| drop_partition(t)}
get_all_supported_partition_tables
partition_name
c
partition_name = build_partition_name(from, to)
c
partition_name = build_partition_name(from, to)
c
new_latest_coverage_time
current_coverage_time
current_coverage_time < new_latest_coverage_time
current_coverage_time = from || latest_partition_coverage_time
current_coverage_time
new_latest_coverage_time = (from || Time.current).utc + (period * number)
new_latest_coverage_time
c
C
c
connection
to
from
table_name
partition_name
partition_name, table_name, from, to
partition_adapter.exec_create_partition_by_time_range
partition_adapter
partition_adapater
partition_name