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)
5151
5252if (${VELOX_ENABLE_AGGREGATES} )
5353 add_subdirectory (aggregates)
54- add_subdirectory (windows)
5554endif ()
5655
5756if (${VELOX_BUILD_TESTING} )
Original file line number Diff line number Diff line change 1111# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1212# See the License for the specific language governing permissions and
1313# 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)
1516
1617target_link_libraries (velox_functions_spark_window velox_buffer velox_exec
1718 velox_functions_window Folly::folly)
Original file line number Diff line number Diff line change 1919#include " velox/expression/FunctionSignature.h"
2020#include " velox/vector/FlatVector.h"
2121
22- namespace facebook ::velox::functions::sparksql::windows {
22+ namespace facebook ::velox::functions::window::sparksql {
2323
2424namespace {
2525
@@ -73,4 +73,4 @@ void registerRowNumber(const std::string& name) {
7373 return std::make_unique<RowNumberFunction>();
7474 });
7575}
76- } // namespace facebook::velox::functions::sparksql::windows
76+ } // namespace facebook::velox::functions::window::sparksql
Original file line number Diff line number Diff line change 1717
1818#include < string>
1919
20- namespace facebook ::velox::functions::sparksql::windows {
20+ namespace facebook ::velox::functions::window::sparksql {
2121void 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 1515 */
1616#include " velox/functions/sparksql/window/WindowFunctionsRegistration.h"
1717#include " velox/functions/lib/window/NthValue.h"
18+ #include " velox/functions/sparksql/window/RowNumber.h"
1819
1920namespace facebook ::velox::functions::window::sparksql {
2021
2122void registerWindowFunctions (const std::string& prefix) {
2223 functions::window::registerIntegerNthValue (prefix + " nth_value" );
24+ registerRowNumber (prefix + " row_number" );
2325}
2426
2527} // 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