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/metrics/cloudwatch/TestCloudWatchMetricsReporter.java 88 hudi-aws/src/test/java/org/apache/hudi/aws/metrics/cloudwatch/TestCloudWatchReporter.java 147 hudi-aws/src/test/java/org/apache/hudi/aws/sync/ITTestGluePartitionPushdown.java 110 hudi-aws/src/test/java/org/apache/hudi/aws/sync/MockAwsGlueCatalogSyncTool.java 19 hudi-aws/src/test/java/org/apache/hudi/aws/sync/TestAWSGlueSyncClient.java 229 hudi-aws/src/test/java/org/apache/hudi/aws/sync/TestAwsGlueSyncTool.java 72 hudi-aws/src/test/java/org/apache/hudi/aws/sync/TestGluePartitionPushdown.java 100 hudi-aws/src/test/java/org/apache/hudi/aws/testutils/GlueTestUtil.java 101 hudi-aws/src/test/java/org/apache/hudi/aws/transaction/integ/ITTestDynamoDBBasedLockProvider.java 181 hudi-aws/src/test/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProviderBaseTest.java 54 hudi-aws/src/test/java/org/apache/hudi/aws/transaction/lock/TestS3StorageBasedLockProvider.java 110 hudi-aws/src/test/java/org/apache/hudi/aws/transaction/lock/TestS3StorageLockClient.java 262 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 148 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 425 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestCompactionCommand.java 155 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestDiffCommand.java 111 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 205 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestMetadataCommand.java 72 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestRepairsCommand.java 322 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestRestoresCommand.java 158 hudi-cli/src/test/java/org/apache/hudi/cli/commands/TestRollbacksCommand.java 153 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 208 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 129 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 97 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestBootstrapCommand.java 76 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestClusteringCommand.java 131 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestCommitsCommand.java 98 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestCompactionCommand.java 220 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestMarkersCommand.java 43 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestRepairsCommand.java 247 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestSavepointsCommand.java 141 hudi-cli/src/test/java/org/apache/hudi/cli/integ/ITTestTableCommand.java 154 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 16 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 20 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/HoodieTestCommitGenerator.java 173 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 77 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/callback/client/http/TestCallbackHttpClient.java 156 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/TestBaseHoodieTableServiceClient.java 208 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/TestBaseHoodieWriteClient.java 166 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/embedded/TestEmbeddedTimelineService.java 150 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/heartbeat/TestHoodieHeartbeatClient.java 85 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/timeline/TestCompletionTimeQueryView.java 145 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/timeline/TestHoodieTimelineArchiver.java 80 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 128 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestConcurrentSchemaEvolutionTableSchemaGetter.java 482 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestConflictResolutionStrategyUtil.java 270 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestHoodieLockMetrics.java 39 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 172 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestSimpleConcurrentFileWritesConflictResolutionStrategy.java 313 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestSimpleConcurrentFileWritesConflictResolutionStrategyWithMORTable.java 55 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestSimpleSchemaConflictResolutionStrategy.java 227 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestTransactionManager.java 200 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestZookeeperBasedLockProvider.java 159 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/lock/StorageBasedLockProviderTestBase.java 201 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/lock/TestStorageBasedLockProvider.java 455 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/lock/models/StorageLockClientFileTest.java 125 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/lock/models/TestLockProviderHeartbeatManager.java 375 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/utils/TestCommitMetadataResolver.java 185 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/utils/TestDeletePartitionUtils.java 76 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 115 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/utils/TestTransactionUtils.java 59 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/common/table/timeline/TestArchivedTimelineV2.java 76 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/common/testutils/HoodieMetadataTestTable.java 149 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/config/TestHoodieErrorTableConfig.java 19 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/config/TestHoodieWriteConfig.java 659 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/config/TestStorageBasedLockConfig.java 61 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/estimator/TestAverageRecordSizeEstimator.java 207 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/estimator/TestRecordSizeEstimatorFactory.java 41 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/index/bucket/TestBucketIdentifier.java 88 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/index/bucket/TestPartitionBucketIndexCalculator.java 97 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/index/simple/TestGlobalSimpleIndex.java 124 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/index/simple/TestSimpleIndex.java 124 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 112 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/TestHoodieBackedTableMetadataWriter.java 85 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 40 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestHoodieGraphiteMetrics.java 41 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestHoodieJmxMetrics.java 96 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestHoodieMetrics.java 251 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/TestSlf4jMetrics.java 42 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 83 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 75 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/prometheus/TestPrometheusReporter.java 43 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/metrics/prometheus/TestPushGateWayReporter.java 133 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/TestBaseHoodieTable.java 150 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/TestBaseTableServicePlanActionExecutor.java 238 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/TestBulkInsertPartitioner.java 16 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/TestHoodieTable.java 91 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/TestCleanPlanner.java 539 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/clean/TestCleanPlanActionExecutor.java 108 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/cluster/strategy/TestPartitionAwareClusteringPlanStrategy.java 58 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/commit/TestWriterHelperBase.java 38 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/compact/TestScheduleCompactionActionExecutor.java 52 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/index/TestIndexingCatchupTask.java 203 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/rollback/HoodieRollbackTestBase.java 109 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/rollback/TestMarkerBasedRollbackStrategy.java 113 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/rollback/TestRollbackHelper.java 340 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/action/rollback/TestRollbackUtils.java 136 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 107 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/TestEightToSevenDowngradeHandler.java 178 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/table/upgrade/TestSevenToEightUpgradeHandler.java 119 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/table/upgrade/TestUpgradeDowngradeUtils.java 24 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/Assertions.java 90 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/GenericRecordValidationTestUtils.java 134 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java 134 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieWriteableTestTable.java 162 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 32 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 1132 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/utils/TestCommonClientUtils.java 38 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/TestLazyConcatenatingIterator.java 73 hudi-client/hudi-client-common/src/test/java/org/apache/hudi/utils/TestMetadataConversionUtils.java 346 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 146 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/merge/TestHoodieFlinkRecordMerger.java 134 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/merge/TestPartialUpdateFlinkRecordMerger.java 109 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 109 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/testutils/HoodieFlinkWriteableTestTable.java 119 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/TestHoodieJavaWriteClientInsert.java 196 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/TestJavaHoodieBackedMetadata.java 2149 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/common/TestMultipleHoodieJavaWriteClient.java 185 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/functional/TestHoodieJavaClientOnCopyOnWriteStorage.java 351 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/client/functional/TestHoodieJavaClientOnMergeOnReadStorage.java 115 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/common/table/read/HoodieFileGroupReaderOnJavaTestBase.java 84 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/common/table/read/TestHoodieFileGroupReaderOnJava.java 24 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/hadoop/TestHoodieFileGroupReaderOnHive.java 95 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/table/action/commit/TestJavaCopyOnWriteActionExecutor.java 426 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/ArrayWritableTestUtil.java 157 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/testutils/HoodieJavaClientTestHarness.java 760 hudi-client/hudi-java-client/src/test/java/org/apache/hudi/testutils/TestHoodieMetadataBase.java 261 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 630 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestCompactionAdminClient.java 190 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestFileBasedLockProvider.java 83 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieReadClient.java 134 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestHoodieSparkIndex.java 115 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestMultiFS.java 122 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 122 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 186 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/TestUpdateSchemaEvolution.java 199 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 78 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/common/TestSparkReaderContextFactory.java 91 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestExternalPathHandling.java 251 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieBackedTableMetadata.java 421 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnCopyOnWriteStorage.java 1293 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieFileSystemViews.java 239 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieIndex.java 521 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieMetadataBase.java 283 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieMetadataBootstrap.java 226 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestSavepointRestoreCopyOnWrite.java 108 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 78 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/TestHoodieJavaPairRDD.java 82 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/data/TestHoodieJavaRDD.java 70 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/data/TrackingCloseableIterator.java 31 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 240 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 209 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/bulkinsert/TestRDDSimpleBucketBulkInsertPartitioner.java 109 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/execution/bulkinsert/TestRowCustomColumnsSortPartitioner.java 28 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 74 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestHoodieBloomIndex.java 586 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestHoodieGlobalBloomIndex.java 268 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/expression/TestHoodieSparkExpressionIndex.java 126 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 668 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieKeyLocationFetchHandle.java 137 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieMergeHandle.java 256 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieMergedReadHandle.java 186 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/io/TestHoodieTimelineArchiver.java 1571 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 75 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/TestCleaner.java 991 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/TestConsistencyGuard.java 144 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/TestHoodieSparkTable.java 102 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/bootstrap/TestBootstrapUtils.java 57 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 164 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/cluster/ClusteringTestUtils.java 114 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/cluster/TestIncrementalClustering.java 170 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 454 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/commit/TestSparkWriteHelper.java 66 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/commit/TestUpsertPartitioner.java 290 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/CompactionTestBase.java 235 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/compact/strategy/TestHoodieCompactionStrategy.java 510 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/rollback/HoodieClientRollbackTestBase.java 115 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/rollback/TestCopyOnWriteRollbackActionExecutor.java 373 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/action/rollback/TestRollbackUtils.java 86 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestCleanActionExecutor.java 148 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/functional/TestCleanPlanExecutor.java 579 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/TestMarkerBasedRollbackStrategy.java 322 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestDirectWriteMarkers.java 88 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestDirectWriteMarkersV1.java 17 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestTimelineServerBasedWriteMarkers.java 157 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestTimelineServerBasedWriteMarkersV1.java 25 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/marker/TestWriteMarkersBase.java 148 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/table/upgrade/TestUpgradeDowngrade.java 767 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/FunctionalTestHarness.java 160 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieCleanerTestBase.java 191 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieClientTestBase.java 400 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieClientTestUtils.java 252 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieSparkClientTestHarness.java 513 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieSparkDeleteRecordMerger.java 19 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieSparkWriteableTestTable.java 115 hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/SparkClientFunctionalTestHarness.java 363 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/TestHoodieSparkKryoRegistrar.java 43 hudi-client/hudi-spark-client/src/test/java/org/apache/spark/sql/TestHoodieDataTypeUtils.java 81 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/AvroSchemaTestUtils.java 39 hudi-common/src/test/java/org/apache/hudi/avro/MercifulJsonConverterTestBase.java 431 hudi-common/src/test/java/org/apache/hudi/avro/TestAvroSchemaComparatorForSchemaEvolution.java 345 hudi-common/src/test/java/org/apache/hudi/avro/TestAvroSchemaUtils.java 337 hudi-common/src/test/java/org/apache/hudi/avro/TestHoodieAvroReaderContext.java 224 hudi-common/src/test/java/org/apache/hudi/avro/TestHoodieAvroUtils.java 784 hudi-common/src/test/java/org/apache/hudi/avro/TestMercifulJsonConverter.java 413 hudi-common/src/test/java/org/apache/hudi/common/TestRegistry.java 44 hudi-common/src/test/java/org/apache/hudi/common/bloom/TestInternalDynamicBloomFilter.java 34 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/config/TestHoodieStorageConfig.java 19 hudi-common/src/test/java/org/apache/hudi/common/config/TestHoodieTimeGeneratorConfig.java 24 hudi-common/src/test/java/org/apache/hudi/common/data/CloseValidationIterator.java 25 hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListData.java 94 hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListDataPairData.java 278 hudi-common/src/test/java/org/apache/hudi/common/fs/TestSizeAwareDataInputStream.java 59 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 76 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieCommitMetadata.java 192 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/TestHoodieLSMTimelineManifest.java 28 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieLogFile.java 67 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieMetadataRecordMerger.java 34 hudi-common/src/test/java/org/apache/hudi/common/model/TestHoodieRecordGlobalLocation.java 16 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 35 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/serialization/TestDefaultSerializer.java 26 hudi-common/src/test/java/org/apache/hudi/common/serialization/TestHoodieFileGroupSerializer.java 51 hudi-common/src/test/java/org/apache/hudi/common/serialization/TestHoodieFileSliceSerializer.java 39 hudi-common/src/test/java/org/apache/hudi/common/table/TestPartitionPathParser.java 65 hudi-common/src/test/java/org/apache/hudi/common/table/checkpoint/TestCheckpointUtils.java 179 hudi-common/src/test/java/org/apache/hudi/common/table/checkpoint/TestHoodieIncrSourceCheckpointValUtils.java 48 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/TestLogFileIterator.java 73 hudi-common/src/test/java/org/apache/hudi/common/table/log/block/TestHoodieAvroDataBlock.java 215 hudi-common/src/test/java/org/apache/hudi/common/table/log/block/TestHoodieLogBlock.java 131 hudi-common/src/test/java/org/apache/hudi/common/table/read/CustomPayloadForTesting.java 12 hudi-common/src/test/java/org/apache/hudi/common/table/read/TestFileGroupRecordBuffer.java 312 hudi-common/src/test/java/org/apache/hudi/common/table/read/TestHoodieFileGroupReaderBase.java 419 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 54 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/versioning/BaseTestCommitMetadataSerDe.java 232 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/versioning/v1/TestCommitMetadataSerDeV1.java 14 hudi-common/src/test/java/org/apache/hudi/common/table/timeline/versioning/v2/TestCommitMetadataSerDeV2.java 38 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestHoodieFileGroupSizeEstimator.java 56 hudi-common/src/test/java/org/apache/hudi/common/table/view/TestPriorityBasedFileSystemView.java 704 hudi-common/src/test/java/org/apache/hudi/common/testutils/Assertions.java 24 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 180 hudi-common/src/test/java/org/apache/hudi/common/testutils/FileCreateUtils.java 494 hudi-common/src/test/java/org/apache/hudi/common/testutils/FileCreateUtilsBase.java 157 hudi-common/src/test/java/org/apache/hudi/common/testutils/FileCreateUtilsLegacy.java 276 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/HoodieTestDataGenerator.java 925 hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestUtils.java 341 hudi-common/src/test/java/org/apache/hudi/common/testutils/InProcessTimeGenerator.java 15 hudi-common/src/test/java/org/apache/hudi/common/testutils/JavaTestUtils.java 15 hudi-common/src/test/java/org/apache/hudi/common/testutils/MockHoodieTimeline.java 29 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 207 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 347 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/ZookeeperTestService.java 160 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/DataGenerationPlan.java 90 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/HoodieFileGroupReaderTestUtils.java 91 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieFileSliceTestUtils.java 385 hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieRecordTestPayload.java 144 hudi-common/src/test/java/org/apache/hudi/common/util/TestBase64CodecUtil.java 22 hudi-common/src/test/java/org/apache/hudi/common/util/TestBaseFileUtils.java 56 hudi-common/src/test/java/org/apache/hudi/common/util/TestBinaryUtil.java 106 hudi-common/src/test/java/org/apache/hudi/common/util/TestCleanerUtils.java 33 hudi-common/src/test/java/org/apache/hudi/common/util/TestCollectionUtils.java 28 hudi-common/src/test/java/org/apache/hudi/common/util/TestConfigUtils.java 86 hudi-common/src/test/java/org/apache/hudi/common/util/TestCustomizedThreadFactory.java 59 hudi-common/src/test/java/org/apache/hudi/common/util/TestDateTimeUtils.java 29 hudi-common/src/test/java/org/apache/hudi/common/util/TestHoodieRecordUtils.java 30 hudi-common/src/test/java/org/apache/hudi/common/util/TestHoodieTimer.java 17 hudi-common/src/test/java/org/apache/hudi/common/util/TestLocalAvroSchemaCache.java 40 hudi-common/src/test/java/org/apache/hudi/common/util/TestMapUtils.java 42 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/TestRatelimiter.java 25 hudi-common/src/test/java/org/apache/hudi/common/util/TestReflectionUtils.java 33 hudi-common/src/test/java/org/apache/hudi/common/util/TestRetryHelper.java 39 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/TestSortUtils.java 78 hudi-common/src/test/java/org/apache/hudi/common/util/TestSystemClock.java 26 hudi-common/src/test/java/org/apache/hudi/common/util/collection/TestFilterIterator.java 35 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 249 hudi-common/src/test/java/org/apache/hudi/common/util/hash/TestBucketIndexUtil.java 167 hudi-common/src/test/java/org/apache/hudi/common/util/hash/TestHashID.java 116 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 59 hudi-common/src/test/java/org/apache/hudi/internal/schema/action/TestTableChanges.java 263 hudi-common/src/test/java/org/apache/hudi/internal/schema/convert/TestAvroInternalSchemaConverter.java 76 hudi-common/src/test/java/org/apache/hudi/internal/schema/utils/TestAvroSchemaEvolutionUtils.java 457 hudi-common/src/test/java/org/apache/hudi/internal/schema/utils/TestInternalSchemaUtils.java 106 hudi-common/src/test/java/org/apache/hudi/io/storage/TestHoodieReaderWriterUtils.java 62 hudi-common/src/test/java/org/apache/hudi/keygen/TestKeyGenerator.java 31 hudi-common/src/test/java/org/apache/hudi/metadata/HoodieBackedTestDelayedTableMetadata.java 27 hudi-common/src/test/java/org/apache/hudi/metadata/TestMetadataPartitionType.java 217 hudi-common/src/test/java/org/apache/hudi/metrics/TestMetrics.java 37 hudi-common/src/test/java/org/apache/hudi/metrics/TestMetricsReporterFactory.java 100 hudi-common/src/test/java/org/apache/hudi/timeline/TestTimelineServiceClient.java 163 hudi-common/src/test/resources/adaptable-payload.avsc 81 hudi-common/src/test/resources/complex-schema-evolved.avsc 30 hudi-common/src/test/resources/complex-test-evolved.avsc 34 hudi-common/src/test/resources/complex.schema.avsc 1881 hudi-common/src/test/resources/date-type-invalid.avsc 25 hudi-common/src/test/resources/date-type.avsc 25 hudi-common/src/test/resources/decimal-logical-type-fixed-type.avsc 35 hudi-common/src/test/resources/decimal-logical-type-invalid.avsc 25 hudi-common/src/test/resources/decimal-logical-type-zero-scale.avsc 25 hudi-common/src/test/resources/decimal-logical-type.avsc 25 hudi-common/src/test/resources/duration-logical-type-invalid.avsc 33 hudi-common/src/test/resources/duration-logical-type.avsc 33 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/local-timestamp-logical-type.avsc 26 hudi-common/src/test/resources/local-timestamp-micros-logical-type.avsc 25 hudi-common/src/test/resources/local-timestamp-millis-logical-type.avsc 25 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/time-logical-type.avsc 26 hudi-common/src/test/resources/timestamp-logical-type.avsc 26 hudi-common/src/test/resources/timestamp-logical-type2.avsc 26 hudi-common/src/test/resources/timestamp-test-evolved.avsc 62 hudi-common/src/test/resources/uuid-logical-type.avsc 25 hudi-examples/hudi-examples-spark/src/test/python/HoodiePySparkQuickstart.py 198 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 44 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/ITTestDataStreamWrite.java 430 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestStreamWriteOperatorCoordinator.java 498 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java 517 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnRead.java 180 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteMergeOnReadWithCompact.java 239 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteWithTimelineBasedCkpMetadata.java 33 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriterWithPartitionTTl.java 54 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bucket/ITTestBucketStreamWrite.java 136 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 98 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/bulk/TestRowDataKeyGen.java 165 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 520 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/CompactionCommitTestSink.java 28 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/ITTestHoodieFlinkCompactor.java 392 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/TestCompactionPlanStrategy.java 101 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/compact/TestCustomSerDe.java 50 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 162 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/BulkInsertFunctionWrapper.java 191 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/ClusteringFunctionWrapper.java 76 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/CompactFunctionWrapper.java 75 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/ConsistentBucketStreamWriteFunctionWrapper.java 43 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/InsertFunctionWrapper.java 151 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/MockKeyedStateStore.java 106 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 65 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockStateInitializationContext.java 53 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockStreamingRuntimeContext.java 93 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/MockSubtaskGateway.java 27 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/RecordsCollector.java 25 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/StreamWriteFunctionWrapper.java 235 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/TestFunctionWrapper.java 58 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 452 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/keyedstate/MockKeyContext.java 13 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/keyedstate/MockKeyedListState.java 63 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/keyedstate/MockKeyedMapState.java 99 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/keyedstate/MockKeyedValueState.java 52 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 191 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestIncrementalInputSplits.java 453 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestStreamReadMonitoringFunction.java 381 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/TestStreamReadOperator.java 203 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/prune/TestColumnStatsProbe.java 58 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/source/stats/TestColumnStatsIndex.java 103 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestHoodieDataSource.java 2252 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/ITTestSchemaEvolution.java 587 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 421 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/HoodieCatalogTestUtils.java 49 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/table/catalog/TestHoodieCatalog.java 383 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 434 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 997 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 55 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 64 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestClusteringUtil.java 101 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestCompactionUtil.java 135 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestConfigurations.java 364 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestData.java 774 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestFlinkWriteClients.java 115 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 65 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestSchemaEvolvingRowDataProjection.java 124 hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/utils/TestStreamerUtil.java 92 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 118 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 159 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.15.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java 7 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/ExecutionAttemptUtil.java 7 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/ExecutionAttemptUtil.java 7 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/ExecutionAttemptUtil.java 7 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-flink-datasource/hudi-flink1.19.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java 7 hudi-flink-datasource/hudi-flink1.19.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java 6 hudi-flink-datasource/hudi-flink1.19.x/src/test/java/org/apache/hudi/adapter/TestStreamConfigs.java 9 hudi-flink-datasource/hudi-flink1.20.x/src/test/java/org/apache/hudi/adapter/ExecutionAttemptUtil.java 7 hudi-flink-datasource/hudi-flink1.20.x/src/test/java/org/apache/hudi/adapter/TestHoodieCatalogs.java 6 hudi-flink-datasource/hudi-flink1.20.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 173 hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestBigQuerySyncToolArgs.java 50 hudi-gcp/src/test/java/org/apache/hudi/gcp/bigquery/TestHoodieBigQuerySyncClient.java 182 hudi-gcp/src/test/java/org/apache/hudi/gcp/transaction/lock/TestGCSStorageBasedLockProvider.java 102 hudi-gcp/src/test/java/org/apache/hudi/gcp/transaction/lock/TestGCSStorageLockClient.java 220 hudi-hadoop-common/src/test/java/org/apache/hudi/client/transaction/lock/TestInProcessLockProvider.java 407 hudi-hadoop-common/src/test/java/org/apache/hudi/client/transaction/lock/TestNoopLockProvider.java 104 hudi-hadoop-common/src/test/java/org/apache/hudi/common/bloom/TestBloomFilter.java 131 hudi-hadoop-common/src/test/java/org/apache/hudi/common/bootstrap/index/TestBaseHoodieTableFileIndex.java 59 hudi-hadoop-common/src/test/java/org/apache/hudi/common/bootstrap/index/TestBootstrapIndex.java 165 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/TestFSUtils.java 551 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/TestFSUtilsWithRetryWrapperEnable.java 213 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/TestHoodieWrapperFileSystem.java 58 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java 62 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/inline/InLineFSUtilsTest.java 34 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystem.java 315 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystemHFileInLiningBase.java 128 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystemWithHBaseHFileReader.java 90 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/inline/TestInLineFileSystemWithHFileReader.java 73 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/inline/TestInMemoryFileSystem.java 92 hudi-hadoop-common/src/test/java/org/apache/hudi/common/fs/inline/TestParquetInLining.java 108 hudi-hadoop-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormat.java 2355 hudi-hadoop-common/src/test/java/org/apache/hudi/common/functional/TestHoodieLogFormatAppendFailure.java 112 hudi-hadoop-common/src/test/java/org/apache/hudi/common/model/TestHoodieFileGroup.java 175 hudi-hadoop-common/src/test/java/org/apache/hudi/common/model/TestHoodiePartitionMetadata.java 71 hudi-hadoop-common/src/test/java/org/apache/hudi/common/model/TestHoodieRecord.java 42 hudi-hadoop-common/src/test/java/org/apache/hudi/common/model/TestHoodieRecordDelegate.java 58 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableConfig.java 397 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/TestHoodieTableMetaClient.java 254 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/TestTableSchemaResolver.java 83 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/TestTimelineUtils.java 513 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/TestTimelineUtilsBackComp.java 83 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/log/TestLogReaderUtils.java 62 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/log/block/TestHoodieDeleteBlock.java 113 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/log/block/TestHoodieLogWriterBuilder.java 48 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/read/TestCustomMerger.java 210 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/read/TestEventTimeMerging.java 160 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/read/TestHoodieFileGroupReaderInflightCommit.java 66 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/read/TestOverwriteWithLatestMerger.java 159 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/timeline/TestArchivedTimelineV1.java 532 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/timeline/TestHoodieActiveTimeline.java 720 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/timeline/TestHoodieInstant.java 68 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/timeline/TestTimelinePathProvider.java 40 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/timeline/TestWaitBasedTimeGenerator.java 117 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/view/TestHoodieTableFSViewWithClustering.java 150 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/view/TestHoodieTableFileSystemView.java 1985 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/view/TestIncrementalFSViewSync.java 693 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDBBasedIncrementalFSViewSync.java 18 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/view/TestRocksDbBasedFileSystemView.java 16 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/view/TestSpillableMapBasedFileSystemView.java 15 hudi-hadoop-common/src/test/java/org/apache/hudi/common/table/view/TestSpillableMapBasedIncrementalFSViewSync.java 16 hudi-hadoop-common/src/test/java/org/apache/hudi/common/testutils/FileSystemTestUtils.java 40 hudi-hadoop-common/src/test/java/org/apache/hudi/common/testutils/HadoopFSTestUtils.java 17 hudi-hadoop-common/src/test/java/org/apache/hudi/common/testutils/HoodieCommonTestHarness.java 342 hudi-hadoop-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestTable.java 1317 hudi-hadoop-common/src/test/java/org/apache/hudi/common/testutils/minicluster/HdfsTestService.java 80 hudi-hadoop-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieFileGroupReaderTestHarness.java 111 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestAvroOrcUtils.java 49 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestClusteringUtils.java 214 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestCommitUtils.java 170 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestCompactionUtils.java 351 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestDFSPropertiesConfiguration.java 157 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestFileIOUtils.java 83 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestHFileUtils.java 31 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestHadoopConfigUtils.java 36 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestMarkerUtils.java 54 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestParquetReaderIterator.java 36 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestParquetUtils.java 325 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/TestTablePathUtils.java 118 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/collection/TestBitCaskDiskMap.java 201 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/collection/TestExternalSpillableMap.java 340 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/collection/TestRocksDbBasedMap.java 40 hudi-hadoop-common/src/test/java/org/apache/hudi/common/util/collection/TestRocksDbDiskMap.java 170 hudi-hadoop-common/src/test/java/org/apache/hudi/hadoop/fs/TestHadoopFSUtils.java 91 hudi-hadoop-common/src/test/java/org/apache/hudi/internal/schema/io/TestFileBasedInternalSchemaStorageManager.java 76 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieAvroFileReaderFactory.java 38 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieBaseParquetWriter.java 85 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieHBaseHFileReaderWriter.java 111 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieHFileReaderWriter.java 61 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieHFileReaderWriterBase.java 431 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieHadoopIOFactory.java 37 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieOrcReaderWriter.java 82 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestHoodieReaderWriterBase.java 236 hudi-hadoop-common/src/test/java/org/apache/hudi/io/hadoop/TestOrcReaderIterator.java 69 hudi-hadoop-common/src/test/java/org/apache/hudi/metadata/TestFileSystemBackedTableMetadata.java 160 hudi-hadoop-common/src/test/java/org/apache/hudi/metadata/TestHoodieMetadataPayload.java 267 hudi-hadoop-common/src/test/java/org/apache/hudi/metadata/TestHoodieTableMetadataUtil.java 605 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 37 hudi-hadoop-common/src/test/java/org/apache/parquet/avro/TestHoodieAvroReadSupport.java 92 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/TestHiveHoodieReaderContext.java 70 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 378 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieParquetInputFormat.java 603 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestHoodieROTablePathFilter.java 70 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/TestInputPathHandler.java 172 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 391 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieMergeOnReadSnapshotReader.java 150 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieMergeOnReadTableInputFormat.java 55 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieRealtimeFileSplit.java 128 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/realtime/TestHoodieRealtimeRecordReader.java 785 hudi-hadoop-mr/src/test/java/org/apache/hudi/hadoop/testutils/InputFormatTestUtil.java 444 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/TestHoodieArrayWritableAvroUtils.java 77 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 327 hudi-integ-test/src/test/java/org/apache/hudi/integ/ITTestHoodieDemo.java 395 hudi-integ-test/src/test/java/org/apache/hudi/integ/ITTestHoodieSanity.java 152 hudi-integ-test/src/test/java/org/apache/hudi/integ/command/ITTestHoodieSyncCommand.java 42 hudi-integ-test/src/test/java/org/apache/hudi/integ/testsuite/TestDFSHoodieTestSuiteWriterAdapter.java 100 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 85 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/testutils/NetworkTestUtils.java 13 hudi-io/src/test/java/org/apache/hudi/common/util/TestStringUtils.java 206 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 791 hudi-io/src/test/java/org/apache/hudi/io/storage/BaseTestStorageConfiguration.java 118 hudi-io/src/test/java/org/apache/hudi/io/storage/TestHoodieStorageBase.java 317 hudi-io/src/test/java/org/apache/hudi/io/storage/TestStoragePath.java 203 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 83 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 72 hudi-kafka-connect/src/test/java/org/apache/hudi/writers/TestKafkaConnectTransactionServices.java 33 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/TestDataSourceUtils.java 35 hudi-spark-datasource/hudi-spark-common/src/test/java/org/apache/hudi/TestHoodieSchemaUtils.java 274 hudi-spark-datasource/hudi-spark-common/src/test/java/org/apache/hudi/TestHoodieWriterUtils.java 23 hudi-spark-datasource/hudi-spark-common/src/test/java/org/apache/hudi/testutils/LogFileColStatsTestUtil.java 68 hudi-spark-datasource/hudi-spark-common/src/test/java/org/apache/hudi/testutils/SparkDatasetTestUtils.java 169 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/hudi/ScalaTestUtils.scala 8 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/TestRecordLevelIndexSupport.scala 81 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/hudi/TestSecondaryIndexSupport.scala 61 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/hudi/schema/TestHoodieSparkSchemaUtils.scala 31 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/execution/datasources/TestHoodieInMemoryFileIndex.scala 34 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/execution/datasources/parquet/TestSparkFileFormatInternalRowReaderContext.scala 70 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/TestSparkParquetReaderFormat.scala 30 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/sql/hive/TestHiveClientUtils.scala 27 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/sql/hudi/TestHoodieFileIndex.scala 12 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/sql/hudi/TestProvidesHoodieConfig.scala 121 hudi-spark-datasource/hudi-spark-common/src/test/scala/org/apache/spark/sql/hudi/TestSparkConfigUtils.scala 27 hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaApp.java 184 hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaGenerateApp.java 135 hudi-spark-datasource/hudi-spark/src/test/java/HoodieJavaStreamingApp.java 285 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/ColumnStatsIndexHelper.java 176 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestDataSourceReadWithDeletes.java 147 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestDataSourceUtils.java 232 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestDecimalTypeDataWorkflow.scala 98 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestDefaultSparkRecordMerger.java 146 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/TestMetadataTableSupport.java 73 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/TestPositionBasedFileGroupRecordBuffer.java 207 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/client/TestHoodieClientMultiWriter.java 1102 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/TestMultiWriterWithPreferWriterIngestion.java 213 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/TestTableSchemaEvolution.java 289 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestConsistentBucketIndex.java 237 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestDataValidationCheckForLogCompactionActions.java 313 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestHoodieBackedMetadata.java 2951 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnMergeOnReadStorage.java 406 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestMetadataUtilRLIandSIRecordGeneration.java 536 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestRemoteFileSystemViewWithMetadataTable.java 244 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestSavepointRestoreMergeOnRead.java 249 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/execution/bulkinsert/TestBulkInsertInternalPartitionerForRows.java 180 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/HoodieSparkFunctionalTestSuiteA.java 10 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/HoodieSparkFunctionalTestSuiteB.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 542 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 241 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestColStatsRecordWithMetadataRecord.java 423 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestDataSkippingWithMORColstats.java 325 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestFiltersInFileGroupReader.java 65 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestGlobalIndexEnableUpdatePartitions.java 309 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestHiveTableSchemaEvolution.java 204 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 199 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestNewHoodieParquetFileFormat.java 118 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestOrcBootstrap.java 448 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestSparkClusteringCornerCases.java 53 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestSparkConsistentBucketClustering.java 296 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestSparkParquetReader.java 24 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestSparkSortAndSizeClustering.java 135 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/functional/TestWriteClient.java 57 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/io/storage/row/TestHoodieInternalRowParquetWriter.java 94 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/io/storage/row/TestHoodieRowCreateHandle.java 166 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 321 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 390 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/table/TestHoodieMergeOnReadTable.java 607 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/action/compact/TestAsyncCompaction.java 327 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/action/compact/TestHoodieCompactor.java 377 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/action/compact/TestInlineCompaction.java 262 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/action/compact/strategy/SmallBoundedIOCompactionStrategy.java 34 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/action/rollback/TestMergeOnReadRollbackActionExecutor.java 363 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkCopyOnWriteTableRollbackTableVersionSix.java 23 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableCompaction.java 362 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableIncrementalRead.java 183 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableInsertUpdateDelete.java 349 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkMergeOnReadTableRollback.java 839 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/functional/TestHoodieSparkRollback.java 218 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/table/functional/TestSparkNonBlockingConcurrencyControl.java 535 hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/testutils/DataSourceTestUtils.java 161 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 71 hudi-spark-datasource/hudi-spark/src/test/resources/sql-statements.sql 249 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/TestIncrementalQueryWithArchivedInstants.scala 78 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/TestAutoKeyGenForSQL.scala 67 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestAvroConversionHelper.scala 30 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestAvroConversionUtils.scala 418 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestAvroSchemaResolutionSupport.scala 714 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 26 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieFileIndex.scala 672 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieParquetBloom.scala 62 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 1026 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestHoodieSparkSqlWriterPartitionTTL.scala 53 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 167 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestInsertDedupPolicy.scala 104 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestMultipleTableVersionWriting.scala 34 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestParquetReaderCompatibility.scala 245 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/TestPartitionDirectoryConverter.scala 132 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 89 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 310 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/common/table/read/TestSpark35RecordPositionMetadataColumn.scala 100 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/ColumnStatIndexTestBase.scala 448 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/HoodieStatsIndexTestBase.scala 167 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/PartitionStatsIndexTestBase.scala 121 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/RecordLevelIndexTestBase.scala 119 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestAutoGenerationOfRecordKeys.scala 222 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestBasicSchemaEvolution.scala 279 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestBloomFiltersIndexSupport.scala 220 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestBucketIndexSupport.scala 321 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestCOWDataSource.scala 1623 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestCOWDataSourceStorage.scala 342 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestColumnStatsIndex.scala 854 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestColumnStatsIndexWithSQL.scala 615 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestDataSourceForBootstrap.scala 506 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 190 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestHoodieMultipleBaseFileFormat.scala 95 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestIncrementalReadByStateTransitionTime.scala 71 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestIncrementalReadWithFullTableScan.scala 129 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestLayoutOptimization.scala 142 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMORDataSource.scala 1321 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMORDataSourceStorage.scala 298 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 170 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestMetadataTableWithSparkDataSource.scala 289 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 326 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestPartialUpdateAvroPayload.scala 104 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestPartitionBucketIndexSupport.scala 157 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestPartitionStatsIndex.scala 494 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestPartitionStatsIndexWithSql.scala 550 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestPartitionStatsPruning.scala 327 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestRecordLevelIndex.scala 551 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestRecordLevelIndexTableVersionSix.scala 9 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestRecordLevelIndexWithSQL.scala 328 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSecondaryIndexPruning.scala 1434 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSevenToEightUpgrade.scala 199 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSixToFiveDowngradeHandler.scala 114 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkDataSource.scala 383 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 405 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkSqlWithCustomKeyGenerator.scala 633 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestSparkSqlWithTimestampKeyGenerator.scala 157 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 63 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestStreamingSource.scala 305 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestStructuredStreaming.scala 451 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestTimeTravelQuery.scala 284 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/TestWriteTableVersionConfig.scala 34 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/cdc/HoodieCDCTestBase.scala 162 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/cdc/TestCDCDataFrameSuite.scala 629 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/functional/cdc/TestCDCStreamingSuite.scala 148 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/util/JavaConversions.scala 27 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/util/TestPathUtils.scala 50 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/hudi/util/TestSparkInternalSchemaConverter.scala 63 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 36 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 55 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/BoundInMemoryExecutorBenchmark.scala 112 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/CowTableReadBenchmark.scala 93 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/LSMTimelineReadBenchmark.scala 72 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/execution/benchmark/ReadAndWriteWithoutAvroBenchmark.scala 126 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/analysis/TestMergeIntoHoodieTableCommand.scala 77 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/HoodieSparkSqlTestBase.scala 382 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestHoodieInternalRowUtils.scala 246 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestHoodieOptionConfig.scala 123 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 120 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 73 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestTableColumnTypeMismatch.scala 716 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/common/TestVectorizedReadWithSchemaEvolution.scala 45 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestAlterTable.scala 424 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 547 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestCreateTable.scala 1468 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestDescribeTable.scala 75 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestDropTable.scala 333 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestRepairTable.scala 156 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestShowPartitions.scala 251 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestSpark3DDL.scala 940 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/ddl/TestTruncateTable.scala 100 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestDeleteFromTable.scala 68 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestDeleteTable.scala 285 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestHoodieTableValuedFunction.scala 614 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestInsertTable.scala 3028 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestInsertTableWithPartitionBucketIndex.scala 541 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 1489 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeIntoTable2.scala 1048 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeIntoTableWithNonRecordKeyField.scala 334 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeModeCommitTimeOrdering.scala 283 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestMergeModeEventTimeOrdering.scala 282 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestPartialUpdateForMergeInto.scala 592 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestTimeTravelTable.scala 255 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/dml/TestUpdateTable.scala 381 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/TestCDCForSparkSQL.scala 252 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/TestCompactionTable.scala 155 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/TestDataSkippingQuery.scala 168 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/TestQueryMergeOnReadOptimizedTable.scala 50 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/index/TestExpressionIndex.scala 1910 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/index/TestGlobalIndex.scala 61 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/index/TestIndexSyntax.scala 188 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/feature/index/TestSecondaryIndex.scala 465 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 195 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCallCommandParser.scala 93 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 720 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 304 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestCopyToTableProcedure.scala 293 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/TestDropPartitionProcedure.scala 174 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 210 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 431 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestRunRollbackInflightTableServiceProcedure.scala 89 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/TestShowFileStatusProcedure.scala 245 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 182 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/TestTruncateTableProcedure.scala 87 hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestUpgradeOrDowngradeProcedure.scala 159 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 253 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 247 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 103 hudi-spark-datasource/hudi-spark3.5.x/src/test/java/org/apache/hudi/spark3/internal/TestHoodieDataSourceInternalBatchWrite.java 246 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 256 hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/TestDataHubSyncTool.java 42 hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/TestDataHubTableProperties.java 51 hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/config/TestDataHubSyncConfig.java 49 hudi-sync/hudi-datahub-sync/src/test/java/org/apache/hudi/sync/datahub/config/TestHoodieDataHubDatasetIdentifier.java 123 hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/TestHiveSyncTool.java 1601 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/TestParquetToSparkSchemaUtils.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 121 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 725 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/TestHoodieSyncClient.java 41 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/TestHoodieSyncTool.java 18 hudi-sync/hudi-sync-common/src/test/java/org/apache/hudi/sync/common/metrics/TestHoodieMetaSyncMetrics.java 77 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 194 hudi-tests-common/pom.xml 207 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/MockHoodieHadoopStorage.java 52 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/TestRequestHandler.java 111 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/TestTimelineService.java 79 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/TimelineServiceTestHarness.java 139 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/functional/TestRemoteHoodieTableFileSystemView.java 141 hudi-timeline-service/src/test/java/org/apache/hudi/timeline/service/handlers/marker/TestMarkerBasedEarlyConflictDetectionRunnable.java 88 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 145 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieIndexer.java 483 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieMetadataTableValidator.java 1280 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieRepairTool.java 349 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestHoodieSnapshotExporter.java 31 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestManifestFileWriterSpark.java 83 hudi-utilities/src/test/java/org/apache/hudi/utilities/TestSchemaPostProcessor.java 130 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 699 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 2778 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerDAGExecution.java 84 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerErrorTableWriteFlow.java 86 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerSchemaEvolutionBase.java 337 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerSchemaEvolutionExtensive.java 494 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerSchemaEvolutionQuick.java 582 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieDeltaStreamerWithMultiWriter.java 395 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestHoodieMultiTableDeltaStreamer.java 238 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestSchedulerConfGenerator.java 65 hudi-utilities/src/test/java/org/apache/hudi/utilities/deltastreamer/TestSourceFormatAdapter.java 150 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/TestHiveSchemaProvider.java 104 hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieSnapshotExporter.java 335 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 288 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 135 hudi-utilities/src/test/java/org/apache/hudi/utilities/offlinejob/TestHoodieCompactorJob.java 87 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/TestFilebasedSchemaProvider.java 65 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 142 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/converter/TestJsonToAvroSchemaConverter.java 65 hudi-utilities/src/test/java/org/apache/hudi/utilities/schema/converter/TestProtoSchemaToAvroSchemaConverter.java 28 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/BaseTestKafkaSource.java 239 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/CheckpointValidator.java 89 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/DummyOperationExecutor.java 52 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/MockGcsEventsHoodieIncrSource.java 46 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/MockGeneralHoodieIncrSource.java 26 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/MockS3EventsHoodieIncrSource.java 49 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSourceHarness.java 236 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 247 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 42 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsHoodieIncrSource.java 402 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestGcsEventsSource.java 216 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 702 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 317 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 434 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 34 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestProtoKafkaSource.java 222 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsHoodieIncrSource.java 278 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestS3EventsSource.java 90 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/TestSqlFileBasedSource.java 130 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 158 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 178 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestDFSPathSelectorCommonMethods.java 131 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestDatePartitionPathSelector.java 158 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestIncrSourceHelper.java 315 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestKafkaOffsetGen.java 485 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestKafkaSourceUtil.java 40 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestMercifulJsonToRowConverter.java 464 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestProtoConversionUtil.java 523 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/TestS3EventsMetaSelector.java 97 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 70 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/gcs/TestPubsubMessagesFetcher.java 79 hudi-utilities/src/test/java/org/apache/hudi/utilities/sources/helpers/gcs/TestPubsubQueueClient.java 53 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestErrorTableUtils.java 41 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestHoodieIncrSourceE2E.java 306 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestHoodieIncrSourceE2EAutoUpgrade.java 210 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestHoodieStreamerMetrics.java 43 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestHoodieStreamerUtils.java 66 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSync.java 294 hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamerCheckpointUtils.java 367 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 451 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 62 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 50 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 60 hudi-utilities/src/test/resources/exporter/sql-file-transformer.sql 1 hudi-utilities/src/test/resources/hive-site.xml 16 hudi-utilities/src/test/resources/schema-provider/proto/evolved.proto 44 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/evolved-test-with-default-value.avsc 42 hudi-utilities/src/test/resources/schema/nested_data_schema.avsc 81 hudi-utilities/src/test/resources/schema/sample_data_schema.avsc 28 hudi-utilities/src/test/resources/schema/sample_gcs_data.avsc 31 hudi-utilities/src/test/resources/schema/simple-test-with-default-value.avsc 37 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_short_trip_uber.avsc 43 hudi-utilities/src/test/resources/streamer-config/source_uber.avsc 43 hudi-utilities/src/test/resources/streamer-config/source_uber_encoded_decimal.avsc 77 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 594 packaging/hudi-integ-test-bundle/src/main/java/org/apache/hudi/testsuite/bundle/Main.java 7