Skip to content

Commit 6810e76

Browse files
committed
Added correct GQL temporal function naming
Signed-off-by: ama2369 <ama2369@columbia.edu>
1 parent 3f96382 commit 6810e76

File tree

1 file changed

+9
-13
lines changed

1 file changed

+9
-13
lines changed

functions-gql/src/lib.rs

Lines changed: 9 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,6 @@ pub fn register_default_gql_functions(registry: &FunctionRegistry) {
4141
register_list_functions(registry);
4242
register_metadata_functions(registry);
4343
register_drasi_functions(registry);
44-
register_context_mutators(registry);
4544
register_aggregation_functions(registry);
4645
register_temporal_instant_functions(registry);
4746
register_temporal_duration_functions(registry);
@@ -94,13 +93,6 @@ fn register_drasi_functions(registry: &FunctionRegistry) {
9493
registry.register_function("drasi.stdevp", Function::Scalar(Arc::new(DrasiStdevP {})));
9594
}
9695

97-
fn register_context_mutators(registry: &FunctionRegistry) {
98-
registry.register_function(
99-
"retainHistory",
100-
Function::ContextMutator(Arc::new(RetainHistory {})),
101-
);
102-
}
103-
10496
fn register_aggregation_functions(registry: &FunctionRegistry) {
10597
registry.register_function("sum", Function::Aggregating(Arc::new(Sum {})));
10698
registry.register_function("avg", Function::Aggregating(Arc::new(Avg {})));
@@ -118,7 +110,15 @@ fn register_aggregation_functions(registry: &FunctionRegistry) {
118110
}
119111

120112
fn register_temporal_instant_functions(registry: &FunctionRegistry) {
121-
registry.register_function("duration.between", Function::Scalar(Arc::new(Between {})));
113+
registry.register_function("date", Function::Scalar(Arc::new(Date {})));
114+
registry.register_function("zoned_time", Function::Scalar(Arc::new(Time {})));
115+
registry.register_function("local_time", Function::Scalar(Arc::new(LocalTime {})));
116+
registry.register_function("zoned_datetime", Function::Scalar(Arc::new(DateTime {})));
117+
registry.register_function("local_datetime", Function::Scalar(Arc::new(LocalDateTime {})));
118+
}
119+
120+
fn register_temporal_duration_functions(registry: &FunctionRegistry) {
121+
registry.register_function("duration_between", Function::Scalar(Arc::new(Between {})));
122122
registry.register_function("duration.inMonths", Function::Scalar(Arc::new(InMonths {})));
123123
registry.register_function("duration.inDays", Function::Scalar(Arc::new(InDays {})));
124124
registry.register_function(
@@ -127,7 +127,3 @@ fn register_temporal_instant_functions(registry: &FunctionRegistry) {
127127
);
128128
registry.register_function("duration", Function::Scalar(Arc::new(DurationFunc {})));
129129
}
130-
131-
fn register_temporal_duration_functions(registry: &FunctionRegistry) {
132-
registry.register_function("dateDiff", Function::Scalar(Arc::new(Between {})));
133-
}

0 commit comments

Comments
 (0)