Path	Lines of Code
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/BenchmarkTest.java	121
flink-ml-benchmark/src/test/java/org/apache/flink/ml/benchmark/DataGeneratorTest.java	176
flink-ml-core/src/test/java/org/apache/flink/ml/api/ExampleStages.java	189
flink-ml-core/src/test/java/org/apache/flink/ml/api/GraphTest.java	181
flink-ml-core/src/test/java/org/apache/flink/ml/api/PipelineTest.java	114
flink-ml-core/src/test/java/org/apache/flink/ml/api/ServableTest.java	67
flink-ml-core/src/test/java/org/apache/flink/ml/api/StageTest.java	478
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/BroadcastUtilsTest.java	193
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/TestSink.java	50
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/TestSource.java	65
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastVariableReceiverOperatorTest.java	100
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/BroadcastWrapperOperatorFactory.java	23
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/OneInputBroadcastWrapperOperatorTest.java	69
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestOneInputOp.java	28
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TestTwoInputOp.java	35
flink-ml-core/src/test/java/org/apache/flink/ml/common/broadcast/operator/TwoInputBroadcastWrapperOperatorTest.java	69
flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/AllReduceImplTest.java	136
flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/DataStreamUtilsTest.java	219
flink-ml-core/src/test/java/org/apache/flink/ml/common/datastream/TableUtilsTest.java	128
flink-ml-core/src/test/java/org/apache/flink/ml/common/window/WindowsTest.java	161
flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java	46
flink-ml-core/src/test/java/org/apache/flink/ml/util/TestUtils.java	250
flink-ml-iteration/flink-ml-iteration-1.15/src/test/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinatorTest.java	96
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/IterationConstructionTest.java	361
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/broadcast/BroadcastOutputTest.java	178
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/compile/AllRoundDraftExecutionEnvironmentTest.java	92
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/compile/DraftExecutionEnvironmentSwitchWrapperTest.java	136
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/compile/DraftExecutionEnvironmentTestBase.java	259
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheSnapshotTest.java	155
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/datacache/nonkeyed/DataCacheWriteReadTest.java	199
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/HeadOperatorTest.java	808
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/InputOperatorTest.java	23
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/OutputOperatorTest.java	27
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/ReplayOperatorTest.java	282
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/TailOperatorTest.java	71
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/allround/LifeCycle.java	19
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/allround/MultipleInputAllRoundWrapperOperatorTest.java	222
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/allround/OneInputAllRoundWrapperOperatorTest.java	242
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/allround/TwoInputAllRoundWrapperOperatorTest.java	195
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/coordinator/HeadOperatorCoordinatorTest.java	97
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/coordinator/SharedProgressAlignerTest.java	206
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/perround/MultipleInputPerRoundWrapperOperatorTest.java	236
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/perround/OneInputPerRoundWrapperOperatorTest.java	343
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/perround/PerRoundOperatorStateTest.java	209
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/operator/perround/TwoInputPerRoundWrapperOperatorTest.java	211
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerFactoryTest.java	212
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/progresstrack/OperatorEpochWatermarkTrackerTest.java	74
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/typeinfo/IterationRecordSerializerTest.java	57
flink-ml-iteration/flink-ml-iteration-common/src/test/java/org/apache/flink/iteration/utils/ReflectionUtilsTest.java	54
flink-ml-lib/src/test/java/org/apache/flink/ml/FunctionsTest.java	90
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/KnnTest.java	217
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/LinearSVCTest.java	282
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/LogisticRegressionTest.java	377
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/NaiveBayesTest.java	243
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/OnlineLogisticRegressionTest.java	596
flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/AgglomerativeClusteringTest.java	368
flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java	213
flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java	453
flink-ml-lib/src/test/java/org/apache/flink/ml/common/lossfunc/BinaryLogisticLossTest.java	28
flink-ml-lib/src/test/java/org/apache/flink/ml/common/lossfunc/HingeLossTest.java	30
flink-ml-lib/src/test/java/org/apache/flink/ml/common/lossfunc/LeastSquareLossTest.java	26
flink-ml-lib/src/test/java/org/apache/flink/ml/common/optimizer/RegularizationUtilsTest.java	22
flink-ml-lib/src/test/java/org/apache/flink/ml/common/typeinfo/PriorityQueueSerializerTest.java	48
flink-ml-lib/src/test/java/org/apache/flink/ml/common/typeinfo/QuantileSummaryTypeInfoFactoryTest.java	47
flink-ml-lib/src/test/java/org/apache/flink/ml/common/util/QuantileSummaryTest.java	142
flink-ml-lib/src/test/java/org/apache/flink/ml/common/util/VectorUtilsTest.java	23
flink-ml-lib/src/test/java/org/apache/flink/ml/evaluation/BinaryClassificationEvaluatorTest.java	297
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/BinarizerTest.java	115
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/BucketizerTest.java	166
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/CountVectorizerTest.java	344
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/DCTTest.java	129
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/ElementwiseProductTest.java	169
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/FeatureHasherTest.java	119
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/HashingTFTest.java	138
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/IDFTest.java	160
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/ImputerTest.java	316
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/InteractionTest.java	127
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/KBinsDiscretizerTest.java	241
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MaxAbsScalerTest.java	200
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MinHashLSHTest.java	387
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MinMaxScalerTest.java	184
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/NGramTest.java	88
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/NormalizerTest.java	142
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/OneHotEncoderTest.java	236
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/OnlineStandardScalerTest.java	358
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/PolynomialExpansionTest.java	148
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/RandomSplitterTest.java	120
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/RegexTokenizerTest.java	147
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/RobustScalerTest.java	299
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/SQLTransformerTest.java	153
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/StandardScalerTest.java	225
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/StopWordsRemoverTest.java	404
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/TokenizerTest.java	86
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/UnivariateFeatureSelectorTest.java	726
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VarianceThresholdSelectorTest.java	223
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VectorAssemblerTest.java	355
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VectorIndexerTest.java	230
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VectorSlicerTest.java	178
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/stringindexer/IndexToStringModelTest.java	130
flink-ml-lib/src/test/java/org/apache/flink/ml/feature/stringindexer/StringIndexerTest.java	361
flink-ml-lib/src/test/java/org/apache/flink/ml/recommendation/SwingTest.java	204
flink-ml-lib/src/test/java/org/apache/flink/ml/regression/LinearRegressionTest.java	234
flink-ml-lib/src/test/java/org/apache/flink/ml/stats/ANOVATestTest.java	354
flink-ml-lib/src/test/java/org/apache/flink/ml/stats/ChiSqTestTest.java	150
flink-ml-lib/src/test/java/org/apache/flink/ml/stats/FValueTestTest.java	375
flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySinkFunction.java	54
flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySourceFunction.java	55
flink-ml-lib/src/test/java/org/apache/flink/ml/util/StageAnalyzer.java	84
flink-ml-python/pyflink/ml/classification/tests/__init__.py	7
flink-ml-python/pyflink/ml/classification/tests/test_knn.py	144
flink-ml-python/pyflink/ml/classification/tests/test_linearsvc.py	143
flink-ml-python/pyflink/ml/classification/tests/test_logisticregression.py	168
flink-ml-python/pyflink/ml/classification/tests/test_naivebayes.py	118
flink-ml-python/pyflink/ml/clustering/tests/__init__.py	7
flink-ml-python/pyflink/ml/clustering/tests/test_agglomerativeclustering.py	241
flink-ml-python/pyflink/ml/clustering/tests/test_kmeans.py	189
flink-ml-python/pyflink/ml/evaluation/tests/__init__.py	7
flink-ml-python/pyflink/ml/evaluation/tests/tests_binaryclassification.py	174
flink-ml-python/pyflink/ml/feature/tests/__init__.py	7
flink-ml-python/pyflink/ml/feature/tests/test_binarizer.py	64
flink-ml-python/pyflink/ml/feature/tests/test_bucketizer.py	87
flink-ml-python/pyflink/ml/feature/tests/test_countvectorizer.py	112
flink-ml-python/pyflink/ml/feature/tests/test_dct.py	59
flink-ml-python/pyflink/ml/feature/tests/test_elementwiseproduct.py	52
flink-ml-python/pyflink/ml/feature/tests/test_feature_hasher.py	48
flink-ml-python/pyflink/ml/feature/tests/test_hashingtf.py	78
flink-ml-python/pyflink/ml/feature/tests/test_idf.py	111
flink-ml-python/pyflink/ml/feature/tests/test_imputer.py	139
flink-ml-python/pyflink/ml/feature/tests/test_indextostringmodel.py	71
flink-ml-python/pyflink/ml/feature/tests/test_interaction.py	50
flink-ml-python/pyflink/ml/feature/tests/test_kbinsdiscretizer.py	151
flink-ml-python/pyflink/ml/feature/tests/test_maxabsscaler.py	106
flink-ml-python/pyflink/ml/feature/tests/test_minhashlsh.py	231
flink-ml-python/pyflink/ml/feature/tests/test_minmaxscaler.py	141
flink-ml-python/pyflink/ml/feature/tests/test_ngram.py	62
flink-ml-python/pyflink/ml/feature/tests/test_normalizer.py	58
flink-ml-python/pyflink/ml/feature/tests/test_onehotencoder.py	120
flink-ml-python/pyflink/ml/feature/tests/test_onlinestandardscaler.py	157
flink-ml-python/pyflink/ml/feature/tests/test_polynomialexpansion.py	45
flink-ml-python/pyflink/ml/feature/tests/test_randomsplitter.py	49
flink-ml-python/pyflink/ml/feature/tests/test_regextokenizer.py	64
flink-ml-python/pyflink/ml/feature/tests/test_robustscaler.py	128
flink-ml-python/pyflink/ml/feature/tests/test_sqltransformer.py	40
flink-ml-python/pyflink/ml/feature/tests/test_standardscaler.py	130
flink-ml-python/pyflink/ml/feature/tests/test_stopwordsremover.py	81
flink-ml-python/pyflink/ml/feature/tests/test_stringindexer.py	153
flink-ml-python/pyflink/ml/feature/tests/test_tokenizer.py	50
flink-ml-python/pyflink/ml/feature/tests/test_univariatefeatureselector.py	169
flink-ml-python/pyflink/ml/feature/tests/test_variancethresholdselector.py	136
flink-ml-python/pyflink/ml/feature/tests/test_vectorassembler.py	54
flink-ml-python/pyflink/ml/feature/tests/test_vectorindexer.py	91
flink-ml-python/pyflink/ml/feature/tests/test_vectorslicer.py	45
flink-ml-python/pyflink/ml/recommendation/tests/__init__.py	7
flink-ml-python/pyflink/ml/recommendation/tests/test_swing.py	130
flink-ml-python/pyflink/ml/regression/tests/__init__.py	7
flink-ml-python/pyflink/ml/regression/tests/test_linearregression.py	120
flink-ml-python/pyflink/ml/stats/tests/__init__.py	7
flink-ml-python/pyflink/ml/stats/tests/test_chisqtest.py	75
flink-ml-python/pyflink/ml/tests/__init__.py	7
flink-ml-python/pyflink/ml/tests/test_functions.py	74
flink-ml-python/pyflink/ml/tests/test_linalg.py	67
flink-ml-python/pyflink/ml/tests/test_ml_lib_completeness.py	113
flink-ml-python/pyflink/ml/tests/test_param.py	204
flink-ml-python/pyflink/ml/tests/test_pipeline.py	57
flink-ml-python/pyflink/ml/tests/test_stage.py	210
flink-ml-python/pyflink/ml/tests/test_utils.py	82
flink-ml-servable-core/src/test/java/org/apache/flink/ml/common/distance/DistanceMeasureTest.java	52
flink-ml-servable-core/src/test/java/org/apache/flink/ml/linalg/BLASTest.java	104
flink-ml-servable-core/src/test/java/org/apache/flink/ml/linalg/DenseVectorTest.java	23
flink-ml-servable-core/src/test/java/org/apache/flink/ml/linalg/SparseVectorTest.java	118
flink-ml-servable-core/src/test/java/org/apache/flink/ml/linalg/VectorWithNormTest.java	16
flink-ml-servable-core/src/test/java/org/apache/flink/ml/servable/TestUtils.java	20
flink-ml-servable-core/src/test/java/org/apache/flink/ml/servable/builder/ExampleServables.java	72
flink-ml-servable-core/src/test/java/org/apache/flink/ml/servable/builder/PipelineModelServableTest.java	47
flink-ml-tests/pom.xml	45
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/BoundedAllRoundCheckpointITCase.java	140
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/BoundedAllRoundStreamIterationITCase.java	280
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/BoundedMixedLifeCycleStreamIterationITCase.java	151
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/BoundedPerRoundCheckpointITCase.java	157
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/BoundedPerRoundStreamIterationITCase.java	279
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/UnboundedStreamIterationITCase.java	294
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/CollectSink.java	14
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/EpochRecord.java	22
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/FailingMap.java	19
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/IncrementEpochMap.java	8
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/OutputRecord.java	39
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/ReduceAllRoundProcessFunction.java	121
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/SequenceSource.java	57
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/StatefulProcessFunction.java	25
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/TwoInputReduceAllRoundProcessFunction.java	59
flink-ml-tests/src/test/java/org/apache/flink/test/iteration/operators/TwoInputReducePerRoundOperator.java	54