MCPcopy Create free account

hub / github.com/apache/amoro / types & classes

Types & classes3,104 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
Class
amoro-web/src/services/login.service.ts:24
ClassAMSColumnInfo
AMS server column info.
amoro-common/src/main/java/org/apache/amoro/table/descriptor/AMSColumnInfo.java:22
ClassAMSManagerTestBase
amoro-ams/src/test/java/org/apache/amoro/server/AMSManagerTestBase.java:36
ClassAMSPartitionField
amoro-common/src/main/java/org/apache/amoro/table/descriptor/AMSPartitionField.java:21
ClassAMSServiceTestBase
amoro-ams/src/test/java/org/apache/amoro/server/AMSServiceTestBase.java:32
ClassAMSTableTestBase
amoro-ams/src/test/java/org/apache/amoro/server/table/AMSTableTestBase.java:55
ClassAPITokenManager
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/APITokenManager.java:25
ClassAbstractAdaptHiveKeyedDataReader
AdaptHive can read all Data.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/reader/AbstractAdaptHiveKeyedDataReader.java:43
ClassAbstractAdaptHiveUnkeyedDataReader
AdaptHive can read all Data.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/reader/AbstractAdaptHiveUnkeyedDataReader.java:38
ClassAbstractFormatCatalogTestHelper
amoro-common/src/test/java/org/apache/amoro/formats/AbstractFormatCatalogTestHelper.java:31
ClassAbstractHiddenLogWriter
This is an abstract log queue writer. Sending flip message to the kafka topic when the operator occurs restoring, through the {@link GlobalFlipCommitt
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/hidden/AbstractHiddenLogWriter.java:55
ClassAbstractHiveChecker
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/checker/AbstractHiveChecker.java:51
ClassAbstractKeyedDataReader
Abstract implementation of mixed-format data reader consuming {@link KeyedTableScanTask}, return records after filtering with {@link MixedDeleteFilter
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/AbstractKeyedDataReader.java:57
ClassAbstractMixedFormatEnumerator
The abstract mixed-format source enumerator.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/enumerator/AbstractMixedFormatEnumerator.java:44
ClassAbstractOptimizerOperator
amoro-optimizer/amoro-optimizer-common/src/main/java/org/apache/amoro/optimizer/common/AbstractOptimizerOperator.java:35
ClassAbstractOptimizingEvaluator
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/plan/AbstractOptimizingEvaluator.java:54
ClassAbstractOptimizingPlanner
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/plan/AbstractOptimizingPlanner.java:46
ClassAbstractOptimizingTest
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/AbstractOptimizingTest.java:66
ClassAbstractPartitionPlan
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/plan/AbstractPartitionPlan.java:47
ClassAbstractPluginManager
Parent class of all plugin managers, which provide the common method to help load, install, and visit plugins. @param <T> The plugin types.
amoro-ams/src/main/java/org/apache/amoro/server/manager/AbstractPluginManager.java:62
ClassAbstractResourceContainer
amoro-ams/src/main/java/org/apache/amoro/server/manager/AbstractResourceContainer.java:33
ClassAbstractRewriteFilesExecutor
An abstract OptimizingExecutor implementation that rewrites the rewrittenDataFiles in RewriteInput and generates new position delete for rePosDeletedD
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/AbstractRewriteFilesExecutor.java:64
ClassAbstractSceneCountChecker
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/checker/AbstractSceneCountChecker.java:31
ClassAbstractTableDataView
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/view/AbstractTableDataView.java:52
ClassAbstractTableMetrics
amoro-ams/src/main/java/org/apache/amoro/server/table/AbstractTableMetrics.java:31
ClassAbstractUnkeyedDataReader
Abstract implementation of iceberg data reader consuming {@link MixedFileScanTask}. @param <T> to indicate the record data type.
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/AbstractUnkeyedDataReader.java:55
ClassAbstractWriterFactory
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/writer/KeyedSparkBatchWrite.java:253
ClassAbstractWriterFactory
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/writer/KeyedSparkBatchWrite.java:253
ClassAbstractWriterFactory
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/writer/KeyedSparkBatchWrite.java:253
ClassAction
amoro-common/src/main/java/org/apache/amoro/Action.java:29
InterfaceAction
amoro-common/src/main/java/org/apache/amoro/client/ClientPool.java:28
InterfaceActivePlugin
Plugins that need to initialize and close
amoro-common/src/main/java/org/apache/amoro/ActivePlugin.java:24
ClassAdaptHiveApplyNameMapping
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveApplyNameMapping.java:25
ClassAdaptHiveBaseParquetReaders
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/data/parquet/AdaptHiveBaseParquetReaders.java:53
ClassAdaptHiveBaseParquetWriter
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/data/parquet/AdaptHiveBaseParquetWriter.java:52
ClassAdaptHiveColumnWriter
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveColumnWriter.java:25
ClassAdaptHiveFlinkAppenderFactory
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/AdaptHiveFlinkAppenderFactory.java:51
ClassAdaptHiveFlinkParquetReaders
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/data/AdaptHiveFlinkParquetReaders.java:59
ClassAdaptHiveFlinkParquetReaders
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/AdaptHiveFlinkParquetReaders.java:59
ClassAdaptHiveFlinkParquetWriters
Copy from iceberg {@link FlinkParquetWriters} to support int96 type and use {@link AdaptHiveParquetWithFlinkSchemaVisitor}.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/data/AdaptHiveFlinkParquetWriters.java:67
ClassAdaptHiveGenericAppenderFactory
Factory to create a new {@link FileAppender} to write {@link Record}s.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/data/AdaptHiveGenericAppenderFactory.java:46
ClassAdaptHiveGenericKeyedDataReader
Implementation of {@link AbstractKeyedDataReader} with record type {@link Record}.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/reader/AdaptHiveGenericKeyedDataReader.java:44
ClassAdaptHiveGenericMixedDeleteFilter
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/reader/AbstractAdaptHiveKeyedDataReader.java:149
ClassAdaptHiveGenericParquetReaders
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/data/parquet/AdaptHiveGenericParquetReaders.java:33
ClassAdaptHiveGenericParquetWriter
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/data/parquet/AdaptHiveGenericParquetWriter.java:28
ClassAdaptHiveGenericTaskWriterBuilder
Builder to create writers for {@link KeyedTable} writing {@link Record}.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/writer/AdaptHiveGenericTaskWriterBuilder.java:59
ClassAdaptHiveGenericUnkeyedDataReader
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/reader/AdaptHiveGenericUnkeyedDataReader.java:42
ClassAdaptHiveIcebergTableHandle
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/unkeyed/AdaptHiveIcebergTableHandle.java:40
ClassAdaptHiveMixedDeleteFilter
Abstract implementation of MixedDeleteFilter to adapt hive when open equality delete files. @param <T> to indicate the record data type.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/reader/AdaptHiveMixedDeleteFilter.java:41
ClassAdaptHiveOperateToTableRelation
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/writer/AdaptHiveOperateToTableRelation.java:29
ClassAdaptHiveOutputFileFactory
<pre> For adapt hive table with partitions the dir construct is : ${table_location} -| change -| base -| hive
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/writer/AdaptHiveOutputFileFactory.java:55
ClassAdaptHiveParquet
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:97
ClassAdaptHiveParquetConversions
Copy from iceberg {@link org.apache.iceberg.parquet.ParquetConversions} to resolve int96 type.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetConversions.java:46
ClassAdaptHiveParquetDictionaryRowGroupFilter
Copy from iceberg {@link org.apache.iceberg.parquet.ParquetDictionaryRowGroupFilter} to resolve int96 type.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetDictionaryRowGroupFilter.java:56
ClassAdaptHiveParquetMetricsRowGroupFilter
Copy from iceberg {@link org.apache.iceberg.parquet.ParquetMetricsRowGroupFilter} to resolve int96 type.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetMetricsRowGroupFilter.java:53
ClassAdaptHiveParquetReader
Copy from iceberg {@link org.apache.iceberg.parquet.ParquetReader} to use {@link AdaptHiveReadConf}
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetReader.java:42
ClassAdaptHiveParquetSchemaUtil
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetSchemaUtil.java:36
ClassAdaptHiveParquetUtil
Copy from {@link ParquetUtil} to resolve int96 in metric.
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetUtil.java:55
ClassAdaptHiveParquetWithFlinkSchemaVisitor
Copy from iceberg {@link ParquetWithFlinkSchemaVisitor}. see annotation "Change For mixed-format"
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/data/AdaptHiveParquetWithFlinkSchemaVisitor.java:40
ClassAdaptHiveParquetWithSparkSchemaVisitor
Copy from iceberg {@link org.apache.iceberg.spark.data.ParquetWithSparkSchemaVisitor} to change some code, see annotation "Change for mixed-format tab
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/iceberg/spark/data/AdaptHiveParquetWithSparkSchemaVisitor.java:43
ClassAdaptHiveParquetWithSparkSchemaVisitor
Copy from iceberg {@link ParquetWithSparkSchemaVisitor} to change some code, see annotation "Change for mixed-format table"
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/iceberg/spark/data/AdaptHiveParquetWithSparkSchemaVisitor.java:43
ClassAdaptHiveParquetWithSparkSchemaVisitor
Copy from iceberg {@link org.apache.iceberg.spark.data.ParquetWithSparkSchemaVisitor} to change some code, see annotation "Change for mixed-format tab
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/iceberg/spark/data/AdaptHiveParquetWithSparkSchemaVisitor.java:43
ClassAdaptHiveParquetWriter
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetWriter.java:47
ClassAdaptHivePrimitiveWriter
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHivePrimitiveWriter.java:27
ClassAdaptHiveReadConf
Copy from iceberg {@ling org.apache.iceberg.parquet.ReadConf} to use {@link AdaptHiveParquetMetricsRowGroupFilter} and {@link AdaptHiveParquetDictiona
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveReadConf.java:49
ClassAdaptHiveSparkParquetWriters
Copy from iceberg {@link org.apache.iceberg.spark.data.SparkParquetWriters} to support int96 type.
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/iceberg/spark/data/AdaptHiveSparkParquetWriters.java:63
ClassAdaptHiveSparkParquetWriters
Copy from iceberg {@link SparkParquetWriters} to support int96 type.
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/iceberg/spark/data/AdaptHiveSparkParquetWriters.java:60
ClassAdaptHiveSparkParquetWriters
Copy from iceberg {@link org.apache.iceberg.spark.data.SparkParquetWriters} to support int96 type.
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/iceberg/spark/data/AdaptHiveSparkParquetWriters.java:63
ClassAdaptHiveTypeToMessageType
Copy from iceberg {@link org.apache.iceberg.parquet.TypeToMessageType} for follow reason: 1. Make timestamp to int96. 2. remove {@link AvroSchemaUtil#
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveTypeToMessageType.java:43
ClassAdd
amoro-format-iceberg/src/main/java/org/apache/amoro/op/KeyedSchemaUpdate.java:412
ClassAggregationClauseContext
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:4255
ClassAggregationClauseContext
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:4050
ClassAggregationClauseContext
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:4255
ClassAliasedQueryContext
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:6342
ClassAliasedQueryContext
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:6052
ClassAliasedQueryContext
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:6342
ClassAliasedRelationContext
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:6315
ClassAliasedRelationContext
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:6027
ClassAliasedRelationContext
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/gen-antlr/org/apache/amoro/spark/sql/parser/MixedFormatSqlExtendParser.java:6315
ClassAlreadyExistsException
amoro-common/src/main/java/org/apache/amoro/AlreadyExistsException.java:21
ClassAlreadyExistsException
amoro-common/src/main/java/org/apache/amoro/exception/AlreadyExistsException.java:23
ClassAlreadyExistsException
General definition of the amoro thrift interface. This file defines the type definitions that all of amoro's multiple thrift services depend on.
amoro-common/src/main/gen-java/org/apache/amoro/api/AlreadyExistsException.java:14
ClassAlreadyExistsExceptionStandardScheme
amoro-common/src/main/gen-java/org/apache/amoro/api/AlreadyExistsException.java:308
ClassAlreadyExistsExceptionStandardSchemeFactory
amoro-common/src/main/gen-java/org/apache/amoro/api/AlreadyExistsException.java:301
ClassAlreadyExistsExceptionTupleScheme
amoro-common/src/main/gen-java/org/apache/amoro/api/AlreadyExistsException.java:363
ClassAlreadyExistsExceptionTupleSchemeFactory
amoro-common/src/main/gen-java/org/apache/amoro/api/AlreadyExistsException.java:356
ClassAlwaysTrueEvaluator
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/TableEntriesScan.java:444
ClassAmoroAMSTest
amoro-ams/src/test/java/org/apache/amoro/server/AmoroAMSTest.java:31
InterfaceAmoroCatalog
Base Catalog interface for Amoro.
amoro-common/src/main/java/org/apache/amoro/AmoroCatalog.java:24
ClassAmoroCatalogITCaseBase
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/table/AmoroCatalogITCaseBase.java:44
ClassAmoroCatalogTestBase
amoro-common/src/test/java/org/apache/amoro/formats/AmoroCatalogTestBase.java:29
InterfaceAmoroCatalogTestHelper
Helper Interface for testing AmoroCatalog.
amoro-common/src/test/java/org/apache/amoro/formats/AmoroCatalogTestHelper.java:26
EnumAmoroErrorCode
Error code
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/AmoroErrorCode.java:28
ClassAmoroException
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroException.java:9
ClassAmoroExceptionStandardScheme
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroException.java:464
ClassAmoroExceptionStandardSchemeFactory
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroException.java:457
ClassAmoroExceptionTupleScheme
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroException.java:543
ClassAmoroExceptionTupleSchemeFactory
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroException.java:536
ClassAmoroIOException
Exception thrown for table IO-related failures.
amoro-common/src/main/java/org/apache/amoro/AmoroIOException.java:22
ClassAmoroManagementConf
amoro-ams/src/main/java/org/apache/amoro/server/AmoroManagementConf.java:29
next →1–100 of 3,104, ranked by callers