[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r772060051 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [FLINK-24557] Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r769301266 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768422566 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/linalg/BLASTest.java ## @@ -0,0 +1,74 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768414729 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -26,9 +26,91 @@ private static final dev.ludovic.netlib.BLAS

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768414729 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -26,9 +26,91 @@ private static final dev.ludovic.netlib.BLAS

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r768413217 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767490529 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/DenseMatrix.java ## @@ -0,0 +1,69 @@ +package org.apache.flink.ml.linalg; + +import

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767387752 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -22,13 +22,84 @@ /** A utility class that provides BLAS routines

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767387005 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,134 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r766351212 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/DenseMatrix.java ## @@ -0,0 +1,74 @@ +package org.apache.flink.ml.linalg; + +import

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r766347505 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/knn/KnnTest.java ## @@ -0,0 +1,273 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r766347443 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,134 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r766344063 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,134 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r766343636 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r765407180 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r76541 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,138 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r764641563 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasK.java ## @@ -0,0 +1,39 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r763682700 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/DenseMatrix.java ## @@ -0,0 +1,47 @@ +package org.apache.flink.ml.linalg; + +import

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r762714568 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/FastDistanceMatrixData.java ## @@ -0,0 +1,122 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752285170 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/params/shared/colname/HasOutputColDefaultAsNull.java ## @@ -0,0 +1,46 @@ +/* + * Licensed to

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752280532 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/knn/KnnTest.java ## @@ -0,0 +1,168 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r751889202 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java ## @@ -0,0 +1,38 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r747369365 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/algo/batch/knn/KnnTrainBatchOp.java ## @@ -0,0 +1,230 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r747369365 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/algo/batch/knn/KnnTrainBatchOp.java ## @@ -0,0 +1,230 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r747319728 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/algo/batch/knn/KnnPredictBatchOp.java ## @@ -0,0 +1,345 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r747318831 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/params/knn/KnnClassifierParams.java ## @@ -0,0 +1,4 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r747312484 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/algo/batch/knn/KnnTrainBatchOp.java ## @@ -0,0 +1,230 @@ +package

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: Flink 24557

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r747189344 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/algo/batch/knn/KnnTrainBatchOp.java ## @@ -0,0 +1,230 @@ +package