File tree Expand file tree Collapse file tree 8 files changed +8
-75
lines changed Expand file tree Collapse file tree 8 files changed +8
-75
lines changed Original file line number Diff line number Diff line change @@ -51,7 +51,6 @@ add_subdirectory(window)
51
51
52
52
if (${VELOX_ENABLE_AGGREGATES} )
53
53
add_subdirectory (aggregates )
54
- add_subdirectory (windows )
55
54
endif ()
56
55
57
56
if (${VELOX_BUILD_TESTING} )
Original file line number Diff line number Diff line change 11
11
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12
12
# See the License for the specific language governing permissions and
13
13
# limitations under the License.
14
- add_library (velox_functions_spark_window WindowFunctionsRegistration.cpp )
14
+ add_library (velox_functions_spark_window RowNumber.cpp
15
+ WindowFunctionsRegistration.cpp )
15
16
16
17
target_link_libraries (velox_functions_spark_window velox_buffer velox_exec
17
18
velox_functions_window Folly::folly )
Original file line number Diff line number Diff line change 19
19
#include " velox/expression/FunctionSignature.h"
20
20
#include " velox/vector/FlatVector.h"
21
21
22
- namespace facebook ::velox::functions::sparksql::windows {
22
+ namespace facebook ::velox::functions::window::sparksql {
23
23
24
24
namespace {
25
25
@@ -73,4 +73,4 @@ void registerRowNumber(const std::string& name) {
73
73
return std::make_unique<RowNumberFunction>();
74
74
});
75
75
}
76
- } // namespace facebook::velox::functions::sparksql::windows
76
+ } // namespace facebook::velox::functions::window::sparksql
Original file line number Diff line number Diff line change 17
17
18
18
#include < string>
19
19
20
- namespace facebook ::velox::functions::sparksql::windows {
20
+ namespace facebook ::velox::functions::window::sparksql {
21
21
void registerRowNumber (const std::string& prefix);
22
- } // namespace facebook::velox::functions::sparksql::windows
22
+ } // namespace facebook::velox::functions::window::sparksql
Original file line number Diff line number Diff line change 15
15
*/
16
16
#include " velox/functions/sparksql/window/WindowFunctionsRegistration.h"
17
17
#include " velox/functions/lib/window/NthValue.h"
18
+ #include " velox/functions/sparksql/window/RowNumber.h"
18
19
19
20
namespace facebook ::velox::functions::window::sparksql {
20
21
21
22
void registerWindowFunctions (const std::string& prefix) {
22
23
functions::window::registerIntegerNthValue (prefix + " nth_value" );
24
+ registerRowNumber (prefix + " row_number" );
23
25
}
24
26
25
27
} // namespace facebook::velox::functions::window::sparksql
Load Diff This file was deleted.
Load Diff This file was deleted.
Load Diff This file was deleted.
You can’t perform that action at this time.
0 commit comments