Path Lines of Code hudi-aws/src/test/java/org/apache/hudi/aws/TestHoodieAWSCredentialsProviderFactory.java 33 hudi-aws/src/test/java/org/apache/hudi/aws/cloudwatch/TestCloudWatchReporter.java 134 hudi-aws/src/test/java/org/apache/hudi/aws/sync/ITTestGluePartitionPushdown.java 106 hudi-aws/src/test/java/org/apache/hudi/aws/sync/TestGluePartitionPushdown.java 100 hudi-aws/src/test/java/org/apache/hudi/aws/transaction/integ/ITTestDynamoDBBasedLockProvider.java 86 hudi-cli/src/test/java/org/apache/hudi/cli/TestSparkUtil.java 21 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestArchiveCommand.java 38 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestArchivedCommitsCommand.java 147 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCleansCommand.java 136 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCommitsCommand.java 422 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCompactionCommand.java 160 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestDiffCommand.java 109 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestFileSystemViewCommand.java 250 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestHoodieLogFileCommand.java 207 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestMetadataCommand.java 73 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestRepairsCommand.java 323 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestRestoresCommand.java 161 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestRollbacksCommand.java 156 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestSavepointsCommand.java 69 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestSparkEnvCommand.java 32 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestStatsCommand.java 135 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestTableCommand.java 207 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestTempViewCommand.java 66 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestUpgradeDowngradeCommand.java 122 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestUtilsCommand.java 46 hudi-cli/src/test/java/org/apache/hudi/cli/functional/CLIFunctionalTestHarness.java 95 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestBootstrapCommand.java 77 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestClusteringCommand.java 129 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestCommitsCommand.java 96 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestCompactionCommand.java 218 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestHDFSParquetImportCommand.java 128 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestMarkersCommand.java 42 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestRepairsCommand.java 234 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestSavepointsCommand.java 130 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestTableCommand.java 152 hudi-cli/src/test/java/org/apache/hudi/cli/testutils/HoodieCLIIntegrationTestBase.java 19 hudi-cli/src/test/java/org/apache/hudi/cli/testutils/HoodieCLIIntegrationTestHarness.java 17 hudi-cli/src/test/java/org/apache/hudi/cli/testutils/HoodieTestCommitMetadataGenerator.java 134 hudi-cli/src/test/java/org/apache/hudi/cli/testutils/HoodieTestCommitUtilities.java 20 hudi-cli/src/test/java/org/apache/hudi/cli/testutils/HoodieTestReplaceCommitMetadataGenerator.java 64 hudi-cli/src/test/java/org/apache/hudi/cli/testutils/MockCommandLineInput.java 36 hudi-cli/src/test/java/org/apache/hudi/cli/testutils/ShellEvaluationResultUtil.java 15 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/ClientFunctionalTestSuite.java 10 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/DummyActiveAction.java 19 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/DummyTaskContextSupplier.java 27 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/HoodieTestCommitGenerator.java 172 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/async/TestAsyncArchiveService.java 46 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/async/TestHoodieAsyncTableService.java 30 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/avro/TestHoodieAvroParquetWriter.java 76 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/callback/http/TestCallbackHttpClient.java 98 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/embedded/TestEmbeddedTimelineService.java 142 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/heartbeat/TestHoodieHeartbeatClient.java 73 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/timeline/TestCompletionTimeQueryView.java 115 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/FileSystemBasedLockProviderTestClass.java 83 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/InProcessLockProviderWithRuntimeError.java 20 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestBucketIndexConcurrentFileWritesConflictResolutionStrategy.java 127 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestConflictResolutionStrategyUtil.java 234 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestLockManager.java 88 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestPreferWriterConflictResolutionStrategy.java 170 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestSimpleConcurrentFileWritesConflictResolutionStrategy.java 295 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestTransactionManager.java 199 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestZookeeperBasedLockProvider.java 97 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/utils/TestDeletePartitionUtils.java 75 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/utils/TestFileSliceMetricUtils.java 80 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/utils/TestLegacyArchivedMetaEntryReader.java 114 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/common/table/timeline/TestHoodieArchivedTimeline.java 67 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/common/testutils/HoodieMetadataTestTable.java 133 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/config/TestHoodieWriteConfig.java 523 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/index/TestHoodieIndexUtils.java 45 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/index/bucket/TestBucketIdentifier.java 94 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/index/bucket/TestConsistentBucketIdIdentifier.java 178 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/keygen/RawTripTestPayloadKeyGenerator.java 16 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/keygen/TestComplexAvroKeyGenerator.java 62 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/keygen/TestKeyGenUtils.java 55 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/keygen/factory/TestCreateAvroKeyGeneratorByTypeWithFactory.java 87 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/keygen/factory/TestHoodieAvroKeyGeneratorFactory.java 41 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metadata/TestHoodieMetadataWriteUtils.java 36 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestHoodieConsoleMetrics.java 36 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestHoodieGraphiteMetrics.java 37 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestHoodieJmxMetrics.java 46 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestHoodieMetrics.java 148 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestMetricsReporterFactory.java 59 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/cloudwatch/TestCloudWatchMetricsReporter.java 32 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/datadog/TestDatadogHttpClient.java 128 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/datadog/TestDatadogMetricsReporter.java 79 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/datadog/TestDatadogReporter.java 84 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/datadog/TestHoodieMetricsDatadogConfig.java 14 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/m3/TestM3Metrics.java 66 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/prometheus/TestPrometheusReporter.java 39 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/prometheus/TestPushGateWayReporter.java 123 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/optimize/TestHilbertCurveUtils.java 14 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/TestBulkInsertPartitioner.java 32 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/TestCleanPlanner.java 487 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/cluster/strategy/TestPartitionAwareClusteringPlanStrategy.java 64 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/commit/TestWriterHelperBase.java 56 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/index/TestIndexingCatchupTask.java 114 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/cluster/strategy/TestClusteringPlanStrategyConfigCompatibility.java 38 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/marker/TestWriteMarkersFactory.java 83 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/repair/TestRepairUtils.java 139 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/upgrade/TestTwoToThreeUpgradeHandler.java 54 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/Assertions.java 17 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/GenericRecordValidationTestUtils.java 122 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java 171 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieWriteableTestTable.java 155 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/MetadataMergeWriteStatus.java 51 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/providers/DFSProvider.java 9 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/providers/HoodieEngineContextProvider.java 5 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/providers/HoodieMetaClientProvider.java 28 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/providers/HoodieWriteClientProvider.java 7 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/utils/HoodieWriterClientTestHarness.java 147 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/utils/TestConcatenatingIterator.java 37 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/utils/TestMetadataConversionUtils.java 337 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/client/TestFlinkWriteClient.java 34 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/client/common/TestHoodieFlinkEngineContext.java 55 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/index/bloom/TestFlinkHoodieBloomIndex.java 356 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/io/storage/row/parquet/TestParquetSchemaConverter.java 66 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/table/action/cluster/strategy/TestFlinkSizeBasedClusteringPlanStrategy.java 66 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/testutils/HoodieFlinkClientTestHarness.java 108 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/testutils/HoodieFlinkWriteableTestTable.java 111 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/TestHoodieJavaWriteClientInsert.java 195 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/TestJavaHoodieBackedMetadata.java 2070 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/common/TestHoodieJavaEngineContext.java 52 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/functional/TestHoodieJavaClientOnCopyOnWriteStorage.java 1226 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/functional/TestHoodieJavaClientOnMergeOnReadStorage.java 109 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/execution/bulkinsert/TestJavaBulkInsertInternalPartitioner.java 72 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/table/action/commit/TestJavaCopyOnWriteActionExecutor.java 423 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/table/action/commit/TestSchemaEvolutionClient.java 62 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/testutils/HoodieJavaClientTestHarness.java 710 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/testutils/TestHoodieMetadataBase.java 252 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/callback/TestHoodieClientInitCallback.java 179 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestClientRollback.java 621 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestCompactionAdminClient.java 192 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestFileBasedLockProvider.java 81 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieClientMultiWriter.java 800 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieReadClient.java 133 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestMultiFS.java 120 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestMultiWriterWithPreferWriterIngestion.java 211 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestPartitionTTLManagement.java 137 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestSavepoint.java 126 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestSimpleTransactionDirectMarkerBasedDetectionStrategyWithZKLockProvider.java 117 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestSparkHoodieMetadataBulkInsertPartitioner.java 67 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestSparkRDDWriteClient.java 156 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestTableSchemaEvolution.java 287 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestUpdateSchemaEvolution.java 197 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestWriteStatus.java 164 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/bootstrap/TestBootstrapRegexModeSelector.java 48 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/bootstrap/TestUniformBootstrapModeSelector.java 40 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/clustering/plan/strategy/TestSparkConsistentBucketClusteringPlanStrategy.java 154 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/clustering/plan/strategy/TestSparkSizeBasedClusteringPlanStrategy.java 59 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/common/TestHoodieSparkEngineContext.java 24 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestConsistentBucketIndex.java 236 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestDataValidationCheckForLogCompactionActions.java 313 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestExternalPathHandling.java 240 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieBackedMetadata.java 2686 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieBackedTableMetadata.java 382 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnCopyOnWriteStorage.java 2261 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnMergeOnReadStorage.java 404 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieIndex.java 526 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieMetadataBase.java 281 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieMetadataBootstrap.java 231 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestRemoteFileSystemViewWithMetadataTable.java 251 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestSavepointRestoreCopyOnWrite.java 107 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestSavepointRestoreMergeOnRead.java 240 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/model/TestHoodieInternalRow.java 229 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/common/fs/NonSerializableFileSystem.java 77 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/common/fs/TestHoodieSerializableFileStatus.java 56 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/data/TestHoodieJavaRDD.java 16 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/TestBoundedInMemoryExecutorInSpark.java 133 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/TestBoundedInMemoryQueue.java 247 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/TestDisruptorExecutionInSpark.java 107 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/TestDisruptorMessageQueue.java 239 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/TestSimpleExecutionInSpark.java 165 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/bulkinsert/TestBulkInsertInternalPartitioner.java 206 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/bulkinsert/TestRDDSimpleBucketBulkInsertPartitioner.java 99 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/functional/SparkClientFunctionalTestSuite.java 13 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/TestHoodieIndexConfigs.java 110 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestBloomIndexTagWithColStats.java 117 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestBucketizedBloomCheckPartitioner.java 73 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestHoodieBloomIndex.java 564 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestHoodieGlobalBloomIndex.java 263 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestKeyRangeLookupTree.java 115 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bucket/TestHoodieSimpleBucketIndex.java 131 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/functional/TestHoodieSparkFunctionalIndex.java 81 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestHBaseIndexUsage.java 16 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestHBasePutBatchSizeCalculator.java 22 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestHBaseQPSResourceAllocator.java 68 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/hbase/TestSparkHoodieHBaseIndex.java 665 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieKeyLocationFetchHandle.java 136 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieMergeHandle.java 254 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieMergedReadHandle.java 184 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieTimelineArchiver.java 1381 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestSparkIOUtils.java 35 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/storage/TestHoodieAvroFileWriterFactory.java 68 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/TestCleaner.java 973 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/TestConsistencyGuard.java 133 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/TestHoodieMergeOnReadTable.java 514 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/bootstrap/TestBootstrapUtils.java 49 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/clean/TestCleanerInsertAndCleanByCommits.java 185 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/clean/TestCleanerInsertAndCleanByVersions.java 165 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/cluster/ClusteringTestUtils.java 103 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/cluster/strategy/TestSparkBuildClusteringGroupsForPartition.java 94 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/cluster/strategy/TestSparkClusteringPlanPartitionFilter.java 103 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/commit/TestCopyOnWriteActionExecutor.java 433 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/commit/TestSparkWriteHelper.java 45 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/commit/TestUpsertPartitioner.java 364 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/CompactionTestBase.java 221 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/TestAsyncCompaction.java 301 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/TestHoodieCompactor.java 228 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/TestInlineCompaction.java 251 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/strategy/TestHoodieCompactionStrategy.java 313 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/rollback/HoodieClientRollbackTestBase.java 109 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/rollback/TestCopyOnWriteRollbackActionExecutor.java 348 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/rollback/TestMergeOnReadRollbackActionExecutor.java 281 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/rollback/TestRollbackUtils.java 88 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestCleanPlanExecutor.java 554 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkCopyOnWriteTableArchiveWithReplace.java 69 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableCompaction.java 157 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableIncrementalRead.java 183 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableInsertUpdateDelete.java 337 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableRollback.java 697 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestMarkerBasedRollbackStrategy.java 208 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestSparkNonBlockingConcurrencyControl.java 343 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestDirectWriteMarkers.java 52 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestTimelineServerBasedWriteMarkers.java 94 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestWriteMarkersBase.java 102 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/upgrade/TestUpgradeDowngrade.java 707 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/FunctionalTestHarness.java 147 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieCleanerTestBase.java 181 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieClientTestBase.java 368 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieClientTestUtils.java 243 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieSparkClientTestHarness.java 472 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieSparkWriteableTestTable.java 107 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/SparkClientFunctionalTestHarness.java 324 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/providers/SparkProvider.java 31 hudi-client/hudi-spark-client/src/test/java/org/apache/spark/sql/hudi/execution/TestRangeSampleSort.java 32 hudi-client/hudi-spark-client/src/test/scala/org/apache/spark/sql/TestHoodieUnsafeRowUtils.scala 122 hudi-common/src/test/java/org/apache/hudi/avro/TestAvroSchemaUtils.java 198 hudi-common/src/test/java/org/apache/hudi/avro/TestHoodieAvroUtils.java 541 hudi-common/src/test/java/org/apache/hudi/avro/TestMercifulJsonConverter.java 71 hudi-common/src/test/java/org/apache/hudi/client/transaction/lock/TestInProcessLockProvider.java 406 hudi-common/src/test/java/org/apache/hudi/common/TestRegistry.java 44 hudi-common/src/test/java/org/apache/hudi/common/bloom/TestBloomFilter.java 131 hudi-common/src/test/java/org/apache/hudi/common/bloom/TestInternalDynamicBloomFilter.java 34 hudi-common/src/test/java/org/apache/hudi/common/bootstrap/TestBootstrapIndex.java 167 hudi-common/src/test/java/org/apache/hudi/common/config/HoodieTestFakeConfig.java 57 hudi-common/src/test/java/org/apache/hudi/common/config/TestConfigProperty.java 148 hudi-common/src/test/java/org/apache/hudi/common/config/TestHoodieConfig.java 34 hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListData.java 59 hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListDataPairData.java 211 hudi-common/src/test/java/org/apache/hudi/common/fs/TestFSUtils.java 475 hudi-common/src/test/java/org/apache/hudi/common/fs/TestFSUtilsWithRetryWrapperEnable.java 191 hudi-common/src/test/java/org/apache/hudi/common/fs/TestHoodieWrapperFileSystem.java 54 hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java 54 hudi-common/src/test/java/org/apache/hudi/common/fs/inline/InLineFSUtilsTest.java 33 hudi-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystem.java 310 hudi-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystemHFileInLiningBase.java 127 hudi-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystemWithHBaseHFileReader.java 90 hudi-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystemWithHFileReader.java 73 hudi-common/src/test/java/org/apache/hudi/common/fs/inline/TestInMemoryFileSystem.java 92 hudi-common/src/test/java/org/apache/hudi/common/fs/inline/TestParquetInLining.java 107 hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java 2413 hudi-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormatAppendFailure.java 105 hudi-common/src/test/java/org/apache/hudi/common/model/TestAWSDmsAvroPayload.java 104 hudi-common/src/test/java/org/apache/hudi/common/model/TestDefaultHoodieRecordPayload.java 198 hudi-common/src/test/java/org/apache/hudi/common/model/TestFileSlice.java 22 hudi-common/src/test/java/org/apache/hudi/common/model/TestFirstValueAvroPayload.java 51 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieBaseFile.java 66 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieCommitMetadata.java 68 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieConsistentHashingMetadata.java 10 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieDeltaWriteStat.java 46 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieFileGroup.java 114 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieLSMTimelineManifest.java 28 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieLogFile.java 62 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodiePartitionMetadata.java 65 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieRecord.java 42 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieRecordDelegate.java 58 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieReplaceCommitMetadata.java 21 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieWriteStat.java 31 hudi-common/src/test/java/org/apache/hudi/common/model/TestOverwriteNonDefaultsWithLatestAvroPayload.java 161 hudi-common/src/test/java/org/apache/hudi/common/model/TestOverwriteWithLatestAvroPayload.java 65 hudi-common/src/test/java/org/apache/hudi/common/model/TestPartialUpdateAvroPayload.java 214 hudi-common/src/test/java/org/apache/hudi/common/model/debezium/TestMySqlDebeziumAvroPayload.java 123 hudi-common/src/test/java/org/apache/hudi/common/model/debezium/TestPostgresDebeziumAvroPayload.java 179 hudi-common/src/test/java/org/apache/hudi/common/properties/TestOrderedProperties.java 49 hudi-common/src/test/java/org/apache/hudi/common/properties/TestTypedProperties.java 71 hudi-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableConfig.java 150 hudi-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableMetaClient.java 90 hudi-common/src/test/java/org/apache/hudi/common/table/TestTableSchemaResolver.java 34 hudi-common/src/test/java/org/apache/hudi/common/table/TestTimelineUtils.java 541 hudi-common/src/test/java/org/apache/hudi/common/table/log/TestHoodieLogFormatVersion.java 51 hudi-common/src/test/java/org/apache/hudi/common/table/log/TestLogReaderUtils.java 62 hudi-common/src/test/java/org/apache/hudi/common/table/log/block/TestHoodieDeleteBlock.java 116 hudi-common/src/test/java/org/apache/hudi/common/table/read/TestCustomMerger.java 164 hudi-common/src/test/java/org/apache/hudi/common/table/read/TestEventTimeMerging.java 114 hudi-common/src/test/java/org/apache/hudi/common/table/read/TestHoodieFileGroupReaderBase.java 147 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/TestHoodieActiveTimeline.java 574 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/TestHoodieInstant.java 66 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/TestLSMTimeline.java 29 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/TestTimelineLayout.java 53 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/TestWaitBasedTimeGenerator.java 91 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestHoodieTableFSViewWithClustering.java 145 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestHoodieTableFileSystemView.java 1828 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestIncrementalFSViewSync.java 677 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestPriorityBasedFileSystemView.java 608 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDBBasedIncrementalFSViewSync.java 14 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDbBasedFileSystemView.java 12 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestSpillableMapBasedFileSystemView.java 11 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestSpillableMapBasedIncrementalFSViewSync.java 12 hudi-common/src/test/java/org/apache/hudi/common/testutils/Assertions.java 15 hudi-common/src/test/java/org/apache/hudi/common/testutils/AvroBinaryTestPayload.java 30 hudi-common/src/test/java/org/apache/hudi/common/testutils/CheckedFunction.java 5 hudi-common/src/test/java/org/apache/hudi/common/testutils/CompactionTestUtils.java 177 hudi-common/src/test/java/org/apache/hudi/common/testutils/FileCreateUtils.java 425 hudi-common/src/test/java/org/apache/hudi/common/testutils/FileSystemTestUtils.java 70 hudi-common/src/test/java/org/apache/hudi/common/testutils/HadoopMapRedUtils.java 50 hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieAdaptablePayloadDataGenerator.java 229 hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarness.java 88 hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestDataGenerator.java 796 hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestTable.java 1135 hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestUtils.java 229 hudi-common/src/test/java/org/apache/hudi/common/testutils/InProcessTimeGenerator.java 16 hudi-common/src/test/java/org/apache/hudi/common/testutils/MockHoodieTimeline.java 22 hudi-common/src/test/java/org/apache/hudi/common/testutils/NetworkTestUtils.java 13 hudi-common/src/test/java/org/apache/hudi/common/testutils/PreCombineTestUtils.java 28 hudi-common/src/test/java/org/apache/hudi/common/testutils/RawTripTestPayload.java 204 hudi-common/src/test/java/org/apache/hudi/common/testutils/SampleTestRecord.java 75 hudi-common/src/test/java/org/apache/hudi/common/testutils/SchemaTestUtil.java 313 hudi-common/src/test/java/org/apache/hudi/common/testutils/SpillableMapTestUtils.java 33 hudi-common/src/test/java/org/apache/hudi/common/testutils/Transformations.java 46 hudi-common/src/test/java/org/apache/hudi/common/testutils/minicluster/HdfsTestService.java 80 hudi-common/src/test/java/org/apache/hudi/common/testutils/minicluster/ZookeeperTestService.java 160 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/DataGenerationPlan.java 78 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieAvroRecordTestMerger.java 51 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieFileGroupReaderTestHarness.java 86 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieFileGroupReaderTestUtils.java 102 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieFileSliceTestUtils.java 373 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieRecordTestPayload.java 134 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieTestReaderContext.java 180 hudi-common/src/test/java/org/apache/hudi/common/util/TestAvroOrcUtils.java 45 hudi-common/src/test/java/org/apache/hudi/common/util/TestBase64CodecUtil.java 22 hudi-common/src/test/java/org/apache/hudi/common/util/TestBinaryUtil.java 106 hudi-common/src/test/java/org/apache/hudi/common/util/TestClusteringUtils.java 215 hudi-common/src/test/java/org/apache/hudi/common/util/TestCollectionUtils.java 28 hudi-common/src/test/java/org/apache/hudi/common/util/TestCommitUtils.java 169 hudi-common/src/test/java/org/apache/hudi/common/util/TestCompactionUtils.java 286 hudi-common/src/test/java/org/apache/hudi/common/util/TestConfigUtils.java 70 hudi-common/src/test/java/org/apache/hudi/common/util/TestCustomizedThreadFactory.java 59 hudi-common/src/test/java/org/apache/hudi/common/util/TestDFSPropertiesConfiguration.java 155 hudi-common/src/test/java/org/apache/hudi/common/util/TestDateTimeUtils.java 29 hudi-common/src/test/java/org/apache/hudi/common/util/TestFileIOUtils.java 83 hudi-common/src/test/java/org/apache/hudi/common/util/TestHoodieRecordUtils.java 31 hudi-common/src/test/java/org/apache/hudi/common/util/TestMapUtils.java 42 hudi-common/src/test/java/org/apache/hudi/common/util/TestMarkerUtils.java 54 hudi-common/src/test/java/org/apache/hudi/common/util/TestNumericUtils.java 39 hudi-common/src/test/java/org/apache/hudi/common/util/TestObjectSizeCalculator.java 83 hudi-common/src/test/java/org/apache/hudi/common/util/TestOrcReaderIterator.java 67 hudi-common/src/test/java/org/apache/hudi/common/util/TestParquetReaderIterator.java 36 hudi-common/src/test/java/org/apache/hudi/common/util/TestParquetUtils.java 208 hudi-common/src/test/java/org/apache/hudi/common/util/TestRatelimiter.java 25 hudi-common/src/test/java/org/apache/hudi/common/util/TestReflectionUtils.java 19 hudi-common/src/test/java/org/apache/hudi/common/util/TestRetryHelper.java 23 hudi-common/src/test/java/org/apache/hudi/common/util/TestSerializableSchema.java 56 hudi-common/src/test/java/org/apache/hudi/common/util/TestSerializationUtils.java 77 hudi-common/src/test/java/org/apache/hudi/common/util/TestStringUtils.java 83 hudi-common/src/test/java/org/apache/hudi/common/util/TestTablePathUtils.java 103 hudi-common/src/test/java/org/apache/hudi/common/util/collection/TestBitCaskDiskMap.java 187 hudi-common/src/test/java/org/apache/hudi/common/util/collection/TestExternalSpillableMap.java 338 hudi-common/src/test/java/org/apache/hudi/common/util/collection/TestIterators.java 24 hudi-common/src/test/java/org/apache/hudi/common/util/collection/TestRocksDBDAO.java 248 hudi-common/src/test/java/org/apache/hudi/common/util/collection/TestRocksDbBasedMap.java 38 hudi-common/src/test/java/org/apache/hudi/common/util/collection/TestRocksDbDiskMap.java 153 hudi-common/src/test/java/org/apache/hudi/common/util/hash/TestHashID.java 89 hudi-common/src/test/java/org/apache/hudi/common/util/io/TestByteBufferBackedInputStream.java 59 hudi-common/src/test/java/org/apache/hudi/expression/TestPartialBindVisitor.java 51 hudi-common/src/test/java/org/apache/hudi/internal/schema/TestSerDeHelper.java 81 hudi-common/src/test/java/org/apache/hudi/internal/schema/action/TestMergeSchema.java 54 hudi-common/src/test/java/org/apache/hudi/internal/schema/action/TestTableChanges.java 263 hudi-common/src/test/java/org/apache/hudi/internal/schema/io/TestFileBasedInternalSchemaStorageManager.java 74 hudi-common/src/test/java/org/apache/hudi/internal/schema/utils/TestAvroSchemaEvolutionUtils.java 456 hudi-common/src/test/java/org/apache/hudi/internal/schema/utils/TestInternalSchemaUtils.java 86 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieAvroFileReaderFactory.java 32 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieBaseParquetWriter.java 80 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHBaseHFileReaderWriter.java 156 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriter.java 56 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieHFileReaderWriterBase.java 387 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieOrcReaderWriter.java 73 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieReaderWriterBase.java 230 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieReaderWriterUtils.java 62 hudi-common/src/test/java/org/apache/hudi/metadata/HoodieBackedTestDelayedTableMetadata.java 25 hudi-common/src/test/java/org/apache/hudi/metadata/TestFileSystemBackedTableMetadata.java 137 hudi-common/src/test/java/org/apache/hudi/metadata/TestHoodieMetadataPayload.java 146 hudi-common/src/test/java/org/apache/hudi/metadata/TestHoodieTableMetadataUtil.java 115 hudi-common/src/test/resources/adaptable-payload.avsc 81 hudi-common/src/test/resources/complex-test-evolved.avsc 34 hudi-common/src/test/resources/complex.schema.avsc 1881 hudi-common/src/test/resources/exampleEvolvedSchema.avsc 40 hudi-common/src/test/resources/exampleEvolvedSchemaChangeOrder.avsc 40 hudi-common/src/test/resources/exampleEvolvedSchemaColumnRequire.avsc 40 hudi-common/src/test/resources/exampleEvolvedSchemaColumnType.avsc 36 hudi-common/src/test/resources/exampleEvolvedSchemaDeleteColumn.avsc 32 hudi-common/src/test/resources/exampleSchema.avsc 36 hudi-common/src/test/resources/exampleSchemaWithMetaFields.avsc 66 hudi-common/src/test/resources/exampleSchemaWithUDT.avsc 67 hudi-common/src/test/resources/nullRight.avsc 213 hudi-common/src/test/resources/nullWrong.avsc 203 hudi-common/src/test/resources/simple-test-doced.avsc 27 hudi-common/src/test/resources/simple-test-evolved-compatible.avsc 29 hudi-common/src/test/resources/simple-test-evolved.avsc 30 hudi-common/src/test/resources/simple-test.avsc 27 hudi-common/src/test/resources/source_evolved.avsc 158 hudi-common/src/test/resources/timestamp-logical-type.avsc 26 hudi-common/src/test/resources/timestamp-test-evolved.avsc 62 hudi-examples/hudi-examples-spark/src/test/python/HoodiePySparkQuickstart.py 202 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/configuration/TestOptionsInference.java 47 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/configuration/TestOptionsResolver.java 27 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java 437 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestStreamWriteOperatorCoordinator.java 467 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java 519 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java 165 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnReadWithCompact.java 235 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteWithTimelineBasedCkpMetadata.java 32 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/ITTestBucketStreamWrite.java 106 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/ITTestConsistentBucketStreamWrite.java 155 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bulk/TestBulkInsertWriteHelper.java 97 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bulk/TestRowDataKeyGen.java 150 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ClusteringCommitTestSink.java 21 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ITTestFlinkConsistentHashingClustering.java 130 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/cluster/ITTestHoodieFlinkClustering.java 475 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/CompactionCommitTestSink.java 27 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java 371 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/TestCompactionPlanStrategy.java 100 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/TestCustomSerDe.java 47 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/meta/TestCkpMetadata.java 76 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/meta/TestTimelineBasedCkpMetadata.java 66 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/partitioner/TestBucketAssigner.java 341 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/BucketStreamWriteFunctionWrapper.java 145 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/BulkInsertFunctionWrapper.java 185 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/ClusteringFunctionWrapper.java 75 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/CollectorOutput.java 39 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/CompactFunctionWrapper.java 74 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/ConsistentBucketStreamWriteFunctionWrapper.java 46 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/InsertFunctionWrapper.java 139 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockCoordinatorExecutor.java 31 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockMapState.java 52 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockOperatorStateStore.java 99 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockStateInitializationContext.java 37 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockStreamingRuntimeContext.java 90 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockValueState.java 17 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/ScalaCollector.java 19 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/StreamWriteFunctionWrapper.java 214 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/TestFunctionWrapper.java 50 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/TestHiveSyncContext.java 32 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/TestWriteBase.java 403 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestExpressionEvaluators.java 332 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestExpressionPredicates.java 192 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestFileIndex.java 136 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestIncrementalInputSplits.java 389 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestStreamReadMonitoringFunction.java 344 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestStreamReadOperator.java 204 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/prune/TestDataPruner.java 58 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/stats/TestColumnStatsIndices.java 64 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java 1822 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestSchemaEvolution.java 495 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestSchemaEvolutionBySQL.java 212 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestSchemaEvolutionBySQLWithDFSCatalog.java 27 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestSchemaEvolutionBySQLWithHMSCatalog.java 10 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/TestHoodieTableFactory.java 605 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/TestHoodieTableSource.java 276 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/HoodieCatalogTestUtils.java 44 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java 337 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalogFactory.java 81 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieHiveCatalog.java 351 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/format/TestCastMap.java 171 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/format/TestFormatUtils.java 36 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/format/TestInputFormat.java 851 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/format/cow/TestBlockLocationSort.java 24 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/util/TestExpressionUtils.java 117 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/FlinkMiniCluster.java 47 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/SchemaBuilder.java 41 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestAvroSchemaConverter.java 63 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestClusteringUtil.java 107 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestCompactionUtil.java 140 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestConfigurations.java 318 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestData.java 755 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestFlinkWriteClients.java 31 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestHoodieRowData.java 98 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestRowDataToAvroConverters.java 55 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestSQL.java 50 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestStreamerUtil.java 83 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestStringToRowDataConverter.java 82 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestTableEnvs.java 16 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestUtils.java 110 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestViewStorageProperties.java 46 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/factory/CollectSinkTableFactory.java 119 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/factory/ContinuousFileSourceFactory.java 42 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/source/ContinuousFileSource.java 120 hudi-flink-datasource/hudi-flink/src/test/resources/hive-site.xml 12 hudi-flink-datasource/hudi-flink/src/test/resources/test-catalog-factory-conf/hive-site.xml 8 hudi-flink-datasource/hudi-flink/src/test/resources/test_read_schema.avsc 45 hudi-flink-datasource/hudi-flink/src/test/resources/test_read_schema_dropped_age.avsc 41 hudi-flink-datasource/hudi-flink1.14.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java 6 hudi-flink-datasource/hudi-flink1.14.x/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java 8 hudi-flink-datasource/hudi-flink1.15.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java 6 hudi-flink-datasource/hudi-flink1.15.x/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java 8 hudi-flink-datasource/hudi-flink1.16.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java 6 hudi-flink-datasource/hudi-flink1.16.x/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java 9 hudi-flink-datasource/hudi-flink1.17.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java 6 hudi-flink-datasource/hudi-flink1.17.x/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java 9 hudi-flink-datasource/hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java 6 hudi-flink-datasource/hudi-flink1.18.x/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java 9 hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestBigQuerySchemaResolver.java 250 hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestBigQuerySyncConfig.java 95 hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestBigQuerySyncTool.java 105 hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestBigQuerySyncToolArgs.java 52 hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestHoodieBigQuerySyncClient.java 123 hudi-hadoop-common/src/test/java/org/apache/hudi/hadoop/fs/TestHadoopFSUtils.java 91 hudi-hadoop-common/src/test/java/org/apache/hudi/storage/hadoop/TestHadoopStorageConfiguration.java 17 hudi-hadoop-common/src/test/java/org/apache/hudi/storage/hadoop/TestHoodieHadoopStorage.java 24 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestAnnotation.java 41 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestGloballyConsistentTimeStampFilteringInputFormat.java 76 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieColumnProjectionUtils.java 44 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieCopyOnWriteTableInputFormat.java 33 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieHFileInputFormat.java 379 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieParquetInputFormat.java 599 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieROTablePathFilter.java 69 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestInputPathHandler.java 165 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestRecordReaderValueIterator.java 64 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/hive/TestHoodieCombineHiveInputFormat.java 292 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieMergeOnReadSnapshotReader.java 145 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieMergeOnReadTableInputFormat.java 50 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieRealtimeFileSplit.java 127 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieRealtimeRecordReader.java 764 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/testutils/InputFormatTestUtil.java 416 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/utils/TestHiveAvroSerializer.java 121 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/utils/TestHoodieRealtimeInputFormatUtils.java 23 hudi-hadoop-mr/src/test/resources/sample1.avsc 34 hudi-hadoop-mr/src/test/resources/test_timetype.avsc 45 hudi-integ-test/src/test/java/org/apache/hudi/integ/HoodieTestHiveBase.java 70 hudi-integ-test/src/test/java/org/apache/hudi/integ/ITTestBase.java 326 hudi-integ-test/src/test/java/org/apache/hudi/integ/ITTestHoodieDemo.java 406 hudi-integ-test/src/test/java/org/apache/hudi/integ/ITTestHoodieSanity.java 151 hudi-integ-test/src/test/java/org/apache/hudi/integ/command/ITTestHoodieSyncCommand.java 40 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/TestDFSHoodieTestSuiteWriterAdapter.java 101 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/TestFileDeltaInputWriter.java 105 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/configuration/TestWorkflowBuilder.java 48 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/converter/TestDeleteConverter.java 43 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/converter/TestUpdateConverter.java 58 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/dag/ComplexDagGenerator.java 49 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/dag/HiveSyncDagGenerator.java 29 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/dag/HiveSyncDagGeneratorMOR.java 31 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/dag/TestDagUtils.java 95 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/generator/TestGenericRecordPayloadEstimator.java 31 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/generator/TestGenericRecordPayloadGenerator.java 124 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/job/TestHoodieTestSuiteJob.java 253 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/reader/TestDFSAvroDeltaInputReader.java 46 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/reader/TestDFSHoodieDatasetInputReader.java 84 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/utils/TestUtils.java 32 hudi-integ-test/src/test/resources/unit-test-cow-dag-spark-datasource.yaml 28 hudi-integ-test/src/test/resources/unit-test-cow-dag.yaml 79 hudi-integ-test/src/test/resources/unit-test-mor-dag.yaml 59 hudi-integ-test/src/test/resources/unit-test-spark-sql-dag.yaml 24 hudi-io/src/test/java/org/apache/hudi/common/util/TestStringUtils.java 91 hudi-io/src/test/java/org/apache/hudi/io/compress/TestHoodieDecompressor.java 74 hudi-io/src/test/java/org/apache/hudi/io/hfile/TestHFileReader.java 462 hudi-io/src/test/java/org/apache/hudi/io/storage/BaseTestStorageConfiguration.java 70 hudi-io/src/test/java/org/apache/hudi/io/storage/TestHoodieStorageBase.java 266 hudi-io/src/test/java/org/apache/hudi/io/storage/TestStoragePath.java 178 hudi-io/src/test/java/org/apache/hudi/io/storage/TestStoragePathFilter.java 43 hudi-io/src/test/java/org/apache/hudi/io/storage/TestStoragePathInfo.java 72 hudi-io/src/test/java/org/apache/hudi/io/util/TestHFileUtils.java 18 hudi-io/src/test/java/org/apache/hudi/io/util/TestIOUtils.java 102 hudi-kafka-connect/src/test/java/org/apache/hudi/connect/TestConnectTransactionCoordinator.java 259 hudi-kafka-connect/src/test/java/org/apache/hudi/connect/TestConnectTransactionParticipant.java 207 hudi-kafka-connect/src/test/java/org/apache/hudi/connect/TestHdfsConfiguration.java 43 hudi-kafka-connect/src/test/java/org/apache/hudi/helper/MockConnectTransactionServices.java 27 hudi-kafka-connect/src/test/java/org/apache/hudi/helper/MockKafkaConnect.java 97 hudi-kafka-connect/src/test/java/org/apache/hudi/helper/MockKafkaControlAgent.java 54 hudi-kafka-connect/src/test/java/org/apache/hudi/helper/TestHudiWriterProvider.java 45 hudi-kafka-connect/src/test/java/org/apache/hudi/writers/TestAbstractConnectWriter.java 155 hudi-kafka-connect/src/test/java/org/apache/hudi/writers/TestBufferedConnectWriter.java 71 hudi-kafka-connect/src/test/resources/hadoop_conf/core-site.xml 13 hudi-kafka-connect/src/test/resources/hadoop_conf/hdfs-site.xml 11 hudi-kafka-connect/src/test/resources/hadoop_home/etc/hadoop/core-site.xml 13 hudi-kafka-connect/src/test/resources/hadoop_home/etc/hadoop/hdfs-site.xml 11 hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/test/java/org/apache/hudi/metaserver/client/TestHoodieMetaserverClient.java 25 hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/test/java/org/apache/hudi/metaserver/TestHoodieMetaserver.java 10 hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/test/java/org/apache/hudi/metaserver/store/TestRelationalDBBasedStore.java 88 hudi-spark-datasource/hudi-spark-common/src/test/java/org/apache/hudi/TestHoodieSchemaUtils.java 225 hudi-spark-datasource/hudi-spark-common/src/test/java/org/apache/hudi/testutils/SparkDatasetTestUtils.java 175 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/hudi/TestDataSourceOptions.scala 22 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/hudi/cdc/TestInternalRowToJsonStringConverter.scala 52 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/execution/datasources/TestHoodieInMemoryFileIndex.scala 33 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/execution/datasources/parquet/TestHoodieFileGroupReaderBasedParquetFileFormat.scala 67 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/sql/hive/TestHiveClientUtils.scala 27 hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaApp.java 185 hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaGenerateApp.java 135 hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaStreamingApp.java 283 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/ColumnStatsIndexHelper.java 175 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestDataSourceReadWithDeletes.java 146 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestDataSourceUtils.java 277 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestHoodieMergeHandleWithSparkMerger.java 301 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestHoodiePositionBasedFileGroupRecordBuffer.java 157 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestQuickstartUtils.java 19 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/execution/bulkinsert/TestBulkInsertInternalPartitionerForRows.java 175 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/HoodieSparkFunctionalTestSuite.java 10 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/SparkSQLCoreFlow.java 10 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestBootstrap.java 528 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestBootstrapRead.java 65 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestBootstrapReadBase.java 238 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestDataSkippingWithMORColstats.java 316 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestGlobalIndexEnableUpdatePartitions.java 184 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestHiveTableSchemaEvolution.java 123 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestHoodieDatasetBulkInsertHelper.java 325 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestHoodieSparkMergeOnReadTableClustering.java 200 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestNewHoodieParquetFileFormat.java 107 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestOrcBootstrap.java 438 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestSparkConsistentBucketClustering.java 288 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestSparkSortAndSizeClustering.java 122 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestWriteClient.java 56 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/io/storage/row/TestHoodieInternalRowParquetWriter.java 92 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/io/storage/row/TestHoodieRowCreateHandle.java 182 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/TestComplexKeyGenerator.java 143 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/TestCustomKeyGenerator.java 293 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/TestGlobalDeleteRecordGenerator.java 61 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/TestNonpartitionedKeyGenerator.java 105 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/TestSimpleKeyGenerator.java 128 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/TestTimestampBasedKeyGenerator.java 369 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/factory/TestCreateKeyGeneratorByTypeWithFactory.java 87 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/keygen/factory/TestHoodieSparkKeyGeneratorFactory.java 77 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/testutils/DataSourceTestUtils.java 110 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/testutils/HoodieSparkClientTestBase.java 11 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/testutils/KeyGeneratorTestUtilities.java 85 hudi-spark-datasource/hudi-spark/src/test/resources/sql-statements.sql 249 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/HoodieSparkWriterTestBase.scala 75 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/ScalaAssertionSupport.scala 15 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/SparkDatasetMixin.scala 21 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestAvroConversionHelper.scala 31 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestAvroConversionUtils.scala 409 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestAvroSchemaResolutionSupport.scala 689 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestConvertFilterToCatalystExpression.scala 128 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestDataSkippingUtils.scala 610 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestDataSourceDefaults.scala 443 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestDataSourceOptions.scala 34 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestGenericRecordAndRowConsistency.scala 79 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieDataSourceHelper.scala 25 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieFileIndex.scala 653 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieParquetBloom.scala 67 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieRelations.scala 30 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieSparkSqlWriter.scala 917 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieSparkSqlWriterUtc.scala 44 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieSparkUtils.scala 171 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestSparkFilterHelper.scala 128 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestTableSchemaResolverWithSparkSQL.scala 93 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/common/model/TestHoodieRecordSerialization.scala 133 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/common/table/read/TestHoodieFileGroupReaderOnSpark.scala 86 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/common/table/read/TestSpark35RecordPositionMetadataColumn.scala 106 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/ColumnStatIndexTestBase.scala 214 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/CommonOptionUtils.scala 32 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/RecordLevelIndexTestBase.scala 232 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestAutoGenerationOfRecordKeys.scala 220 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestBasicSchemaEvolution.scala 248 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestCOWDataSource.scala 1597 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestCOWDataSourceStorage.scala 344 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestColumnStatsIndex.scala 332 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestColumnStatsIndexWithSQL.scala 324 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestDataSourceForBootstrap.scala 500 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestEmptyCommit.scala 44 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestGetPartitionValuesFromPath.scala 67 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestHoodieActiveTimeline.scala 165 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestHoodieMultipleBaseFileFormat.scala 82 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestIncrementalReadByStateTransitionTime.scala 76 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestIncrementalReadWithFullTableScan.scala 122 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestLayoutOptimization.scala 147 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMORDataSource.scala 1094 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMORDataSourceStorage.scala 140 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMORDataSourceWithBucketIndex.scala 142 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMetadataRecordIndex.scala 168 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMetadataTableWithSparkDataSource.scala 146 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMetricsReporter.scala 69 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestParquetColumnProjection.scala 366 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestPartialUpdateAvroPayload.scala 102 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestRecordLevelIndex.scala 425 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestRecordLevelIndexWithSQL.scala 142 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSixToFiveDowngradeHandler.scala 110 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkDataSource.scala 278 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkDataSourceDAGExecution.scala 143 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkSqlCoreFlow.scala 380 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSqlStatement.scala 153 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestStreamSourceReadByStateTransitionTime.scala 69 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestStreamingSource.scala 199 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestStructuredStreaming.scala 398 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestTimeTravelQuery.scala 288 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/cdc/HoodieCDCTestBase.scala 169 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/cdc/TestCDCDataFrameSuite.scala 636 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/cdc/TestCDCStreamingSuite.scala 152 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/util/JavaConversions.scala 16 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/util/TestPathUtils.scala 54 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/hudi/benchmark/HoodieBenchmark.scala 136 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/hudi/benchmark/HoodieBenchmarkBase.scala 50 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/hudi/benchmark/HoodieBenchmarks.scala 62 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/avro/TestAvroSerDe.scala 37 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/avro/TestSchemaConverters.scala 14 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/AvroSerDerBenchmark.scala 56 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/BoundInMemoryExecutorBenchmark.scala 116 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/CowTableReadBenchmark.scala 97 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/LSMTimelineReadBenchmark.scala 73 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/ReadAndWriteWithoutAvroBenchmark.scala 130 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/SpaceCurveOptimizeBenchmark.scala 75 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/analysis/TestHoodiePruneFileSourcePartitions.scala 169 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/command/index/TestFunctionalIndex.scala 205 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/command/index/TestIndexSyntax.scala 69 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/command/index/TestSecondaryIndex.scala 61 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/HoodieSparkSqlTestBase.scala 203 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestHoodieInternalRowUtils.scala 229 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestHoodieOptionConfig.scala 128 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestLazyPartitionPathFetching.scala 100 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestNestedSchemaPruningOptimization.scala 118 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestPartitionPushDownWhenListingPaths.scala 71 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestSqlConf.scala 75 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestAlterTable.scala 353 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestAlterTableAddPartition.scala 174 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestAlterTableDropPartition.scala 523 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestCreateTable.scala 1318 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestSpark3DDL.scala 898 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestCDCForSparkSQL.scala 259 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestCompactionTable.scala 103 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestDataSkippingQuery.scala 85 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestDeleteFromTable.scala 53 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestDeleteTable.scala 253 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestDropTable.scala 333 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestHoodieTableValuedFunction.scala 563 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestInsertTable.scala 2368 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeIntoLogOnlyTable.scala 67 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeIntoTable.scala 1093 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeIntoTable2.scala 748 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeIntoTableWithNonRecordKeyField.scala 338 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestPartialUpdateForMergeInto.scala 361 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestQueryMergeOnReadOptimizedTable.scala 50 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestRepairTable.scala 159 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestShowPartitions.scala 260 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestTimeTravelTable.scala 280 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestTruncateTable.scala 100 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestUpdateTable.scala 240 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/HoodieSparkProcedureTestBase.scala 19 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestArchiveCommitsProcedure.scala 45 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestBootstrapProcedure.scala 188 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCallCommandParser.scala 101 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCallProcedure.scala 264 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCleanProcedure.scala 151 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestClusteringProcedure.scala 661 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCommitsProcedure.scala 245 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCompactionProcedure.scala 302 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCopyToTableProcedure.scala 289 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCopyToTempViewProcedure.scala 122 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestExportInstantsProcedure.scala 27 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestFsViewProcedure.scala 136 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestHdfsParquetImportProcedure.scala 159 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestHelpProcedure.scala 61 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestHoodieLogFileProcedure.scala 70 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestMetadataProcedure.scala 334 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestRepairsProcedure.scala 437 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestSavepointsProcedure.scala 319 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestShowFsPathDetailProcedure.scala 34 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestShowInvalidParquetProcedure.scala 50 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestShowTablePropertiesProcedure.scala 25 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestStatsProcedure.scala 121 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestTTLProcedure.scala 83 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestUpgradeOrDowngradeProcedure.scala 112 hudi-spark-datasource/hudi-spark2/src/test/java/org/apache/hudi/internal/HoodieBulkInsertInternalWriterTestBase.java 131 hudi-spark-datasource/hudi-spark2/src/test/java/org/apache/hudi/internal/TestHoodieBulkInsertDataInternalWriter.java 140 hudi-spark-datasource/hudi-spark2/src/test/java/org/apache/hudi/internal/TestHoodieDataSourceInternalWriter.java 235 hudi-spark-datasource/hudi-spark3.0.x/src/test/java/org/apache/hudi/internal/HoodieBulkInsertInternalWriterTestBase.java 131 hudi-spark-datasource/hudi-spark3.0.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieBulkInsertDataInternalWriter.java 110 hudi-spark-datasource/hudi-spark3.0.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieDataSourceInternalBatchWrite.java 239 hudi-spark-datasource/hudi-spark3.1.x/src/test/org/apache/hudi/internal/HoodieBulkInsertInternalWriterTestBase.java 131 hudi-spark-datasource/hudi-spark3.1.x/src/test/org/apache/hudi/spark3/internal/TestHoodieBulkInsertDataInternalWriter.java 110 hudi-spark-datasource/hudi-spark3.1.x/src/test/org/apache/hudi/spark3/internal/TestHoodieDataSourceInternalBatchWrite.java 239 hudi-spark-datasource/hudi-spark3.2.x/src/test/java/org/apache/hudi/internal/HoodieBulkInsertInternalWriterTestBase.java 131 hudi-spark-datasource/hudi-spark3.2.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieBulkInsertDataInternalWriter.java 110 hudi-spark-datasource/hudi-spark3.2.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieDataSourceInternalBatchWrite.java 239 hudi-spark-datasource/hudi-spark3.3.x/src/test/java/org/apache/hudi/internal/HoodieBulkInsertInternalWriterTestBase.java 131 hudi-spark-datasource/hudi-spark3.3.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieBulkInsertDataInternalWriter.java 110 hudi-spark-datasource/hudi-spark3.3.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieDataSourceInternalBatchWrite.java 239 hudi-spark-datasource/hudi-spark3.3.x/src/test/java/org/apache/hudi/spark3/internal/TestReflectUtil.java 25 hudi-spark-datasource/hudi-spark3.4.x/src/test/java/org/apache/hudi/internal/HoodieBulkInsertInternalWriterTestBase.java 131 hudi-spark-datasource/hudi-spark3.4.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieBulkInsertDataInternalWriter.java 110 hudi-spark-datasource/hudi-spark3.4.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieDataSourceInternalBatchWrite.java 239 hudi-spark-datasource/hudi-spark3.4.x/src/test/java/org/apache/hudi/spark3/internal/TestReflectUtil.java 25 hudi-spark-datasource/hudi-spark3.5.x/src/test/java/org/apache/hudi/internal/HoodieBulkInsertInternalWriterTestBase.java 131 hudi-spark-datasource/hudi-spark3.5.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieBulkInsertDataInternalWriter.java 110 hudi-spark-datasource/hudi-spark3.5.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieDataSourceInternalBatchWrite.java 239 hudi-spark-datasource/hudi-spark3.5.x/src/test/java/org/apache/hudi/spark3/internal/TestReflectUtil.java 25 hudi-sync/hudi-adb-sync/src/test/java/org/apache/hudi/sync/adb/TestAdbSyncConfig.java 61 hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/DummyPartitionValueExtractor.java 10 hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/TestDataHubSyncClient.java 88 hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/config/TestDataHubSyncConfig.java 49 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java 1311 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncToolArgs.java 30 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestMultiPartKeysValueExtractor.java 17 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestParquet2SparkSchemaUtils.java 67 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestPartitionValueExtractor.java 36 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/functional/HiveSyncFunctionalTestSuite.java 10 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/functional/TestHiveMetastoreBasedLockProvider.java 137 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/replication/TestHiveSyncGlobalCommitTool.java 119 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveSyncFunctionalTestHarness.java 116 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestCluster.java 219 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestService.java 250 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestUtil.java 597 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/util/TestHiveSchemaUtil.java 86 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/util/TestPartitionFilterGenerator.java 93 hudi-sync/hudi-sync-common/src/test/java/org/apache/hudi/sync/common/TestHoodieSyncConfig.java 126 hudi-sync/hudi-sync-common/src/test/java/org/apache/hudi/sync/common/util/TestManifestFileWriter.java 69 hudi-sync/hudi-sync-common/src/test/java/org/apache/hudi/sync/common/util/TestSyncUtilHelpers.java 160 hudi-tests-common/pom.xml 188 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/functional/TestRemoteHoodieTableFileSystemView.java 130 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/handlers/marker/TestMarkerBasedEarlyConflictDetectionRunnable.java 82 hudi-utilities/src/test/java/org/apache/hudi/utilities/DummySchemaPostProcessor.java 15 hudi-utilities/src/test/java/org/apache/hudi/utilities/DummySchemaProvider.java 14 hudi-utilities/src/test/java/org/apache/hudi/utilities/SparkAvroSchemaProvider.java 14 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHiveIncrementalPuller.java 143 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieIndexer.java 432 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieMetadataTableValidator.java 63 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieRepairTool.java 343 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieSnapshotExporter.java 31 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestSchemaPostProcessor.java 138 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestSqlQueryBuilder.java 30 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestUtilHelpers.java 18 hudi-utilities/src/test/java/org/apache/hudi/utilities/callback/TestKafkaCallbackProvider.java 68 hudi-utilities/src/test/java/org/apache/hudi/utilities/checkpointing/TestKafkaConnectHdfsProvider.java 57 hudi-utilities/src/test/java/org/apache/hudi/utilities/config/SourceTestConfig.java 26 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamerTestBase.java 634 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/MockConfigurationHotUpdateStrategy.java 25 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamer.java 2372 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerDAGExecution.java 85 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerSchemaEvolutionBase.java 283 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerSchemaEvolutionExtensive.java 447 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerSchemaEvolutionQuick.java 566 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java 378 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieMultiTableDeltaStreamer.java 248 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestSchedulerConfGenerator.java 70 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestSourceFormatAdapter.java 148 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestSparkSampleWritesUtils.java 73 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestTransformer.java 61 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/multisync/MockSyncTool1.java 14 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/multisync/MockSyncTool2.java 14 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/multisync/MockSyncToolException1.java 13 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/multisync/MockSyncToolException2.java 13 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/multisync/TestMultipleMetaSync.java 82 hudi-utilities/src/test/java/org/apache/hudi/utilities/deser/TestKafkaAvroSchemaDeserializer.java 95 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestAWSDatabaseMigrationServiceSource.java 59 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestChainedTransformer.java 107 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestErrorTableAwareChainedTransformer.java 109 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHDFSParquetImporter.java 280 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHiveSchemaProvider.java 104 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieSnapshotCopier.java 99 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieSnapshotExporter.java 222 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestJdbcbasedSchemaProvider.java 53 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/UtilitiesFunctionalTestSuite.java 10 hudi-utilities/src/test/java/org/apache/hudi/utilities/multitable/TestHoodieMultiTableServicesMain.java 285 hudi-utilities/src/test/java/org/apache/hudi/utilities/offlinejob/HoodieOfflineJobTestBase.java 96 hudi-utilities/src/test/java/org/apache/hudi/utilities/offlinejob/TestHoodieClusteringJob.java 133 hudi-utilities/src/test/java/org/apache/hudi/utilities/offlinejob/TestHoodieCompactorJob.java 83 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/TestFilebasedSchemaProvider.java 64 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/TestKafkaOffsetPostProcessor.java 41 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/TestLazyCastingIterator.java 146 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/TestProtoClassBasedSchemaProvider.java 65 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/TestSchemaRegistryProvider.java 112 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/converter/TestJsonToAvroSchemaConverter.java 37 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/BaseTestKafkaSource.java 224 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestAvroDFSSource.java 29 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestAvroKafkaSource.java 182 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestCsvDFSSource.java 33 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestDataSource.java 41 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsHoodieIncrSource.java 338 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsSource.java 209 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGenericRddTransform.java 58 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestHoodieIncrSource.java 290 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestInputBatch.java 30 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestJdbcSource.java 312 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestJsonDFSSource.java 69 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestJsonKafkaSource.java 282 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestJsonKafkaSourcePostProcessor.java 212 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestParquetDFSSource.java 25 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestParquetDFSSourceEmptyBatch.java 33 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestProtoKafkaSource.java 168 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsHoodieIncrSource.java 387 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsSource.java 67 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestSqlFileBasedSource.java 127 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestSqlSource.java 116 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/debezium/TestAbstractDebeziumSource.java 144 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/debezium/TestMysqlDebeziumSource.java 66 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/debezium/TestPostgresDebeziumSource.java 67 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/SchemaTestProvider.java 16 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestCheckpointUtils.java 335 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestCloudObjectsSelector.java 164 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestCloudObjectsSelectorCommon.java 98 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestDFSPathSelectorCommonMethods.java 125 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestDatePartitionPathSelector.java 152 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestIncrSourceHelper.java 304 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestKafkaOffsetGen.java 207 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestProtoConversionUtil.java 499 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestS3EventsMetaSelector.java 96 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestSanitizationUtils.java 101 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestSnapshotQuerySplitterImpl.java 22 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/gcs/TestPubsubMessagesFetcher.java 79 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestHoodieStreamerUtils.java 56 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java 120 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/CloudObjectTestUtils.java 60 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/JdbcTestUtils.java 164 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/SanitizationTestUtils.java 136 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/SparkClientFunctionalTestHarnessWithHiveSupport.java 9 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/UtilitiesTestBase.java 428 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/sources/AbstractBaseTestSource.java 122 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/sources/AbstractCloudObjectsSourceTestBase.java 61 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/sources/AbstractDFSSourceTestBase.java 107 hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/sources/DistributedTestDataSource.java 49 hudi-utilities/src/test/java/org/apache/hudi/utilities/transform/TestChainedTransformer.java 17 hudi-utilities/src/test/java/org/apache/hudi/utilities/transform/TestFlatteningTransformer.java 25 hudi-utilities/src/test/java/org/apache/hudi/utilities/transform/TestSqlFileBasedTransformer.java 131 hudi-utilities/src/test/java/org/apache/hudi/utilities/transform/TestSqlQueryBasedTransformer.java 58 hudi-utilities/src/test/resources/hive-site.xml 16 hudi-utilities/src/test/resources/schema-provider/proto/oneof_schema.avsc 59 hudi-utilities/src/test/resources/schema-provider/proto/parent_schema_recursive_default_limit.avsc 177 hudi-utilities/src/test/resources/schema-provider/proto/parent_schema_recursive_depth_2.avsc 132 hudi-utilities/src/test/resources/schema-provider/proto/recursive.proto 31 hudi-utilities/src/test/resources/schema-provider/proto/sample.proto 77 hudi-utilities/src/test/resources/schema-provider/proto/sample_schema_defaults.avsc 322 hudi-utilities/src/test/resources/schema-provider/proto/sample_schema_wrapped_and_timestamp_as_record.avsc 434 hudi-utilities/src/test/resources/schema/sample_data_schema.avsc 27 hudi-utilities/src/test/resources/schema/sample_gcs_data.avsc 31 hudi-utilities/src/test/resources/streamer-config/complex-source.avsc 466 hudi-utilities/src/test/resources/streamer-config/file_schema_provider_invalid.avsc 49 hudi-utilities/src/test/resources/streamer-config/file_schema_provider_valid.avsc 48 hudi-utilities/src/test/resources/streamer-config/gcs-metadata.avsc 128 hudi-utilities/src/test/resources/streamer-config/hive_schema_provider_source.avsc 102 hudi-utilities/src/test/resources/streamer-config/hive_schema_provider_target.avsc 102 hudi-utilities/src/test/resources/streamer-config/s3-metadata.avsc 188 hudi-utilities/src/test/resources/streamer-config/schema_registry.source_schema_tab.sql 12 hudi-utilities/src/test/resources/streamer-config/schema_registry.target_schema_tab.sql 12 hudi-utilities/src/test/resources/streamer-config/source-flattened.avsc 85 hudi-utilities/src/test/resources/streamer-config/source-jdbc.avsc 67 hudi-utilities/src/test/resources/streamer-config/source.avsc 161 hudi-utilities/src/test/resources/streamer-config/source_evolved.avsc 158 hudi-utilities/src/test/resources/streamer-config/source_evolved_post_processed.avsc 160 hudi-utilities/src/test/resources/streamer-config/source_short_trip_uber.avsc 43 hudi-utilities/src/test/resources/streamer-config/source_uber.avsc 43 hudi-utilities/src/test/resources/streamer-config/sql-file-based-source-invalid-table.sql 3 hudi-utilities/src/test/resources/streamer-config/sql-file-based-source.sql 6 hudi-utilities/src/test/resources/streamer-config/sql-file-transformer-empty.sql 8 hudi-utilities/src/test/resources/streamer-config/sql-file-transformer-invalid.sql 5 hudi-utilities/src/test/resources/streamer-config/sql-file-transformer.sql 7 hudi-utilities/src/test/resources/streamer-config/target-flattened.avsc 89 hudi-utilities/src/test/resources/streamer-config/target.avsc 165 hudi-utilities/src/test/resources/streamer-config/target_short_trip_uber.avsc 43 hudi-utilities/src/test/resources/streamer-config/target_uber.avsc 43 hudi-utilities/src/test/resources/streamer-config/triprec.sql 11 packaging/bundle-validation/docker_java17/docker_java17_test.sh 121 packaging/hudi-integ-test-bundle/pom.xml 589 packaging/hudi-integ-test-bundle/src/main/java/org/apache/hudi/testsuite/bundle/Main.java 7