@@ -23,9 +23,9 @@ protocol Stage {
23
23
}
24
24
25
25
class CollectionSource : Stage {
26
- var name : String = " collection "
26
+ let name : String = " collection "
27
27
28
- var bridge : StageBridge
28
+ let bridge : StageBridge
29
29
private var collection : String
30
30
31
31
init ( collection: String ) {
@@ -35,9 +35,9 @@ class CollectionSource: Stage {
35
35
}
36
36
37
37
class CollectionGroupSource : Stage {
38
- var name : String = " collectionId "
38
+ let name : String = " collectionId "
39
39
40
- var bridge : StageBridge
40
+ let bridge : StageBridge
41
41
private var collectionId : String
42
42
43
43
init ( collectionId: String ) {
@@ -48,8 +48,8 @@ class CollectionGroupSource: Stage {
48
48
49
49
// Represents the entire database as a source.
50
50
class DatabaseSource : Stage {
51
- var name : String = " database "
52
- var bridge : StageBridge
51
+ let name : String = " database "
52
+ let bridge : StageBridge
53
53
54
54
init ( ) {
55
55
bridge = DatabaseSourceStageBridge ( )
@@ -58,8 +58,8 @@ class DatabaseSource: Stage {
58
58
59
59
// Represents a list of document references as a source.
60
60
class DocumentsSource : Stage {
61
- var name : String = " documents "
62
- var bridge : StageBridge
61
+ let name : String = " documents "
62
+ let bridge : StageBridge
63
63
private var references : [ String ]
64
64
65
65
// Initialize with an array of String paths
@@ -71,8 +71,8 @@ class DocumentsSource: Stage {
71
71
72
72
// Represents an existing Query as a source.
73
73
class QuerySource : Stage {
74
- var name : String = " query "
75
- var bridge : StageBridge
74
+ let name : String = " query "
75
+ let bridge : StageBridge
76
76
private var query : Query
77
77
78
78
init ( query: Query ) {
@@ -84,8 +84,8 @@ class QuerySource: Stage {
84
84
85
85
// Represents an existing AggregateQuery as a source.
86
86
class AggregateQuerySource : Stage {
87
- var name : String = " aggregateQuery "
88
- var bridge : StageBridge
87
+ let name : String = " aggregateQuery "
88
+ let bridge : StageBridge
89
89
private var aggregateQuery : AggregateQuery
90
90
91
91
init ( aggregateQuery: AggregateQuery ) {
@@ -96,9 +96,9 @@ class AggregateQuerySource: Stage {
96
96
}
97
97
98
98
class Where : Stage {
99
- var name : String = " where "
99
+ let name : String = " where "
100
100
101
- var bridge : StageBridge
101
+ let bridge : StageBridge
102
102
private var condition : BooleanExpr
103
103
104
104
init ( condition: BooleanExpr ) {
@@ -108,9 +108,9 @@ class Where: Stage {
108
108
}
109
109
110
110
class Limit : Stage {
111
- var name : String = " limit "
111
+ let name : String = " limit "
112
112
113
- var bridge : StageBridge
113
+ let bridge : StageBridge
114
114
private var limit : Int32
115
115
116
116
init ( _ limit: Int32 ) {
@@ -120,9 +120,9 @@ class Limit: Stage {
120
120
}
121
121
122
122
class Offset : Stage {
123
- var name : String = " offset "
123
+ let name : String = " offset "
124
124
125
- var bridge : StageBridge
125
+ let bridge : StageBridge
126
126
private var offset : Int32
127
127
128
128
init ( _ offset: Int32 ) {
@@ -132,8 +132,8 @@ class Offset: Stage {
132
132
}
133
133
134
134
class AddFields : Stage {
135
- var name : String = " addFields "
136
- var bridge : StageBridge
135
+ let name : String = " addFields "
136
+ let bridge : StageBridge
137
137
private var fields : [ Selectable ]
138
138
139
139
init ( fields: [ Selectable ] ) {
@@ -150,8 +150,8 @@ class AddFields: Stage {
150
150
}
151
151
152
152
class RemoveFieldsStage : Stage {
153
- var name : String = " removeFields "
154
- var bridge : StageBridge
153
+ let name : String = " removeFields "
154
+ let bridge : StageBridge
155
155
private var fields : [ String ]
156
156
157
157
init ( fields: [ String ] ) {
@@ -166,8 +166,8 @@ class RemoveFieldsStage: Stage {
166
166
}
167
167
168
168
class Select : Stage {
169
- var name : String = " select "
170
- var bridge : StageBridge
169
+ let name : String = " select "
170
+ let bridge : StageBridge
171
171
private var selections : [ Selectable ]
172
172
173
173
init ( selections: [ Selectable ] ) {
@@ -179,8 +179,8 @@ class Select: Stage {
179
179
}
180
180
181
181
class Distinct : Stage {
182
- var name : String = " distinct "
183
- var bridge : StageBridge
182
+ let name : String = " distinct "
183
+ let bridge : StageBridge
184
184
private var groups : [ Selectable ]
185
185
186
186
init ( groups: [ Selectable ] ) {
@@ -192,8 +192,8 @@ class Distinct: Stage {
192
192
}
193
193
194
194
class Aggregate : Stage {
195
- var name : String = " aggregate "
196
- var bridge : StageBridge
195
+ let name : String = " aggregate "
196
+ let bridge : StageBridge
197
197
private var accumulators : [ AggregateWithAlias ]
198
198
private var groups : [ String : Expr ] = [ : ]
199
199
@@ -214,8 +214,8 @@ class Aggregate: Stage {
214
214
}
215
215
216
216
class FindNearest : Stage {
217
- var name : String = " findNearest "
218
- var bridge : StageBridge
217
+ let name : String = " findNearest "
218
+ let bridge : StageBridge
219
219
private var field : Field
220
220
private var vectorValue : [ Double ]
221
221
private var distanceMeasure : DistanceMeasure
@@ -243,8 +243,8 @@ class FindNearest: Stage {
243
243
}
244
244
245
245
class Sort : Stage {
246
- var name : String = " sort "
247
- var bridge : StageBridge
246
+ let name : String = " sort "
247
+ let bridge : StageBridge
248
248
private var orderings : [ Ordering ]
249
249
250
250
init ( orderings: [ Ordering ] ) {
@@ -254,8 +254,8 @@ class Sort: Stage {
254
254
}
255
255
256
256
class ReplaceWith : Stage {
257
- var name : String = " replaceWith "
258
- var bridge : StageBridge
257
+ let name : String = " replaceWith "
258
+ let bridge : StageBridge
259
259
private var expr : Expr
260
260
261
261
init ( expr: Expr ) {
@@ -265,8 +265,8 @@ class ReplaceWith: Stage {
265
265
}
266
266
267
267
class Sample : Stage {
268
- var name : String = " sample "
269
- var bridge : StageBridge
268
+ let name : String = " sample "
269
+ let bridge : StageBridge
270
270
private var count : Int64 ?
271
271
private var percentage : Double ?
272
272
@@ -284,8 +284,8 @@ class Sample: Stage {
284
284
}
285
285
286
286
class Union : Stage {
287
- var name : String = " union "
288
- var bridge : StageBridge
287
+ let name : String = " union "
288
+ let bridge : StageBridge
289
289
private var other : Pipeline
290
290
291
291
init ( other: Pipeline ) {
@@ -295,8 +295,8 @@ class Union: Stage {
295
295
}
296
296
297
297
class Unnest : Stage {
298
- var name : String = " unnest "
299
- var bridge : StageBridge
298
+ let name : String = " unnest "
299
+ let bridge : StageBridge
300
300
private var field : Selectable
301
301
private var indexField : String ?
302
302
@@ -311,8 +311,8 @@ class Unnest: Stage {
311
311
}
312
312
313
313
class GenericStage : Stage {
314
- var name : String
315
- var bridge : StageBridge
314
+ let name : String
315
+ let bridge : StageBridge
316
316
private var params : [ Sendable ]
317
317
private var options : [ String : Sendable ] ?
318
318
0 commit comments