amoro
Apache Amoro(incubating) is a Lakehouse management system built on open data lake formats.
파일 탐색기
최종 버전 다운로드 (.zip)파일 수가 많아 일부만 표시됩니다. 전체 파일은 위 다운로드 버튼으로 확인해 주세요.
- bug_report.yml
- config.yml
- feature_request.yml
- improvement.yml
- subtask.yml
- core-hadoop2-ci.yml
- core-hadoop3-ci.yml
- deps.yml
- docker-images.yml
- helm-charts-ci.yml
- labeler.yml
- mcp-server-ci.yml
- openapi-sdk-ci.yml
- site-deploy.yml
- stale.yml
- take.yml
- trino-ci.yml
- labeler.yml
- PULL_REQUEST_TEMPLATE
- release.yml
- icon.svg
- vcs.xml
- maven-wrapper.properties
- jvm.config
- DefaultPasswdAuthenticationProvider.java
- DefaultPasswordCredential.java
- DefaultTokenCredential.java
- HttpAuthenticationFactory.java
- LdapPasswdAuthenticationProvider.java
- AuthorizationRequest.java
- CasbinAuthorizationManager.java
- DashboardPrivilegeMapper.java
- DashboardPrivilegeMappingRule.java
- LdapGroupRoleResolver.java
- Privilege.java
- ResourceType.java
- Role.java
- RoleResolver.java
- CatalogBuilder.java
- CatalogManager.java
- CatalogType.java
- DatabaseMetadata.java
- DefaultCatalogManager.java
- ExternalCatalog.java
- InternalCatalog.java
- InternalCatalogImpl.java
- ServerCatalog.java
- IcebergTableMetaExtract.java
- IcebergTypeToSparkType.java
- ApiTokenController.java
- CatalogController.java
- HealthCheckController.java
- LoginController.java
- OptimizerController.java
- OptimizerGroupController.java
- OverviewController.java
- PlatformFileInfoController.java
- SettingController.java
- TableController.java
- TerminalController.java
- VersionController.java
- ApiTokens.java
- CatalogRegisterInfo.java
- CatalogSettingInfo.java
- HiveTableInfo.java
- KafkaClusterSimpleInfo.java
- LatestSessionInfo.java
- LogInfo.java
- OptimizerInstanceInfo.java
- OptimizerResourceInfo.java
- OverviewDataSizeItem.java
- OverviewResourceUsageItem.java
- OverviewSummary.java
- OverviewTopTableItem.java
- PlatformFileInfo.java
- SessionInfo.java
- SnapshotInfo.java
- SqlExample.java
- SqlResult.java
- SqlStatus.java
- TableBasicInfo.java
- TableMeta.java
- TableOperation.java
- TableOptimizingInfo.java
- TableStatistics.java
- UpgradeHiveMeta.java
- UpgradeRunningInfo.java
- UpgradeStatus.java
- VersionInfo.java
- ErrorResponse.java
- OkResponse.java
- PageResult.java
- Response.java
- AmsUtil.java
- CommonUtil.java
- DesensitizationUtil.java
- OptimizingUtil.java
- ParamSignatureCalculator.java
- PropertiesUtil.java
- TableStatCollector.java
- APITokenManager.java
- DashboardServer.java
- JavalinJsonMapper.java
- MixedAndIcebergTableDescriptor.java
- OverviewManager.java
- PlatformFileManager.java
- ServerTableDescriptor.java
- ServerTableProperties.java
- LoggingEventListener.java
- DataBaseHighAvailabilityContainer.java
- HighAvailabilityContainer.java
- HighAvailabilityContainerFactory.java
- NoopHighAvailabilityContainer.java
- ZkHighAvailabilityContainer.java
- AbstractOptimizerContainer.java
- AbstractPluginManager.java
- ClassLoaderContext.java
- EventsManager.java
- ExecUtil.java
- FlinkOptimizerContainer.java
- KubernetesOptimizerContainer.java
- LocalOptimizerContainer.java
- MetricManager.java
- PluginConfiguration.java
- PluginManager.java
- SparkOptimizerContainer.java
- DynamicAllocationConfig.java
- DynamicAllocationMetrics.java
- DynamicAllocationState.java
- PendingRegistrations.java
- DefaultTableMaintainerContext.java
- TableMaintainerFactory.java
- TableMaintainers.java
- BalancedSorter.java
- QuotaOccupySorter.java
- SorterFactory.java
- KeyedTableCommit.java
- OptimizerGroupMetrics.java
- OptimizingProcess.java
- OptimizingQueue.java
- OptimizingStatus.java
- OptimizingTaskMeta.java
- SchedulingPolicy.java
- TaskRuntime.java
- UnKeyedTableCommit.java
- JsonObjectConverter.java
- List2StringConverter.java
- Long2TsConverter.java
- Map2StringConverter.java
- MapLong2StringConverter.java
- Object2ByteArrayConvert.java
- OptimizingStatusConverter.java
- TableFormatConverter.java
- TaskDescriptorTypeConverter.java
- InListExtendedLanguageDriver.java
- ApiTokensMapper.java
- BucketAssignMapper.java
- CatalogMetaMapper.java
- HaLeaseMapper.java
- OptimizerMapper.java
- OptimizingProcessMapper.java
- PlatformFileMapper.java
- ResourceMapper.java
- TableBlockerMapper.java
- TableMetaMapper.java
- TableProcessMapper.java
- TableRuntimeMapper.java
- BucketAssignmentMeta.java
- BucketIdCount.java
- DataSourceFactory.java
- HaLeaseMeta.java
- HttpSessionHandlerFactory.java
- NestedSqlSession.java
- OptimizingProcessState.java
- PersistentBase.java
- ProcessSimpleMeta.java
- SqlSessionFactoryProvider.java
- StatedPersistentBase.java
- TableRuntimeMeta.java
- TableRuntimeState.java
- TaskFilesPersistence.java
- TableProcessExecutor.java
- DanglingDeleteFilesCleaningProcess.java
- DataExpiringProcess.java
- HiveCommitSyncProcess.java
- IcebergProcessFactory.java
- OrphanFilesCleaningProcess.java
- SnapshotsExpiringProcess.java
- TagsAutoCreatingProcess.java
- ActionCoordinatorScheduler.java
- DefaultTableProcessStore.java
- ProcessService.java
- TableProcessFactoryManager.java
- TableProcessMeta.java
- ContainerMetadata.java
- Containers.java
- DefaultOptimizerManager.java
- OptimizerInstance.java
- OptimizerManager.java
- OptimizerThread.java
- QuotaProvider.java
- BlockerExpiringExecutor.java
- InlineTableExecutors.java
- OptimizingCommitExecutor.java
- ProcessDataExpiringExecutor.java
- TableRuntimeRefreshExecutor.java
- PeriodicTableScheduler.java
- TableBlocker.java
- TableBlockerManager.java
- TableRuntimeCleanupState.java
- IcebergInternalTableOperations.java
- InternalIcebergCreator.java
- InternalIcebergHandler.java
- InternalMixedIcebergCreator.java
- InternalMixedIcebergHandler.java
- InternalTableConstants.java
- InternalTableCreator.java
- InternalTableHandler.java
- InternalTableManager.java
- MixedIcebergInternalTableStoreOperations.java
- AbstractTableMetrics.java
- AbstractTableRuntime.java
- DefaultActionCoordinator.java
- DefaultTableManager.java
- DefaultTableRuntime.java
- DefaultTableRuntimeFactory.java
- DefaultTableRuntimeStore.java
- DefaultTableService.java
- MaintainedTableManager.java
- RuntimeHandlerChain.java
- SupportProcessManagement.java
- TableConfigurations.java
- TableManager.java
- TableMetadata.java
- TableOptimizingMetrics.java
- TableOrphanFilesCleaningMetrics.java
- TableRuntimeHandler.java
- TableService.java
- TableSummaryMetrics.java
- KyuubiSession.java
- KyuubiTerminalSessionFactory.java
- LocalSessionFactory.java
- LocalTerminalSession.java
- ExecutionResult.java
- ExecutionStatus.java
- JDBCResultSet.java
- SimpleResultSet.java
- SparkContextUtil.java
- StatementResult.java
- TerminalManager.java
- TerminalSession.java
- TerminalSessionContext.java
- TerminalSessionFactory.java
- CompressUtil.java
- FlinkClientUtil.java
- HiveLocationUtil.java
- IcebergTableUtil.java
- InternalTableUtil.java
- PreconditionUtils.java
- SnowflakeIdGenerator.java
- StructuredOptionsSplitter.java
- ThriftServiceProxy.java
- AmoroManagementConf.java
- AmoroManagementConfValidator.java
- AmoroServiceConstants.java
- AmoroServiceContainer.java
- AmsAssignService.java
- AmsServiceMetrics.java
- BucketAssignStore.java
- BucketAssignStoreFactory.java
- DBBucketAssignStore.java
- DefaultOptimizingService.java
- Environments.java
- RestCatalogService.java
- RestExtension.java
- RestExtensionFactory.java
- RestExtensionManager.java
- TableManagementService.java
- ZkBucketAssignStore.java
- amoro_rbac_model.conf
- amoro_rbac_policy.csv
- privilege_mapping.yaml
- ams-derby-init.sql
- upgrade.sql
- org.apache.amoro.events.EventListener
- org.apache.amoro.metrics.MetricReporter
- org.apache.amoro.process.ProcessFactory
- org.apache.amoro.resource.ResourceContainer
- org.apache.amoro.server.optimizing.sorter.SorterFactory
- org.apache.amoro.server.RestExtensionFactory
- org.apache.amoro.table.descriptor.FormatTableDescriptor
- ams-mysql-init.sql
- upgrade-0.3.0-to-0.3.1.sql
- upgrade-0.3.1-to-0.3.2.sql
- upgrade-0.3.2-to-0.4.0.sql
- upgrade-0.4.0-to-0.4.1.sql
- upgrade-0.4.1-to-0.5.0.sql
- upgrade-0.5.0-to-0.5.1.sql
- upgrade-0.5.1-to-0.6.0.sql
- upgrade-0.6.1-to-0.7.0.sql
- upgrade-0.7.0-to-0.8.0.sql
- upgrade.sql
- openapi.yaml
- ams-postgres-init.sql
- upgrade-0.5.1-to-0.6.0.sql
- upgrade-0.6.1-to-0.7.0.sql
- upgrade-0.7.0-to-0.8.0.sql
- upgrade.sql
- log4j2.xml
- ConfigurationsTest.java
- HttpAuthenticationFactoryTest.java
- LdapPasswdAuthenticationProviderTest.java
- UserDefinedTokenAuthenticationProviderImpl.java
- CasbinAuthorizationManagerTest.java
- LdapGroupRoleResolverTest.java
- RoleResolverTest.java
- TableCatalogTestBase.java
- TestDefaultCatalogManagerRecovery.java
- TestServerCatalog.java
- TestConfigShade.java
- TestOptimizingUtil.java
- TestParamSignatureCalculator.java
- TestPropertiesUtil.java
- TestDashboardAuthentication.java
- TestIcebergServerTableDescriptor.java
- TestOverviewManager.java
- DatabaseHaEdgeCasesIT.java
- DataBaseHighAvailabilityContainerIT.java
- HATestConfigs.java
- TestZkHighAvailabilityContainer.java
- TestAbstractPluginManager.java
- TestFlinkOptimizerContainer.java
- TestKubernetesOptimizerContainer.java
- TestSparkOptimizerContainer.java
- MockedMetricReporter.java
- TestMixIcebergCommit.java
- TestUnKeyedTableCommit.java
- TestComputeScaleDown.java
- TestComputeScaleUp.java
- TestDynamicAllocationConfig.java
- TestDynamicAllocationMetrics.java
- TestDynamicAllocationState.java
- TestPendingRegistrations.java
- AbstractHiveChecker.java
- AbstractSceneCountChecker.java
- DataConcurrencyChecker.java
- FullOptimizingMove2HiveChecker.java
- FullOptimizingWrite2HiveChecker.java
- MajorOptimizingChecker.java
- MinorOptimizingCheck.java
- OptimizingCountChecker.java
- AbstractTableDataView.java
- KeyedTableDataView.java
- MatchResult.java
- TableDataView.java
- UnKeyedTableDataView.java
- CompleteOptimizingFlow.java
- DataReader.java
- RandomRecordGenerator.java
- TestKeyedContinuousOptimizing.java
- TestUnKeyedContinuousOptimizing.java
- TestDataExpire.java
- TestDataExpireHive.java
- TestDataExpireIceberg.java
- TestExpireSnapshotsKeepReferencedFiles.java
- TestOrphanFileClean.java
- TestOrphanFileCleanHive.java
- TestOrphanFileCleanIceberg.java
- TestSnapshotExpire.java
- TestSnapshotExpireHive.java
- TestSnapshotExpireIceberg.java
- TestTableMaintainerContext.java
- MixedTablePlanTestBase.java
- TestHiveKeyedPartitionPlan.java
- TestHiveOptimizingEvaluator.java
- TestHiveUnkeyedPartitionPlan.java
- TestIcebergPartitionPlan.java
- TestKeyedPartitionPlan.java
- TestOptimizingEvaluator.java
- TestOptimizingPlanner.java
- TestUnkeyedPartitionPlan.java
- TableFileScanHelperTestBase.java
- TestHiveKeyedTableFileScanHelper.java
- TestHiveUnkeyedTableFileScanHelper.java
- TestIcebergTableFileScanHelper.java
- TestKeyedTableFileScanHelper.java
- TestUnkeyedTableFileScanHelper.java
- AbstractOptimizingTest.java
- BaseOptimizingChecker.java
- OptimizingStatusTest.java
- OptimizingTestHelpers.java
- TestIcebergHadoopOptimizing.java
- TestMixedHiveOptimizing.java
- TestMixedIcebergOptimizing.java
- TestOptimizingIntegration.java
- TestOptimizingQueue.java
- TestTaskRuntime.java
- TestLong2TsConverter.java
- TestTableMetaMapper.java
- TestDerbyUpgrade.java
- TestNestedSqlSession.java
- TestPersistentBase.java
- TestStatedPersistentBase.java
- TestTableProcessExecutor.java
- TestIcebergProcessFactory.java
- MockActionCoordinator.java
- MockExecuteEngine.java
- MockTableProcess.java
- TestProcessServiceMultiFormat.java
- ThrowingRecoverActionCoordinator.java
- ExecutorTestBase.java
- TestBlockerExpiringExecutor.java
- TestConfigurableIntervalExecutors.java
- TestProcessDataExpiringExecutor.java
- TestTableRuntimeRefreshExecutor.java
- TestIcebergInternalTableOperations.java
- AMSTableTestBase.java
- DerbyPersistence.java
- TestCatalogService.java
- TestDatabaseService.java
- TestDefaultTableRuntimeHandler.java
- TestDefaultTableRuntimeManager.java
- TestDefaultTableRuntimeStore.java
- TestSyncTableOfExternalCatalog.java
- TestTableManager.java
- TestTableManagerQuery.java
- TestTableSummaryMetrics.java
- TestTableSummaryWithoutOptimizing.java
- KerberizedTestHelper.java
- TestCompressUtil.java
- TestConfigurationUtil.java
- TestIcebergTableUtil.java
- TestSnowflakeIdGenerator.java
- AmoroAMSTest.java
- AmsEnvironment.java
- AMSManagerTestBase.java
- AMSServiceTestBase.java
- HighAvailabilityContainerTest.java
- RestCatalogServiceTestBase.java
- TestAmoroManagementConf.java
- TestAmoroManagementConfValidator.java
- TestAmsAssignService.java
- TestAmsServiceMetrics.java
- TestDefaultOptimizingService.java
- TestDefaultProcessService.java
- TestHighAvailabilityContainer.java
- TestInternalIcebergCatalogService.java
- TestInternalMixedCatalogService.java
- TestOptimizerGroupController.java
- TestOptimizerGroupKeeper.java
- TestOptimizerScaleKeeper.java
- TestRestCatalogService.java
- TestZkBucketAssignStore.java
- config-base64-shade.yaml
- config-default-shade.yaml
- users.ldif
- org.apache.amoro.metrics.MetricReporter
- org.apache.amoro.server.manager.TestAbstractPluginManager$TestPlugin
- org.mockito.plugins.MockMaker
- config-with-units.yaml
- config-without-units.yaml
- config.yaml
- docker-java.properties
- flink-conf.yaml
- log4j2.xml
- pom.xml
- AlreadyExistsException.java
- AmoroException.java
- AmoroTableMetastore.java
- BlockableOperation.java
- Blocker.java
- CatalogMeta.java
- ColumnInfo.java
- CommitMetaProducer.java
- DataFile.java
- InvalidObjectException.java
- MetaException.java
- NoSuchObjectException.java
- NotSupportedException.java
- OperationConflictException.java
- OptimizerRegisterInfo.java
- OptimizingService.java
- OptimizingTask.java
- OptimizingTaskId.java
- OptimizingTaskResult.java
- PartitionFieldData.java
- PrimaryKeySpec.java
- Schema.java
- SchemaUpdateMeta.java
- TableChange.java
- TableCommitMeta.java
- TableIdentifier.java
- TableMeta.java
- UpdateColumn.java
- BasicPrincipal.java
- PasswdAuthenticationProvider.java
- PasswordCredential.java
- TokenAuthenticationProvider.java
- TokenCredential.java
- AmoroZookeeperFactory.java
- AmsClientPools.java
- AmsServerInfo.java
- AmsThriftUrl.java
- ClientPool.java
- ClientPoolImpl.java
- ConnectionFailException.java
- NoBackendServiceException.java
- OptimizingClientPools.java
- PoolConfig.java
- ServiceInfo.java
- ThriftClient.java
- ThriftClientFactory.java
- ThriftClientPool.java
- ThriftException.java
- ThriftPingFactory.java
- ThriftUtil.java
- ZookeeperService.java
- Base64ConfigShade.java
- ConfigShadeUtils.java
- ConfigShade.java
- ConfigHelpers.java
- ConfigOption.java
- ConfigOptions.java
- ConfigurationException.java
- Configurations.java
- DataExpirationConfig.java
- OptimizingConfig.java
- StructuredOptionsSplitter.java
- TableConfiguration.java
- TagConfiguration.java
- Event.java
- EventListener.java
- EventType.java
- TableEvent.java
- AlreadyExistsException.java
- AmoroRuntimeException.java
- BlockerConflictException.java
- BucketAssignStoreException.java
- ForbiddenException.java
- IllegalMetadataException.java
- IllegalTaskStateException.java
- LoadingPluginException.java
- ObjectNotExistsException.java
- OptimizingClosedException.java
- OptimizingCommitException.java
- PersistenceException.java
- PluginAuthException.java
- PluginRetryAuthException.java
- SignatureCheckException.java
- TaskNotFoundException.java
- TaskRuntimeException.java
- UndefinedException.java
- AuthenticatedHiveClientPool.java
- CachedHiveClientPool.java
- HMSClient.java
- HMSClientImpl.java
- HMSClientPool.java
- MaintainerMetrics.java
- OptimizingInfo.java
- TableMaintainer.java
- TableMaintainerContext.java
- Counter.java
- Gauge.java
- Metric.java
- MetricDefine.java
- MetricDefines.java
- MetricKey.java
- MetricRegisterListener.java
- MetricRegistry.java
- MetricReporter.java
- MetricSet.java
- MetricType.java
- ActionCoordinator.java
- AmoroProcess.java
- EngineType.java
- ExecuteEngine.java
- LocalExecutionEngine.java
- LocalProcess.java
- ManagedProcess.java
- OptimizingStages.java
- PendingInput.java
- ProcessEvent.java
- ProcessFactory.java
- ProcessStage.java
- ProcessStatus.java
- ProcessTaskStatus.java
- ProcessTriggerStrategy.java
- RecoverProcessFailedException.java
- SimpleFuture.java
- StagedTaskDescriptor.java
- TableProcess.java
- TableProcessStore.java
- AmsHAProperties.java
- CatalogMetaProperties.java
- ExternalResourceContainer.java
- InternalResourceContainer.java
- Resource.java
- ResourceContainer.java
- ResourceGroup.java
- ResourceManager.java
- ResourceStatus.java
- ResourceType.java
- JavaSerializer.java
- KryoSerializer.java
- ResourceSerde.java
- SimpleSerializer.java
- AmoroSnapshotsOfTable.java
- AMSColumnInfo.java
- AMSPartitionField.java
- ConsumerInfo.java
- DDLInfo.java
- DDLReverser.java
- FilesStatistics.java
- FilesStatisticsBuilder.java
- FormatTableDescriptor.java
- MetadataChangeHandler.java
- OperationType.java
- OptimizingProcessInfo.java
- OptimizingTaskInfo.java
- PartitionBaseInfo.java
- PartitionFileBaseInfo.java
- ProcessCategory.java
- ServerTableMeta.java
- SparkMetadataChangeHandler.java
- TableMetaExtract.java
- TableSummary.java
- TagOrBranchInfo.java
- StateKey.java
- TableIdentifier.java
- TableMetaStore.java
- TableRuntimeFactory.java
- TableRuntimeStore.java
- TableSummary.java
- CatalogUtil.java
- CommonUtil.java
- ConfigurationFileUtil.java
- DynConstructors.java
- DynMethods.java
- ExceptionUtil.java
- FlipUtil.java
- IdGenerator.java
- JacksonUtil.java
- LocalFileUtil.java
- MemorySize.java
- PropertyUtil.java
- ReflectionUtils.java
- SerializationUtil.java
- Action.java
- ActivePlugin.java
- AlreadyExistsException.java
- AmoroCatalog.java
- AmoroIOException.java
- AmoroPlugin.java
- AmoroTable.java
- AmsClient.java
- CommonUnifiedCatalog.java
- Constants.java
- DatabaseNotEmptyException.java
- ErrorCodes.java
- FormatCatalog.java
- FormatCatalogFactory.java
- IcebergActions.java
- NoSuchDatabaseException.java
- NoSuchTableException.java
- OptimizerProperties.java
- PooledAmsClient.java
- ServerTableIdentifier.java
- StateField.java
- SupportsProcessPlugins.java
- TableFormat.java
- TableIDWithFormat.java
- TableRuntime.java
- TableSnapshot.java
- UnifiedCatalog.java
- UnifiedCatalogLoader.java
- org.apache.amoro.config.shade.ConfigShade
- org.apache.amoro.FormatCatalogFactory
- org.apache.amoro.process.ExecuteEngine
- amoro_commons.thrift
- amoro_optimizing_service.thrift
- amoro_table_metastore.thrift
- README.md
- CatalogTestHelpers.java
- TestPoolConfig.java
- ConfigHelpersTest.java
- AbstractFormatCatalogTestHelper.java
- AmoroCatalogTestBase.java
- AmoroCatalogTestHelper.java
- TestAmoroCatalogBase.java
- HMSMockServer.java
- TestHMS.java
- AmoroRunListener.java
- MetricDefineTest.java
- TestMetricDefine.java
- TestMetricKey.java
- TestMetricRegistry.java
- TestLocalExecutionEngine.java
- TestSimpleFuture.java
- TestServerTableDescriptor.java
- JacksonUtilTest.java
- MemorySizeTest.java
- ReflectionUtilsTest.java
- MockAmoroManagementServer.java
- MockZookeeperServer.java
- SingletonResourceUtil.java
- TestAction.java
- TestAms.java
- PartitionExpressionForMetastore.java
- AuthorizationPreEventListener.java
- hive-schema-3.1.0.derby.sql
- log4j2.xml
- pom.xml
- HudiCatalogFactory.java
- HudiHadoopCatalog.java
- HudiHiveCatalog.java
- HudiSnapshot.java
- HudiTable.java
- HudiTableDescriptor.java
- HudiTableUtil.java
- org.apache.amoro.FormatCatalogFactory
- org.apache.amoro.table.descriptor.FormatTableDescriptor
- pom.xml
- ChangeAction.java
- ChangedLsn.java
- DataFileType.java
- DataTreeNode.java
- DefaultKeyedFile.java
- FileNameRules.java
- PrimaryKeyData.java
- PrimaryKeyedFile.java
- IcebergReportEvent.java
- AutoCreateIcebergTagAction.java
- IcebergTableMaintainer.java
- MixedTableMaintainer.java
- IcebergTableUtil.java
- RollingFileCleaner.java
- IcebergCatalog.java
- IcebergCatalogFactory.java
- IcebergSnapshot.java
- IcebergTable.java
- MixedCatalog.java
- MixedHiveCatalogFactory.java
- MixedIcebergCatalogFactory.java
- MixedSnapshot.java
- MixedTable.java
- Constants.java
- AbstractKeyedDataReader.java
- AbstractUnkeyedDataReader.java
- BaseIcebergPosDeleteReader.java
- CombinedDeleteFilter.java
- DataReaderCommon.java
- DeleteCache.java
- DeleteFilter.java
- Deletes.java
- GenericCombinedIcebergDataReader.java
- GenericKeyedDataReader.java
- GenericUnkeyedDataReader.java
- MixedDeleteFilter.java
- ParallelIcebergGenerics.java
- ParallelTableScanIterable.java
- StructForDelete.java
- StructLikeFunnel.java
- BaseTaskWriter.java
- ChangeTaskWriter.java
- CommonOutputFileFactory.java
- GenericBaseTaskWriter.java
- GenericChangeTaskWriter.java
- GenericIcebergPartitionedFanoutWriter.java
- GenericTaskWriters.java
- IcebergFanoutPosDeleteWriter.java
- MixedTreeNodePosDeleteWriter.java
- OutputFileFactory.java
- RecordWithAction.java
- SetTreeNode.java
- SortedPosDeleteWriter.java
- TaskWriterBuilder.java
- TaskWriterKey.java
- AuthenticatedFileIO.java
- AuthenticatedFileIOAdapter.java
- AuthenticatedFileIOs.java
- AuthenticatedHadoopFileIO.java
- BasicTableTrashManager.java
- CloseableIterableWrapper.java
- CloseableIteratorWrapper.java
- CloseablePredicate.java
- PathInfo.java
- RecoverableHadoopFileIO.java
- SupportFileRecycleOperations.java
- SupportsFileSystemOperations.java
- TableTrashManager.java
- TableTrashManagers.java
- LogArrayData.java
- LogMapData.java
- Bytes.java
- Converter.java
- FormatVersion.java
- JsonToLogDataConverters.java
- LogData.java
- LogDataJsonDeserialization.java
- LogDataJsonSerialization.java
- LogDataToJsonConverters.java
- MessageBytes.java
- TimeFormats.java
- BasicMixedIcebergCatalog.java
- CatalogLoader.java
- InternalMixedIcebergCatalog.java
- MixedFormatCatalog.java
- MixedTables.java
- CreateTableTransaction.java
- KeyedPartitionRewrite.java
- KeyedSchemaUpdate.java
- MixedAppendFiles.java
- MixedDeleteFiles.java
- MixedHadoopTableOperations.java
- MixedOverwriteFiles.java
- MixedReplacePartitions.java
- MixedRewriteFiles.java
- MixedRowDelta.java
- MixedTableOperations.java
- MixedTransaction.java
- MixedUpdate.java
- OverwriteBaseFiles.java
- PartitionPropertiesUpdate.java
- PartitionTransactionOperation.java
- RewritePartitions.java
- SnapshotSummary.java
- UpdateKeyedTableProperties.java
- UpdatePartitionProperties.java
- MetadataBasedEvaluationEvent.java
- MixedAndIcebergTableStatsProvider.java
- TableStatsProvider.java
- AbstractOptimizingEvaluator.java
- AbstractOptimizingPlanner.java
- AbstractPartitionPlan.java
- CommonPartitionEvaluator.java
- IcebergOptimizerEvaluator.java
- IcebergOptimizingPlanner.java
- IcebergPartitionPlan.java
- MixedIcebergOptimizingEvaluator.java
- MixedIcebergOptimizingPlanner.java
- MixedIcebergPartitionPlan.java
- PartitionEvaluator.java
- IcebergTableFileScanHelper.java
- KeyedTableFileScanHelper.java
- TableFileScanHelper.java
- UnkeyedTableFileScanHelper.java
- AbstractRewriteFilesExecutor.java
- BaseOptimizingInput.java
- HealthScoreInfo.java
- IcebergRewriteExecutor.java
- IcebergRewriteExecutorFactory.java
- MetricsSummary.java
- MixedIcebergOptimizingDataReader.java
- MixedIcebergRewriteExecutor.java
- MixedIcebergRewriteExecutorFactory.java
- OptimizingCommitterFactory.java
- OptimizingDataReader.java
- OptimizingExecutor.java
- OptimizingExecutorFactory.java
- OptimizingTaskSummary.java
- OptimizingType.java
- ParquetFileMergeRunner.java
- RewriteFilesInput.java
- RewriteFilesOutput.java
- RewriteStageTask.java
- TableOptimizing.java
- TableRuntimeOptimizingState.java
- TaskProperties.java
- HiveTableProperties.java
- MetaTableProperties.java
- BasicPartitionEvaluator.java
- RewriteNot.java
- BaseCombinedScanTask.java
- BasicKeyedTableScan.java
- BasicMixedFileScanTask.java
- ChangeTableIncrementalScan.java
- CombinedIcebergScanTask.java
- CombinedScanTask.java
- KeyedTableScan.java
- KeyedTableScanTask.java
- MixedFileScanTask.java
- NodeFileScanTask.java
- TableEntriesScan.java
- BasicTableBlockerManager.java
- Blocker.java
- RenewableBlocker.java
- TableBlockerManager.java
- BaseLocationKind.java
- BaseTable.java
- BasicKeyedTable.java
- BasicTableBuilder.java
- BasicTableSnapshot.java
- BasicUnkeyedTable.java
- ChangeLocationKind.java
- ChangeTable.java
- DistributionHashMode.java
- KeyedTable.java
- KeyedTableSnapshot.java
- LocationKind.java
- MetadataColumns.java
- MixedTable.java
- PrimaryKeySpec.java
- TableBuilder.java
- TableProperties.java
- TableSnapshot.java
- UnkeyedTable.java
- WatermarkGenerator.java
- WriteOperationKind.java
- DefaultSizeEstimator.java
- RocksDBBackend.java
- SimpleMap.java
- SimpleSpillableMap.java
- SizeEstimator.java
- StructLikeBaseMap.java
- StructLikeCollections.java
- StructLikeMemoryMap.java
- StructLikeSpillableMap.java
- StructLikeWrapperSerializer.java
- StructLikeWrapperSizeEstimator.java
- CompatiblePropertyUtil.java
- ContentFiles.java
- ConvertStructUtil.java
- ExpressionUtil.java
- FileScanTaskUtil.java
- IcebergInMemoryLockManager.java
- IcebergThreadPools.java
- ManifestEntryFields.java
- MixedDataFiles.java
- MixedFormatCatalogUtil.java
- MixedTableUtil.java
- NodeFilter.java
- SchemaUtil.java
- StatisticsFileUtil.java
- StructLikeSet.java
- TableFileUtil.java
- TablePropertyUtil.java
- IcebergFileEntry.java
- IcebergRecordWrapper.java
- PublicGenericReader.java
- ParquetIOBridge.java
- IcebergFindFiles.java
- MixedChangeTableScan.java
- ReachableFileCleanupBridge.java
- org.apache.amoro.FormatCatalogFactory
- BasicCatalogTestHelper.java
- BasicMixedCatalog.java
- CatalogTestBase.java
- CatalogTestHelper.java
- MixedTables.java
- TableTestBase.java
- TestCatalogLoader.java
- TestMixedCatalog.java
- TestDefaultKeyedFile.java
- TestUpsertPushDown.java
- TestAutoCreateIcebergTagAction.java
- TestIcebergTableMaintainer.java
- TestRollingFileCleaner.java
- IcebergHadoopCatalogTestHelper.java
- MixedIcebergHadoopCatalogTestHelper.java
- TestIcebergAmoroCatalog.java
- TestMixedIcebergFormatCatalog.java
- IcebergDataTestHelpers.java
- MixedDataTestHelpers.java
- TableDataTestBase.java
- TestBasicTableTrashManager.java
- TestCombinedDeleteFilterStructProjection.java
- TestFileNameGenerator.java
- TestIcebergCombinedReader.java
- TestIcebergCombinedReaderVariousTypes.java
- TestIcebergFanoutPosDeleteWriter.java
- TestMixedTreeNodePosDeleteWriter.java
- TestRecoverableAuthenticatedFileIO.java
- TestTableTrashManagers.java
- TestTaskReader.java
- TestTaskWriter.java
- FormatTestBase.java
- TestLogDataJsonSerialization.java
- TestOverwriteBaseFile.java
- TestRewritePartitions.java
- TestUpdatePartitionProperties.java
- TestUpdateTable.java
- TestMetadataBasedEvaluationEvent.java
- IcebergRewriteExecutorTest.java
- TestBaseCombinedScanTask.java
- TestKeyedTableScan.java
- TestMixedChangeTableScan.java
- TestNodeFileScanTask.java
- TestScanSplitTask.java
- TestTableEntriesScan.java
- TestBasicTableBlockerManager.java
- TestTableTracer.java
- TestTableWatermark.java
- TestRocksDBBackend.java
- TestSimpleSpillableMap.java
- TestSimpleSpilledMap.java
- TestStructLikeMap.java
- TestStructLikeWrapperSizeEstimator.java
- TestCompatiblePropertyUtil.java
- TestExpressionUtil.java
- TestFileUtil.java
- TestIcebergThreadPools.java
- TestKeyedExpressionUtil.java
- TestMixedDataFiles.java
- TestMixedFormatCatalogUtil.java
- TestStatisticsFileUtil.java
- TestTablePropertyUtil.java
- TestUnkeyedExpressionUtil.java
- TestWatermarkGenerator.java
- BasicTableTestHelper.java
- DataFileTestHelpers.java
- TableTestHelper.java
- TestedCatalogs.java
- TestTreeNode.java
- TestUnifiedCatalog.java
- TestIcebergFindFiles.java
- pom.xml
- LanceCatalogFactory.java
- LanceDirectoryV1Catalog.java
- LanceTable.java
- LanceTableDescriptor.java
- org.apache.amoro.FormatCatalogFactory
- org.apache.amoro.table.descriptor.FormatTableDescriptor
- pom.xml
- IcebergFlinkCatalogFactory.java
- MixedHiveCatalogFactory.java
- MixedIcebergCatalogFactory.java
- PaimonFlinkCatalogFactory.java
- CatalogFactoryOptions.java
- FlinkUnifiedCatalogFactory.java
- FlinkUnifiedCatalog.java
- MixedCatalog.java
- FlinkTablePropertiesInvocationHandler.java
- KerberosInterceptor.java
- KerberosInvocationHandler.java
- ProxyFactory.java
- RowDataPredicate.java
- RowDataPredicateExpressionVisitor.java
- BasicLookupFunction.java
- BinaryRowDataSerializerWrapper.java
- ByteArraySetSerializer.java
- ByteArrayWrapper.java
- KeyRowData.java
- KVTable.java
- KVTableFactory.java
- LookupMetrics.java
- LookupOptions.java
- LookupRecord.java
- MixedFormatRowDataLookupFunction.java
- RocksDBCacheState.java
- RocksDBRecordState.java
- RocksDBSetSpilledState.java
- RocksDBSetState.java
- RowDataStateFactory.java
- SecondaryIndexTable.java
- TableFactory.java
- UniqueIndexTable.java
- MetricConstant.java
- MetricsGenerator.java
- FlinkTypeSystem.java
- ShuffleSplitAssigner.java
- Split.java
- SplitAssigner.java
- StaticSplitAssigner.java
- AbstractMixedFormatEnumerator.java
- ContinuousEnumerationResult.java
- ContinuousSplitPlanner.java
- ContinuousSplitPlannerImpl.java
- InitializationFinishedEvent.java
- MergeOnReadIncrementalPlanner.java
- MergeOnReadPlannerImpl.java
- MixedFormatEnumeratorOffset.java
- MixedFormatEnumeratorOffsetSerializer.java
- MixedFormatSourceEnumerator.java
- MixedFormatSourceEnumState.java
- MixedFormatSourceEnumStateSerializer.java
- StaticMixedFormatSourceEnumerator.java
- ArrayBatchRecords.java
- ArrayPoolDataIteratorBatcher.java
- DataIteratorBatcher.java
- DataIteratorReaderFunction.java
- HybridSplitReader.java
- MixedFormatRecordEmitter.java
- MixedFormatRecordWithOffset.java
- MixedFormatSourceReader.java
- ReaderFunction.java
- ReaderStartedEvent.java
- RecordFactory.java
- RecordPosition.java
- RowDataReaderFunction.java
- RowDataRecordFactory.java
- ChangelogSplit.java
- MergeOnReadSplit.java
- MixedFormatSplit.java
- MixedFormatSplitSerializer.java
- MixedFormatSplitState.java
- SnapshotSplit.java
- SplitRequestEvent.java
- TemporalJoinSplits.java
- KafkaConsumerMetricConstants.java
- KafkaPartitionSplitReader.java
- KafkaSource.java
- KafkaSourceFetcherManager.java
- KafkaSourceReader.java
- LogKafkaPartitionSplit.java
- LogKafkaPartitionSplitReader.java
- LogKafkaPartitionSplitState.java
- LogKafkaRecordEmitter.java
- LogKafkaSource.java
- LogKafkaSourceBuilder.java
- LogKafkaSourceReader.java
- LogRecordWithRetractInfo.java
- LogSourceHelper.java
- ChangeLogDataIterator.java
- DataIterator.java
- FileScanTaskReader.java
- FlinkKeyedMORDataReader.java
- FlinkUnkyedDataReader.java
- MergeOnReadDataIterator.java
- MixedFormatScanContext.java
- AdaptHiveFlinkParquetReaders.java
- FlinkSplitPlanner.java
- MixedFormatSource.java
- MixedIncrementalLoader.java
- PartitionAndNodeGroup.java
- ReadShuffleRulePolicy.java
- RoundRobinShuffleRulePolicy.java
- ShuffleHelper.java
- ShuffleKey.java
- ShuffleRulePolicy.java
- MixedFormatValidator.java
- FlinkSource.java
- KerberosAwareInputFormat.java
- LogDynamicSource.java
- MixedDynamicTableFactory.java
- MixedFormatDynamicSink.java
- MixedFormatDynamicSource.java
- MixedFormatFileSource.java
- MixedFormatTableLoader.java
- OptionsUtil.java
- UnifiedDynamicTableFactory.java
- UnkeyedInputFormatOperatorFactory.java
- UnkeyedInputFormatSourceFunction.java
- UnkeyedStreamingReaderOperator.java
- CompatibleFlinkPropertyUtil.java
- DateTimeUtils.java
- FilterUtil.java
- IcebergAndFlinkFilters.java
- IcebergClassUtil.java
- LookupUtil.java
- MixedFormatUtils.java
- Projection.java
- ProxyUtil.java
- ReflectionUtil.java
- ThreadLocalCache.java
- HiddenKafkaFactory.java
- HiddenKafkaProducer.java
- AbstractHiddenLogWriter.java
- GlobalFlipCommitter.java
- HiddenLogWriter.java
- LogMsgFactory.java
- MixedFormatLogPartitioner.java
- AdaptHiveFlinkAppenderFactory.java
- AutomaticDoubleWriteStatus.java
- AutomaticLogWriter.java
- AutomaticWriteSpecification.java
- FlinkBaseTaskWriter.java
- FlinkChangeTaskWriter.java
- FlinkSink.java
- FlinkTaskWriterBuilder.java
- MixedFormatFileWriter.java
- MixedFormatLogWriter.java
- MixedFormatRowDataTaskWriterFactory.java
- MixedFormatWriter.java
- FlinkSchemaUtil.java
- InternalCatalogBuilder.java
- org.apache.flink.table.factories.Factory
- log4j.properties
- FlinkAmoroCatalogITCase.java
- FlinkCatalogContext.java
- FlinkUnifiedCatalogITCase.java
- TestFlinkUnifiedCatalogs.java
- TestMixedCatalog.java
- TestMixedCatalogTablePartitions.java
- KafkaConfigGenerate.java
- KafkaContainerTest.java
- KafkaUtil.java
- SuccessException.java
- TestRowDataPredicateAllFieldTypes.java
- TestRowDataPredicateBase.java
- TestRowDataPredicateExpressionVisitor.java
- ByteArraySetSerializerTest.java
- TestKVTable.java
- TestKafkaConsumer.java
- TestKafkaSourceReader.java
- TestLogKafkaPartitionSplitReader.java
- TestShuffleSplitAssigner.java
- TestSplitAssignerAwaiting.java
- TestStaticSplitAssigner.java
- TestContinuousSplitPlannerImpl.java
- TestMixedFormatSourceEnumerator.java
- TestMixedFormatSourceEnumStateSerializer.java
- TestTemporalJoinSplitsThreadSafe.java
- MixedIncrementalLoaderTest.java
- TestRowDataReaderFunction.java
- TestMixedFormatSplitSerializer.java
- TestFlinkSource.java
- TestFlinkSplitPlanner.java
- TestMixedFormatSource.java
- TestLogRecordV1.java
- TestRoundRobinShuffleRulePolicy.java
- AmoroCatalogITCaseBase.java
- CatalogITCaseBase.java
- LookupITCase.java
- TestJoin.java
- TestKeyed.java
- TestLookupSecondary.java
- TestTableRefresh.java
- TestUnkeyed.java
- TestUnkeyedOverwrite.java
- TestWatermark.java
- ClassLoaderUtils.java
- DataUtil.java
- MixedFormatMockEnvironment.java
- MockEnvironmentBuilder.java
- TestCompatibleFlinkPropertyUtil.java
- TestGlobalAggregateManager.java
- TestIcebergClassUtil.java
- TestOneInputStreamOperatorIntern.java
- TestProjection.java
- TestUtil.java
- TestBaseLog.java
- TestHiddenKafkaProducer.java
- TestHiddenLogOperators.java
- FlinkTaskWriterBaseTest.java
- MixedFormatFileWriterITCase.java
- TestAdaptHiveWriter.java
- TestAutomaticDoubleWriteStatus.java
- TestAutomaticLogWriter.java
- TestFlinkSink.java
- TestMixedFormatFileCommitter.java
- TestMixedFormatFileWriter.java
- DynamicTableSourceTestBase.java
- FlinkTableTestBase.java
- FlinkTestBase.java
- MiniClusterResource.java
- TestFlinkSchemaUtil.java
- org.apache.flink.table.factories.Factory
- docker-java.properties
- log4j2-test.xml
- log4j2.component.properties
- pom.xml
- LogRecordV1.java
- RowKindUtil.java
- pom.xml
- AdaptHiveFlinkParquetReaders.java
- AdaptHiveFlinkParquetWriters.java
- AdaptHiveParquetWithFlinkSchemaVisitor.java
- RowDataFileScanTaskReader.java
- ScanContext.java
- pom.xml
- pom.xml
- pom.xml
- pom.xml
- pom.xml
- pom.xml
- pom.xml
- pom.xml
- MixedHiveCatalog.java
- MixedHiveTables.java
- CannotAlterHiveLocationException.java
- AbstractAdaptHiveKeyedDataReader.java
- AbstractAdaptHiveUnkeyedDataReader.java
- AdaptHiveGenericKeyedDataReader.java
- AdaptHiveGenericUnkeyedDataReader.java
- AdaptHiveMixedDeleteFilter.java
- AdaptHiveGenericTaskWriterBuilder.java
- AdaptHiveOperateToTableRelation.java
- AdaptHiveOutputFileFactory.java
- OperateToTableRelation.java
- BaseSchemaUpdate.java
- HiveOperationTransaction.java
- HiveSchemaUpdate.java
- OverwriteHiveFiles.java
- ReplaceHivePartitions.java
- RewriteHiveFiles.java
- UpdateHiveFiles.java
- MixedHiveOptimizingEvaluator.java
- MixedHiveOptimizingPlanner.java
- MixedHivePartitionPlan.java
- MixedHiveOptimizingDataReader.java
- MixedHiveRewriteExecutor.java
- MixedHiveRewriteExecutorFactory.java
- HiveLocationKind.java
- KeyedHiveTable.java
- SupportHive.java
- UnkeyedHiveTable.java
- CatalogUtil.java
- ChangeFieldName.java
- CompatibleHivePropertyUtil.java
- HiveCommitUtil.java
- HiveMetaSynchronizer.java
- HivePartitionUtil.java
- HiveSchemaUtil.java
- HiveTableUtil.java
- TableTypeUtil.java
- TimeUtil.java
- UpgradeHiveTableUtil.java
- AdaptHiveBaseParquetReaders.java
- AdaptHiveBaseParquetWriter.java
- AdaptHiveGenericParquetReaders.java
- AdaptHiveGenericParquetWriter.java
- AdaptHiveGenericAppenderFactory.java
- AdaptHiveApplyNameMapping.java
- AdaptHiveColumnWriter.java
- AdaptHiveParquet.java
- AdaptHiveParquetConversions.java
- AdaptHiveParquetDictionaryRowGroupFilter.java
- AdaptHiveParquetMetricsRowGroupFilter.java
- AdaptHiveParquetReader.java
- AdaptHiveParquetSchemaUtil.java
- AdaptHiveParquetUtil.java
- AdaptHiveParquetWriter.java
- AdaptHivePrimitiveWriter.java
- AdaptHiveReadConf.java
- AdaptHiveTypeToMessageType.java
- IcebergSchemaUtil.java
- HiveCatalogTestHelper.java
- HiveTableTestHelper.java
- TestHiveCatalogLoader.java
- TestMixedHiveCatalog.java
- IcebergHiveCatalogTestHelper.java
- MixedIcebergHiveCatalogTestHelper.java
- TestIcebergHiveAmoroCatalog.java
- TestMixedIcebergHiveAmoroCatalog.java
- HiveDataTestHelpers.java
- TestHiveTableTrashManagers.java
- TestHiveTaskReader.java
- TestHiveTaskWriter.java
- TestImpalaParquet.java
- TestHiveSchemaUpdate.java
- TestOverwriteFiles.java
- TestRewriteFiles.java
- TestRewritePartitions.java
- TestSyncHiveMeta.java
- UpdateHiveFilesTestHelpers.java
- TestCompatibleHivePropertyUtil.java
- TestHiveMetaSynchronizer.java
- TestHiveSchemaUtil.java
- TestTimeUtil.java
- TestUpgradeHiveTableUtil.java
- MixedHiveTableTestBase.java
- TestAdaptHiveParquetSchemaUtil.java
- TestAdaptHiveParquetUtil.java
- TestAdaptHiveReadConf.java
- hive.parquet
- log4j2.xml
- string_is_bytes.parquet
- pom.xml
- IcebergSparkFormat.java
- MixedFormatSparkUtil.java
- MixedHiveDataSource.java
- MixedHiveSparkFormat.java
- MixedIcebergDataSource.java
- MixedIcebergSparkFormat.java
- MixedSessionCatalogBase.java
- MixedSourceBase.java
- MixedSparkCatalogBase.java
- MixedTableStoreType.java
- SparkSQLProperties.java
- PaimonSparkFormat.java
- SparkUtil.java
- SessionCatalogBase.java
- SparkTableFormat.java
- SparkUnifiedCatalogBase.java
- SparkUnifiedCatalogProperties.java
- SparkUnifiedSessionCatalogBase.java
- SupportAuthentication.java
- org.apache.amoro.spark.SparkTableFormat
- org.apache.spark.sql.sources.DataSourceRegister
- DefaultParameterContext.java
- EachParameterResolver.java
- EnableCatalogSelect.java
- EnableCatalogSelectExtension.java
- UnifiedCatalogTestSuites.java
- Asserts.java
- DataComparator.java
- ExpectResultUtil.java
- RecordGenerator.java
- ResourceInputFile.java
- ScalaTestUtil.java
- TableFiles.java
- TestTable.java
- TestTables.java
- TestTableUtil.java
- MixedTableTestBase.java
- SparkTestBase.java
- SparkTestContext.java
- TestIdentifier.java
- pom.xml
- MixedFormatSqlExtend.g4
- MixedFormatSqlExtendBaseListener.java
- MixedFormatSqlExtendBaseVisitor.java
- MixedFormatSqlExtendLexer.java
- MixedFormatSqlExtendListener.java
- MixedFormatSqlExtendParser.java
- MixedFormatSqlExtendVisitor.java
- .gitignore
- MigrateToMixedFormatCommand.java
- MixedFormatSparkCommand.java
- InternalRowFileAppenderFactory.java
- SparkBaseTaskWriter.java
- SparkChangeTaskWriter.java
- TaskWriters.java
- UnkeyedUpsertSparkWriter.java
- KeyedSparkBatchScan.java
- SparkKeyedDataReader.java
- SparkParquetReaders.java
- SparkScanBuilder.java
- SparkUnkeyedDataReader.java
- UnkeyedSparkBatchScan.java
- FileIndexBucket.java
- MixedSparkTable.java
- SparkChangeTable.java
- SupportsExtendIdentColumns.java
- SupportsRowLevelOperator.java
- UnkeyedSparkTable.java
- DistributionAndOrderingUtil.java
- ExpressionHelper.java
- MixedFormatSparkUtils.java
- SortOrderToSpark.java
- Stats.java
- KeyedSparkBatchWrite.java
- MixedFormatSparkWriteBuilder.java
- RowLevelWriter.java
- SimpleInternalRowDataWriter.java
- SimpleRowLevelDataWriter.java
- UnkeyedSparkBatchWrite.java
- WriteMode.java
- WriteTaskCommit.java
- MixedFormatSparkCatalog.java
- MixedFormatSparkSessionCatalog.java
- Spark33Adapter.java
- SparkAdapter.java
- SparkAdapterLoader.java
- SparkInternalRowWrapper.java
- SparkUnifiedCatalog.java
- SparkUnifiedSessionCatalog.java
- AdaptHiveParquetWithSparkSchemaVisitor.java
- AdaptHiveSparkParquetWriters.java
- MixedFormatAlignRowLevelCommandAssignments.scala
- QueryWithConstraintCheck.scala
- ResolveMergeIntoMixedFormatTableReferences.scala
- ResolveMixedFormatCommand.scala
- RewriteMixedFormatCommand.scala
- RewriteMixedFormatMergeIntoTable.scala
- OptimizeWriteRule.scala
- RewriteAppendMixedFormatTable.scala
- RewriteDeleteFromMixedFormatTable.scala
- RewriteUpdateMixedFormatTable.scala
- MixedFormatParserUtils.scala
- MixedFormatSqlExtensionsParser.scala
- AlterMixedFormatTableDropPartition.scala
- logicals.scala
- MergeIntoMixedFormatTable.scala
- MergeRows.scala
- MixedFormatRowLevelWrite.scala
- QueryWithConstraintCheckPlan.scala
- statements.scala
- TruncateMixedFormatTable.scala
- UnresolvedMergeIntoMixedFormatTable.scala
- AlterMixedFormatTableDropPartitionExec.scala
- DescribeKeyedTableExec.scala
- ExtendedMixedFormatStrategy.scala
- MergeRowsExec.scala
- MixedFormatCommandExec.scala
- MixedFormatRowLevelWriteExec.scala
- QueryWithConstraintCheckExec.scala
- TruncateMixedFormatTableExec.scala
- expressions.scala
- MixedFormatRewriteHelper.scala
- ProjectingInternalRow.scala
- RowDeltaUtils.scala
- WriteQueryProjections.scala
- MixedFormatExtensionUtils.scala
- MixedFormatSparkExtensions.scala
- SparkInternalRowCastWrapper.scala
- SupportSparkAdapter.scala
- AssignmentHelper.scala
- ExpressionHelper.scala
- MixedFormatSpark33Helper.scala
- MixedFormatSqlExtendAstBuilder.scala
- QueryParsingErrors.scala
- MixedFormatAssignmentAlignmentSupport.scala
- MixedFormatExtendedDataSourceV2Strategy.scala
- TestKeyedTableDataFrameAPI.java
- TestUnKeyedTableDataFrameAPI.java
- TestSessionCatalog.java
- TestAlterTableColumnSQL.java
- TestCreateTableAsSelect.java
- TestCreateTableLikeSQL.java
- TestCreateTableSQL.java
- TestDeleteFromSQL.java
- TestDescSQL.java
- TestDropPartitionSQL.java
- TestInsertIntoSQL.java
- TestInsertOverwriteSQL.java
- TestMergeIntoSQL.java
- TestMixedFormatSessionCatalog.java
- TestSelectSQL.java
- TestTruncateSQL.java
- TestUpdateSQL.java
- TestSqlExtendParser.java
- TestImpalaParquet.java
- TestMixedWriter.java
- TestUnifiedCatalog.java
- log4j2.properties
- pom.xml
- pom.xml
- MixedFormatSqlExtend.g4
- MixedFormatSqlExtendBaseListener.java
- MixedFormatSqlExtendBaseVisitor.java
- MixedFormatSqlExtendLexer.java
- MixedFormatSqlExtendListener.java
- MixedFormatSqlExtendParser.java
- MixedFormatSqlExtendVisitor.java
- .gitignore
- MigrateToMixedFormatCommand.java
- MixedFormatSparkCommand.java
- InternalRowFileAppenderFactory.java
- SparkBaseTaskWriter.java
- SparkChangeTaskWriter.java
- TaskWriters.java
- UnkeyedUpsertSparkWriter.java
- KeyedSparkBatchScan.java
- SparkKeyedDataReader.java
- SparkParquetReaders.java
- SparkScanBuilder.java
- SparkUnkeyedDataReader.java
- UnkeyedSparkBatchScan.java
- FileIndexBucket.java
- MixedSparkTable.java
- SparkChangeTable.java
- SupportsExtendIdentColumns.java
- SupportsRowLevelOperator.java
- UnkeyedSparkTable.java
- DistributionAndOrderingUtil.java
- ExpressionHelper.java
- MixedFormatSparkUtils.java
- SortOrderToSpark.java
- Stats.java
- KeyedSparkBatchWrite.java
- MixedFormatSparkWriteBuilder.java
- RowLevelWriter.java
- SimpleInternalRowDataWriter.java
- SimpleRowLevelDataWriter.java
- UnkeyedSparkBatchWrite.java
- WriteMode.java
- WriteTaskCommit.java
- MixedFormatSparkCatalog.java
- MixedFormatSparkSessionCatalog.java
- Spark34Adapter.java
- SparkAdapter.java
- SparkAdapterLoader.java
- SparkInternalRowWrapper.java
- SparkUnifiedCatalog.java
- SparkUnifiedSessionCatalog.java
- SupportsFunctions.java
- AdaptHiveParquetWithSparkSchemaVisitor.java
- AdaptHiveSparkParquetWriters.java
- MixedFormatAlignRowLevelCommandAssignments.scala
- QueryWithConstraintCheck.scala
- ResolveMergeIntoMixedFormatTableReferences.scala
- ResolveMixedFormatCommand.scala
- RewriteMixedFormatCommand.scala
- RewriteMixedFormatMergeIntoTable.scala
- OptimizeWriteRule.scala
- RewriteAppendMixedFormatTable.scala
- RewriteDeleteFromMixedFormatTable.scala
- RewriteUpdateMixedFormatTable.scala
- MixedFormatParserUtils.scala
- MixedFormatSqlExtensionsParser.scala
- AlterMixedFormatTableDropPartition.scala
- logicals.scala
- MergeIntoMixedFormatTable.scala
- MergeRows.scala
- MixedFormatRowLevelWrite.scala
- QueryWithConstraintCheckPlan.scala
- statements.scala
- TruncateMixedFormatTable.scala
- UnresolvedMergeIntoMixedFormatTable.scala
- AlterMixedFormatTableDropPartitionExec.scala
- DescribeKeyedTableExec.scala
- ExtendedMixedFormatStrategy.scala
- MergeRowsExec.scala
- MixedFormatCommandExec.scala
- MixedFormatRowLevelWriteExec.scala
- QueryWithConstraintCheckExec.scala
- TruncateMixedFormatTableExec.scala
- expressions.scala
- MixedFormatRewriteHelper.scala
- ProjectingInternalRow.scala
- RowDeltaUtils.scala
- WriteQueryProjections.scala
- MixedFormatExtensionUtils.scala
- MixedFormatSparkExtensions.scala
- SparkInternalRowCastWrapper.scala
- SupportSparkAdapter.scala
- AssignmentHelper.scala
- ExpressionHelper.scala
- MixedFormatSpark34Helper.scala
- MixedFormatSqlExtendAstBuilder.scala
- QueryParsingErrors.scala
- MixedFormatAssignmentAlignmentSupport.scala
- IcebergTransformExpression.scala
- V2WriteCommandLike.scala
- TruncateTransform.scala
- MixedFormatExtendedDataSourceV2Strategy.scala
- TestKeyedTableDataFrameAPI.java
- TestUnKeyedTableDataFrameAPI.java
- TestSessionCatalog.java
- TestAlterTableColumnSQL.java
- TestCreateTableAsSelect.java
- TestCreateTableLikeSQL.java
- TestCreateTableSQL.java
- TestDeleteFromSQL.java
- TestDescSQL.java
- TestDropPartitionSQL.java
- TestInsertIntoSQL.java
- TestInsertOverwriteSQL.java
- TestMergeIntoSQL.java
- TestMixedFormatSessionCatalog.java
- TestSelectSQL.java
- TestTruncateSQL.java
- TestUpdateSQL.java
- TestSqlExtendParser.java
- TestImpalaParquet.java
- TestMixedWriter.java
- TestUnifiedCatalog.java
- pom.xml
- pom.xml
- MixedFormatSqlExtend.g4
- MixedFormatSqlExtendBaseListener.java
- MixedFormatSqlExtendBaseVisitor.java
- MixedFormatSqlExtendLexer.java
- MixedFormatSqlExtendListener.java
- MixedFormatSqlExtendParser.java
- MixedFormatSqlExtendVisitor.java
- .gitignore
- MigrateToMixedFormatCommand.java
- MixedFormatSparkCommand.java
- InternalRowFileAppenderFactory.java
- SparkBaseTaskWriter.java
- SparkChangeTaskWriter.java
- TaskWriters.java
- UnkeyedUpsertSparkWriter.java
- KeyedSparkBatchScan.java
- SparkKeyedDataReader.java
- SparkParquetReaders.java
- SparkScanBuilder.java
- SparkUnkeyedDataReader.java
- UnkeyedSparkBatchScan.java
- FileIndexBucket.java
- MixedSparkTable.java
- SparkChangeTable.java
- SupportsExtendIdentColumns.java
- SupportsRowLevelOperator.java
- UnkeyedSparkTable.java
- DistributionAndOrderingUtil.java
- ExpressionHelper.java
- MixedFormatSparkUtils.java
- SortOrderToSpark.java
- Stats.java
- KeyedSparkBatchWrite.java
- MixedFormatSparkWriteBuilder.java
- RowLevelWriter.java
- SimpleInternalRowDataWriter.java
- SimpleRowLevelDataWriter.java
- UnkeyedSparkBatchWrite.java
- WriteMode.java
- WriteTaskCommit.java
- MixedFormatSparkCatalog.java
- MixedFormatSparkSessionCatalog.java
- Spark35Adapter.java
- SparkAdapter.java
- SparkAdapterLoader.java
- SparkInternalRowWrapper.java
- SparkUnifiedCatalog.java
- SparkUnifiedSessionCatalog.java
- SupportsFunctions.java
- AdaptHiveParquetWithSparkSchemaVisitor.java
- AdaptHiveSparkParquetWriters.java
- MixedFormatAlignRowLevelCommandAssignments.scala
- QueryWithConstraintCheck.scala
- ResolveMergeIntoMixedFormatTableReferences.scala
- ResolveMixedFormatCommand.scala
- RewriteMixedFormatCommand.scala
- RewriteMixedFormatMergeIntoTable.scala
- OptimizeWriteRule.scala
- RewriteAppendMixedFormatTable.scala
- RewriteDeleteFromMixedFormatTable.scala
- RewriteUpdateMixedFormatTable.scala
- MixedFormatParserUtils.scala
- MixedFormatSqlExtensionsParser.scala
- AlterMixedFormatTableDropPartition.scala
- logicals.scala
- MergeIntoMixedFormatTable.scala
- MergeRows.scala
- MixedFormatRowLevelWrite.scala
- QueryWithConstraintCheckPlan.scala
- statements.scala
- TruncateMixedFormatTable.scala
- UnresolvedMergeIntoMixedFormatTable.scala
- AlterMixedFormatTableDropPartitionExec.scala
- DescribeKeyedTableExec.scala
- ExtendedMixedFormatStrategy.scala
- MergeRowsExec.scala
- MixedFormatCommandExec.scala
- MixedFormatRowLevelWriteExec.scala
- QueryWithConstraintCheckExec.scala
- TruncateMixedFormatTableExec.scala
- expressions.scala
- MixedFormatRewriteHelper.scala
- ProjectingInternalRow.scala
- RowDeltaUtils.scala
- WriteQueryProjections.scala
- MixedFormatExtensionUtils.scala
- MixedFormatSparkExtensions.scala
- SparkInternalRowCastWrapper.scala
- SupportSparkAdapter.scala
- AssignmentHelper.scala
- ExpressionHelper.scala
- MixedFormatSpark35Helper.scala
- MixedFormatSqlExtendAstBuilder.scala
- QueryParsingErrors.scala
- MixedFormatAssignmentAlignmentSupport.scala
- IcebergTransformExpression.scala
- V2WriteCommandLike.scala
- TruncateTransform.scala
- MixedFormatExtendedDataSourceV2Strategy.scala
- TestKeyedTableDataFrameAPI.java
- TestUnKeyedTableDataFrameAPI.java
- TestSessionCatalog.java
- TestAlterTableColumnSQL.java
- TestCreateTableAsSelect.java
- TestCreateTableLikeSQL.java
- TestCreateTableSQL.java
- TestDeleteFromSQL.java
- TestDescSQL.java
- TestDropPartitionSQL.java
- TestInsertIntoSQL.java
- TestInsertOverwriteSQL.java
- TestMergeIntoSQL.java
- TestMixedFormatSessionCatalog.java
- TestSelectSQL.java
- TestTruncateSQL.java
- TestUpdateSQL.java
- TestSqlExtendParser.java
- TestImpalaParquet.java
- TestMixedWriter.java
- TestUnifiedCatalog.java
- log4j2.properties
- pom.xml
- pom.xml
- pom.xml
- ColumnReaderFactory.java
- TimestampColumnReader.java
- DummyFileScanTask.java
- TrinoDeleteFile.java
- TrinoRow.java
- KeyedConnectorMetadata.java
- KeyedConnectorPageSource.java
- KeyedConnectorSplit.java
- KeyedConnectorSplitManager.java
- KeyedDeleteFilter.java
- KeyedPageSourceProvider.java
- KeyedTableHandle.java
- AdaptHiveIcebergTableHandle.java
- IcebergMetadata.java
- IcebergPageSource.java
- IcebergPageSourceProvider.java
- IcebergSplit.java
- IcebergSplitManager.java
- IcebergSplitSource.java
- TrinoDeleteFilter.java
- MetricUtil.java
- ObjectSerializerUtil.java
- AmoroErrorCode.java
- DefaultMixedFormatCatalogFactory.java
- MixedFormatCatalogFactory.java
- MixedFormatCatalogSupportTableSuffix.java
- MixedFormatConfig.java
- MixedFormatConnector.java
- MixedFormatConnectorFactory.java
- MixedFormatConnectorMetadata.java
- MixedFormatConnectorSplitManager.java
- MixedFormatHdfsAuthentication.java
- MixedFormatHdfsConfiguration.java
- MixedFormatMetadataFactory.java
- MixedFormatModule.java
- MixedFormatPageSourceProvider.java
- MixedFormatPlugin.java
- MixedFormatSessionProperties.java
- MixedFormatTransactionManager.java
- MixedFormatTrinoCatalog.java
- MixedFormatTrinoCatalogFactory.java
- TableNameResolve.java
- HiveMetaStoreClient.java
- VersionInfo.java
- ParquetMetadataConverterUtil.java
- ColumnIOUtil.java
- io.trino.spi.Plugin
- HiveTestRecords.java
- MixedFormatQueryRunner.java
- TableTestBaseForTrino.java
- TableTestBaseWithInitDataForTrino.java
- TestHiveTable.java
- TestHiveTableBaseForTrino.java
- TestKeyedTable.java
- assembly.xml
- pom.xml
- pom.xml
- PaimonCatalog.java
- PaimonCatalogFactory.java
- PaimonSnapshot.java
- PaimonTable.java
- PaimonTableDescriptor.java
- PaimonTableMetaExtract.java
- PaimonTypeToSparkType.java
- org.apache.amoro.FormatCatalogFactory
- org.apache.amoro.table.descriptor.FormatTableDescriptor
- PaimonHadoopCatalogTestHelper.java
- PaimonHiveCatalogTestHelper.java
- TestPaimonAmoroCatalog.java
- TestPaimonHiveAmoroCatalog.java
- TestPaimonServerTableDescriptor.java
- pom.xml
- __init__.py
- check_ams_connectivity.py
- common.py
- get_table_details.py
- list_catalogs.py
- list_databases.py
- list_optimizers.py
- list_optimizing_processes.py
- list_optimizing_tables.py
- list_optimizing_tasks.py
- list_resource_groups.py
- list_table_snapshots.py
- list_tables.py
- __init__.py
- actions.py
- auth.py
- client.py
- compatibility.py
- config.py
- logging_config.py
- models.py
- request_context.py
- sanitize.py
- server.py
- conftest.py
- test_actions.py
- test_auth.py
- test_client.py
- test_compatibility.py
- test_logging.py
- test_sanitize.py
- test_server.py
- pyproject.toml
- README.md
- uv.lock
- MetricFilter.java
- MetricsCollector.java
- PrometheusMetricsReporter.java
- org.apache.amoro.metrics.MetricReporter
- MetricFilterTest.java
- MetricsCollectorRegexFilterTest.java
- pom.xml
- pom.xml
- OpenAPITest.java
- pom.xml
- AbstractOptimizerOperator.java
- AmsNodeManager.java
- Optimizer.java
- OptimizerConfig.java
- OptimizerExecutor.java
- OptimizerToucher.java
- ThriftAmsNodeManager.java
- OptimizerTestBase.java
- OptimizerTestHelpers.java
- TestAbstractOptimizerOperator.java
- TestOptimizer.java
- TestOptimizerConfig.java
- TestOptimizerExecutor.java
- TestOptimizerToucher.java
- pom.xml
- FlinkExecutor.java
- FlinkOptimizer.java
- FlinkOptimizerExecutor.java
- FlinkToucher.java
- TestFlinkExecutor.java
- TestFlinkOptimizerExecutor.java
- pom.xml
- SparkOptimizer.java
- SparkOptimizerExecutor.java
- SparkOptimizingTaskFunction.java
- pom.xml
- StandaloneOptimizer.java
- log4j2.xml
- pom.xml
- pom.xml
- extensions.json
- settings.json
- LICENSE-@ant-design-icons-vue
- LICENSE-@antfu-eslint-config
- LICENSE-@tsconfig-node18
- LICENSE-@types-node
- LICENSE-@vitejs-plugin-vue
- LICENSE-ant-design-vue
- LICENSE-axios
- LICENSE-babel
- LICENSE-dayjs
- LICENSE-echarts
- LICENSE-eslint
- LICENSE-less
- LICENSE-mockjs
- LICENSE-monaco-editor
- LICENSE-pinia
- LICENSE-qs
- LICENSE-sql-formatter
- LICENSE-typescript
- LICENSE-unplugin-auto-import
- LICENSE-unplugin-vue-components
- LICENSE-vite
- LICENSE-vite-plugin-fake-server
- LICENSE-vite-plugin-svg-icons
- LICENSE-vue
- LICENSE-vue-clipboard3
- LICENSE-vue-draggable-plus
- LICENSE-vue-i18n
- LICENSE-vue-router
- LICENSE-vue-tsc
- catalogs.js
- common.js
- database.js
- db.js
- optimize.js
- overview.js
- settings.js
- table.js
- terminal.js
- index.js
- favicon-bak.ico
- favicon.ico
- amoro.svg
- arctic.svg
- branch.svg
- catalogs.svg
- database.svg
- format.svg
- hive.svg
- hudi.svg
- iceberg.svg
- lance.svg
- optimizers.svg
- optimizing.svg
- overview.svg
- paimon.svg
- settings.svg
- slide.svg
- sqldebug.svg
- sqlinit.svg
- sqlmax.svg
- sqlpause.svg
- tables.svg
- tag.svg
- terminal.svg
- index.ts
- arctic-dashboard.svg
- arctic-dashboard1.svg
- arctic-introduce.png
- Catalog-Service.png
- home-content.png
- Infrastructure-Idependent.png
- introduce_arctic.png
- item-icon.png
- logo-all1.svg
- logo.svg
- logo1.svg
- logo2.svg
- Management-tools.png
- Multiple-Formats.png
- Rich-Plugins.png
- Self-managed.png
- Chart.vue
- index.ts
- index.ts
- loading.vue
- editor-config.ts
- index.vue
- CreateDB.vue
- TablesMenu.vue
- Layout.vue
- register.ts
- Sidebar.vue
- svg-icon.vue
- SwaggerUI.vue
- Topbar.vue
- VirtualRecycleScroller.vue
- usePageScroll.ts
- usePagination.ts
- usePlaceholder.ts
- datetimeFormats.ts
- en.ts
- i18n.ts
- index.ts
- zh.ts
- index.ts
- global.service.ts
- login.service.ts
- optimize.service.ts
- overview.service.ts
- setting.services.ts
- table.service.ts
- terminal.service.ts
- index.ts
- ant-design.less
- global.less
- index.less
- reset.less
- common.type.ts
- chart.ts
- editor.ts
- index.ts
- permission.ts
- request.ts
- sql.ts
- table.ts
- Detail.vue
- index.vue
- Properties.vue
- Details.vue
- ErrorMsg.vue
- Field.vue
- Partition.vue
- Properties.vue
- index.vue
- upgrade.vue
- index.vue
- List.vue
- ScaleOut.vue
- index.vue
- DataSizeCard.vue
- MultipleDataCard.vue
- PieChartCard.vue
- ResourceUsageCard.vue
- SingleDataCard.vue
- Top10TablesCard.vue
- index.vue
- CreateOptimizerModal.vue
- GroupModal.vue
- List.vue
- ScaleOut.vue
- index.vue
- index.vue
- Cleanup.vue
- Details.vue
- Files.vue
- HealthScoreDetails.vue
- Operations.vue
- Optimizing.vue
- Profiling.vue
- Selector.vue
- Snapshots.vue
- TableExplorer.vue
- create.vue
- index.vue
- sql-log.vue
- sql-result.vue
- index.vue
- 404.vue
- Home.vue
- .gitkeep
- App.vue
- main.ts
- shims-vue.d.ts
- vite-env.d.ts
- .browserslistrc
- .gitignore
- eslint.config.mjs
- index.html
- license.node.js
- package.json
- pnpm-lock.yaml
- pom.xml
- README.md
- tsconfig.json
- tsconfig.node.json
- vite.config.ts
- mvn
- _capabilities.tpl
- _ingress.tpl
- _labels.tpl
- _names.tpl
- _tplvalues.tpl
- _helpers.tpl
- _optimizer.tpl
- _pod.tpl
- _rbac.tpl
- amoro-configmap.yaml
- amoro-deployment.yaml
- amoro-httproute.yaml
- amoro-ingress.yaml
- amoro-rbac.yaml
- amoro-secret.yaml
- amoro-service.yaml
- amoro-serviceaccount.yaml
- NOTES.txt
- amoro-configmap_test.yaml
- amoro-deployment_test.yaml
- amoro-httproute_test.yaml
- amoro-ingress_test.yaml
- amoro-rbac_test.yaml
- amoro-secret_test.yaml
- amoro-service_test.yaml
- amoro-serviceaccount_test.yaml
- .helmignore
- Chart.yaml
- README.md
- values.yaml
- dependencies-hadoop-2-spark-3.3
- dependencies-hadoop-3-spark-3.5
- dependencies.sh
- merge_amoro_pr.py
- reformat
- ams.sh
- load-config.sh
- optimizer.sh
- log4j2.xml
- event-listeners.yaml
- execute-engines.yaml
- metric-reporters.yaml
- process-factories.yaml
- rest-extensions.yaml
- config.yaml
- env.sh
- jvm.properties
- log4j2.xml
- bin.xml
- release-bin.xml
- pom.xml
- Dockerfile
- entrypoint.sh
- .gitignore
- build.sh
- README.md
- .asf.yaml
- .gitignore
- AGENTS.md
- CONTRIBUTING.md
- DISCLAIMER
- LICENSE
- LICENSE-binary
- NOTICE
- NOTICE-binary
- README.md
// repository documentation
Was this content helpful?
(0 ratings)
