Google Git
Sign in
apache / flink-ml / HEAD
  1. 44f71f2 [FLINK-35066] Fix the unwrap from IterationRecord during keyBy by yunfengzhou-hub · 2 weeks ago master
  2. f08f275 [FLINK-33118] Remove the PythonBridgeUtils by JiangXin · 7 months ago
  3. 8654049 [FLINK-32704] Supports spilling to disk when feedback channel memory buffer is full by JiangXin · 8 months ago
  4. ebdf362 [FLINK-32810] Improve memory allocation in ListStateWithCache by Fan Hong · 8 months ago
  5. 5619c3b [FLINK-32889] Fix calcuation of weighted areaUnderROC and areaUnderPRC in BinaryClassificationEvaluator by Fan Hong · 8 months ago
  6. ba327b0 [FLINK-32545] Improves the performance by optimizing row operations by JiangXin · 9 months ago
  7. 892fb47 [FLINK-32335] Fix the ConcurrentModificationException in the unittest by JiangXin · 10 months ago
  8. fbd2a52 [hotfix] Update quick-start.md to correctly install Flink ML library jars by Dong Lin · 10 months ago
  9. b3a68e2 [hotfix] Update config.toml for Flink ML 2.3.0 release by Dong Lin · 10 months ago
  10. dcd7a67 [release] Update version to 2.4-SNAPSHOT by Dong Lin · 10 months ago
  11. 45cd465 [hotfix] Pin python 3.7 patch to 3.7.16 by jiangxin · 10 months ago
  12. 56c8de6 [hotfix] Deploy artifacts of each Flink version by jiangxin · 10 months ago
  13. 4122f8e [hotfix] Replace the sed command with perl to avoid different behaviors among different OS by jiangxin · 10 months ago
  14. bb13b73 [FLINK-32285] Support multiple Flink versions in each Flink ML Java library release by jiangxin · 11 months ago
  15. d38ce36 [FLINK-32285] Rename and copy flink-ml-iteration classes by jiangxin · 11 months ago
  16. 0b6b7f7 [FLINK-32292] Fix TableUtils.getRowTypeInfo when the input contains Tuple by Zhipeng Zhang · 11 months ago
  17. 6d69f0a [FLINK-31948] Supports triggering CI manually by JiangXin · 11 months ago
  18. 22e7885 [hotfix] Upgrade dependency to fix security vulnerabilities by Dong Lin · 11 months ago
  19. 84afd6a [hotfix] Update quickstart to require a given Flink version by Dong Lin · 11 months ago
  20. a5b7b49 [FLINK-31899] Upgrade Flink version of Flink ML to 1.17.0 by JiangXin · 12 months ago
  21. 5b193de [FLINK-31887] Upgrade Flink version of Flink ML to 1.16.1 by JiangXin · 1 year ago
  22. 92ecb0e [FLINK-31173] Fix wrong typeinfo in ProxyOperatorStateBackend by congzhou.zzp · 1 year ago
  23. 0c852da [FLINK-31173] TailOperator should have only one input by Zhangzp · 1 year ago
  24. a04a5ae [FLINK-31373] Fix NPE thrown in ProxyOutput by JiangXin · 1 year ago
  25. e843b30 [FLINK-31160] Support join/cogroup in BroadcastUtils.withBroadcastStream by Zhipeng Zhang · 1 year ago
  26. 8946854 [FLINK-31255] OperatorUtils#createWrappedOperatorConfig should update input and sideOutput serializers by JiangXin · 1 year ago
  27. cb376d7 [hotfix] Discard watermarks when feed a datastream into iteration body by Zhipeng Zhang · 1 year ago
  28. c50c3a0 [hotfix] update_branch_version.sh should update version in config.toml and build-your-own-project.md by Dong Lin · 1 year ago
  29. 2a59918 [FLINK-31325] Improve performance of Swing by vacaly · 1 year ago
  30. 987be33 [hotfix] Update pattern matching in test_ml_lib_completeness to work with release branch by Dong Lin · 1 year ago
  31. d7c9c8b [FLINK-31753] Support DataStream CoGroup in stream mode with similar performance as DataSet CoGroup by Dong Lin · 1 year, 1 month ago
  32. 990337b [FLINK-31374] ProxyStreamPartitioner should implement ConfigurableStreamPartitioner by JiangXin · 1 year, 1 month ago
  33. c06efde [hotfix] Update PreviousDocs in website by Dong Lin · 1 year, 1 month ago
  34. bbd7668 [release] Update version to 2.3-SNAPSHOT by Dong Lin · 1 year, 1 month ago
  35. fe338b1 [FLINK-31623] Fix DataStreamUtils#sample with approximate uniform sampling by Fan Hong · 1 year, 1 month ago
  36. 560532d [FLINK-31189] Add HasMaxIndexNum param to StringIndexer by Zhipeng Zhang · 1 year, 1 month ago
  37. 5dacbd9 [FLINK-31029] Fix bug when using quantile in KbinsDiscretizer by Zhipeng Zhang · 1 year, 1 month ago
  38. 1d1f686 [hotfix][doc] Update website doc to avoid space in feature engineering algorithm names by Dong Lin · 1 year, 1 month ago
  39. fa5f47e [FLINK-31486] Get the KeySelector with UserClassLoader by JiangXin · 1 year, 1 month ago
  40. adc1898 [FLINK-31422] Add Servable for Logistic Regression Model by jiangxin · 1 year, 1 month ago
  41. 6a92e36 [FLINK-31422] Move common params from flink-ml-lib to flink-ml-servable-lib by jiangxin · 1 year, 1 month ago
  42. 80fd4df [FLINK-30933] Fix missing max watermark when executing join in iteration body by Zhipeng Zhang · 1 year, 1 month ago
  43. c33bdc1 [FLINK-31453] Improve the test utils to call methods explicitly by JiangXin · 1 year, 1 month ago
  44. 7a4e5d1 [FLINK-31306] Add Servable for PipelineModel by JiangXin · 1 year, 1 month ago
  45. 10c0827 [FLINK-31191] Fix null pointer exception in VectorIndexer by Zhipeng Zhang · 1 year, 2 months ago
  46. f0c1ce7 Add public API classes for FLIP-289 by Dong Lin · 1 year, 2 months ago
  47. 546c25f [hotfix] Optimize Bucketizer performance by using column index to fetch values from input rows by Dong Lin · 1 year, 2 months ago
  48. 5bcbd01 [FLINK-31125] Flink ML benchmark framework should minimize the source operator overhead by Dong Lin · 1 year, 3 months ago
  49. b032ebd [FLINK-31126] Move classes not depending on Flink runtime from flink-ml-core to flink-ml-servable-core by Dong Lin · 1 year, 2 months ago
  50. 904aba2 [FLINK-30688][followup] Disable Kryo fallback for tests in flink-ml-lib by Dong Lin · 1 year, 2 months ago
  51. 0af95f2 [FLINK-31026] Fix KBinsDiscretizer when the input values of one column are same by Fan Hong · 1 year, 2 months ago
  52. e85fcf7 [FLINK-30451] Add AlgoOperator for Swing by vacaly · 1 year, 2 months ago
  53. 19f0f31 [FLINK-30688][followup] Disable Kryo fallback for tests in flink-ml-lib by JiangXin · 1 year, 3 months ago
  54. 76d5b86 [FLINK-27716] Add Flink ML Python API docs by JiangXin · 1 year, 3 months ago
  55. 80cedce [FLINK-30730][followup] Fix test failure in StringIndexerTest by Fan Hong · 1 year, 3 months ago
  56. 2b83d24 [FLINK-30730] Support null value in input for StringIndexer and StringIndexerModel by Fan Hong · 1 year, 3 months ago
  57. 3f62235 [FLINK-30865] Make pyflink-ml modules consistent with Flink ML Java library packages by JiangXin · 1 year, 3 months ago
  58. 7e26b7e [FLINK-30688] Disable Kryo fallback in Flink ML tests by JiangXin · 1 year, 3 months ago
  59. d5f2d39 [FLINK-30541] Add Transformer and Estimator for OnlineStandardScaler by Zhipeng Zhang · 1 year, 3 months ago
  60. 169aca4 [FLINK-30568] Add benchmark for PolyNomialExpansion, Normalizer, Binarizer, Interaction, MaxAbsScaler, VectorSlicer, ElementWiseProduct and Featurehasher by weibo · 1 year, 3 months ago
  61. 2822d44 [FLINK-30578][build] Publish SBOM for externalized connectors by Zsombor Chikan · 1 year, 3 months ago
  62. fc0b154 [FLINK-30566] Add benchmark for AgglomerativeClustering, HashingTF, IDF, KBinsDiscretizer, LinearRegression, LinearSVC, LogisticRegression, NGram, RegexTokenizer, Tokenizer and Vectorindexer by Zhipeng Zhang · 1 year, 4 months ago
  63. 48125b3 [FLINK-30401] Add Estimator and Transformer for MinHashLSH by Fan Hong · 1 year, 4 months ago
  64. 3bd19a2 [FLINK-30532] Add benchmark for DCT, SQLTransformer and StopWordsRemover by yunfengzhou-hub · 1 year, 4 months ago
  65. e4e2eca [hotfix] Add document for DCT algorithm by yunfengzhou-hub · 1 year, 4 months ago
  66. 6f8aa57 [FLINK-30348] Add HasSeed param for RandomSplitter by weibo · 1 year, 4 months ago
  67. 77aad8f [FLINK-30249] Fix TableUtils.getRowTypeInfo by using ExternalTypeInfo.of() by Zhipeng Zhang · 1 year, 4 months ago
  68. 5e4ab6e [FLINK-30515] Add benchmark for CountVectorizer, Imputer, RobustScaler, UnivariateFeatureSelector and VarianceThresholdSelector by JiangXin · 1 year, 4 months ago
  69. 71daebc [FLINK-30523] Fix the DataGenerator class of VectorAssembler benchmark by weibo · 1 year, 4 months ago
  70. f793ef1 [FLINK-29601] Add Estimator and Transformer for UnivariateFeatureSelector by JiangXin · 1 year, 4 months ago
  71. 82e2f18 [hotfix] Improve nightly build Github actions by Dong Lin · 1 year, 5 months ago
  72. 7360966 [FLINK-29911] Improve performance of AgglomerativeClustering by Zhipeng Zhang · 1 year, 5 months ago
  73. 2fbf793 [FLINK-29603] Add Transformer for StopWordsRemover (#183) by yunfengzhou-hub · 1 year, 5 months ago
  74. 2e4021e [hotfix] Add Python quickstart link in README by Dong Lin · 1 year, 5 months ago
  75. af3b42e [FLINK-30160] Add Transformer for FValueTest by JiangXin · 1 year, 5 months ago
  76. d19b76c [FLINK-30124] Support collecting model data with arrays and maps by yunfengzhou-hub · 1 year, 5 months ago
  77. 213e9e3 [FLINK-30037] Use shared mini-cluster in python tests by yunfengzhou-hub · 1 year, 5 months ago
  78. 7a4a2f5 [hotfix] Update python tests to set execution.attached=True by Dong Lin · 1 year, 5 months ago
  79. d6a5b42 [FLINK-30159] Add Transformer for ANOVATest by JiangXin · 1 year, 5 months ago
  80. 23d7646 [FLINK-29604] Add Estimator and Transformer for CountVectorizer by JiangXin · 1 year, 5 months ago
  81. 24eb3ec [FLINK-30144] Enable object reuse in Flink ML tests by yunfengzhou-hub · 1 year, 5 months ago
  82. 4939933 [FLINK-30099] Add test case for algorithms' python APIs by yunfengzhou-hub · 1 year, 5 months ago
  83. 76a0486 [FLINK-29602] Add Transformer for SQLTransformer by yunfengzhou-hub · 1 year, 5 months ago
  84. bc24667 [FLINK-30014][hotfix] Ensure saving non-null value in aggregate util function state by yunfengzhou-hub · 1 year, 5 months ago
  85. acf92f0 [FLINK-29592] Add Estimator and Transformer for RobustScaler by JiangXin · 1 year, 5 months ago
  86. ae5c011 [FLINK-29323] Add inputSizes parameter for VectorAssembler by weibo · 1 year, 6 months ago
  87. 0aad2f9 [FLINK-29434] Add AlgoOperator for RandomSplitter by weibo · 1 year, 6 months ago
  88. b96ce2f [FLINK-29598] Add Estimator and Transformer for Imputer (#166) by JiangXin · 1 year, 6 months ago
  89. aab8250 [FLINK-29843] Avoid negative euclidean distance square by yunfengzhou-hub · 1 year, 6 months ago
  90. 135763c [FLINK-29824] Stop clustering when size of the active clusters is one by Zhipeng Zhang · 1 year, 6 months ago
  91. 0c93277 [FLINK-29115] Improve quickstart documents by yunfengzhou-hub · 1 year, 6 months ago
  92. 3a9cabf [FLINK-29593] Add QuantileSummary to help calculate approximate quantiles by JiangXin · 1 year, 6 months ago
  93. 9af4e9d [FLINK-29786] VarianceThresholdSelector should implement HasInputCol by jiangxin · 1 year, 6 months ago
  94. fe2966d [FLINK-29591] Add built-in UDFs to convert between arrays and vectors by yunfengzhou-hub · 1 year, 6 months ago
  95. 7cbada7 [FLINK-28571] Improve API and Document of ChiSqTest by yunfengzhou-hub · 1 year, 7 months ago
  96. ebc80ce [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector by JiangXin · 1 year, 7 months ago
  97. 4a6ecde [FLINK-29318] Add Transformer for PolynomialExpansion by weibo · 1 year, 7 months ago
  98. 8a79231 [FLINK-29424] Add Pull Request Template by JiangXin · 1 year, 7 months ago
  99. b77aafa [FLINK-28906] Support windowing in AgglomerativeClustering by yunfengzhou-hub · 1 year, 7 months ago
  100. d224f56 [FLINK-28806] Add Transformer and Estimator for IDF by Zhipeng Zhang · 1 year, 8 months ago