MCPcopy Create free account

hub / github.com/apache/amoro / functions

Functions26,017 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
↓ 36 callersMethodequals
(Object o)
amoro-format-iceberg/src/main/java/org/apache/amoro/data/ChangedLsn.java:93
↓ 36 callersMethodpartitionToPath
(SupportHive table, StructLike data)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/utils/HiveMetaSynchronizer.java:364
↓ 36 callersMethodtableRecords
(MixedTable table)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/TestTableUtil.java:233
↓ 36 callersMethodtimestampMillis
The timestamp of event when it is happened. @return event created time.
amoro-common/src/main/java/org/apache/amoro/events/Event.java:36
↓ 36 callersMethodwithKeyMetadata
(EncryptionKeyMetadata metadata)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:482
↓ 36 callersMethodwriteDeletes
(OutputFile file)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:504
↓ 35 callersMethodcontent
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java:151
↓ 35 callersMethodcreateDatabase
create database catalog. @param databaseName database name @throws AlreadyExistsException when database already exist. @throws NoSuchNamespaceExcepti
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:70
↓ 35 callersMethoddropTable
Clean table resources created by AMS @param purge if purge data
amoro-ams/src/main/java/org/apache/amoro/server/table/internal/InternalTableHandler.java:47
↓ 35 callersMethodfield
(Types.NestedField field, Supplier<Type> future)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/utils/ChangeFieldName.java:98
↓ 35 callersMethodgetTableCommitMetas
()
amoro-common/src/test/java/org/apache/amoro/MockAmoroManagementServer.java:242
↓ 35 callersMethodhasNext
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/DataIterator.java:120
↓ 35 callersMethodlistDatabases
Show database list of catalog. @return database list of catalog
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:61
↓ 35 callersMethodpartitionProperty
Returns the partition properties map.
amoro-format-iceberg/src/main/java/org/apache/amoro/table/UnkeyedTable.java:32
↓ 35 callersMethodreadRecords
(Table table)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/AbstractOptimizingTest.java:312
↓ 35 callersMethodsetString
Adds the given key/value pair to the configuration object. @param key the key of the key/value pair to be added @param value the value of the key/val
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:140
↓ 35 callersMethodtableService
()
amoro-ams/src/test/java/org/apache/amoro/server/table/TestTableRuntimeHandler.java:125
↓ 34 callersMethoddropDatabase
(String name, boolean deleteData, boolean ignoreUnknownDb, boolean cascade)
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:62
↓ 34 callersMethodgetMixedTable
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/scan/TestKeyedTableFileScanHelper.java:263
↓ 34 callersMethodgetMixedTable
()
amoro-format-mixed/amoro-mixed-hive/src/test/java/org/apache/amoro/hive/MixedHiveTableTestBase.java:32
↓ 34 callersMethodpartition
(LogData<T> logData, int[] partitions)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/hidden/MixedFormatLogPartitioner.java:43
↓ 34 callersMethodtoMap
()
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:561
↓ 34 callersMethodtoString
()
amoro-format-iceberg/src/test/java/org/apache/amoro/log/FormatTestBase.java:368
↓ 34 callersMethodupdateSchema
Create a new {@link UpdateSchema} to alter the columns of this table and commit the change. @return a new {@link UpdateSchema}
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:68
↓ 33 callersMethodbaseStore
Return the base store of the mixed-format table.
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/MixedTableUtil.java:45
↓ 33 callersMethodgetOptimizingStatus
()
amoro-ams/src/main/java/org/apache/amoro/server/table/TableRuntime.java:473
↓ 33 callersMethodgetRuntime
(Long tableId)
amoro-ams/src/main/java/org/apache/amoro/server/table/TableService.java:35
↓ 33 callersMethodgetSessionCatalog
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/SessionCatalogBase.java:69
↓ 33 callersMethodgetSpec
(int specId)
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/scan/TableFileScanHelper.java:52
↓ 33 callersMethodgetStatus
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingProcess.java:43
↓ 33 callersMethodkey
Gets the configuration key. @return The configuration key
amoro-common/src/main/java/org/apache/amoro/config/ConfigOption.java:105
↓ 32 callersMethodROW
()
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:12137
↓ 32 callersMethodassertOptimizingProcess
( OptimizingProcessMeta optimizingProcess, OptimizingType optimizeType, int fileCntBefore,
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/BaseOptimizingChecker.java:89
↓ 32 callersMethodequals
(Object o)
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/controller/CatalogController.java:720
↓ 32 callersMethodgetFieldName
()
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:2900
↓ 32 callersMethodgetProcessId
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingProcess.java:27
↓ 32 callersMethodnewTableBuilder
Instantiate a builder to build a table. @param identifier a table identifier @param schema a schema @return the builder to build a table
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:137
↓ 32 callersMethodoriginalTable
Returns the original of this table
amoro-common/src/main/java/org/apache/amoro/AmoroTable.java:42
↓ 32 callersMethodparse
(Map<String, String> properties)
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/OptimizingInputProperties.java:52
↓ 32 callersMethodread
(org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocol iprot)
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1432
↓ 32 callersMethodrecordCount
Returns the estimated count of record reading from the task
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/KeyedTableScanTask.java:39
↓ 32 callersMethodtoString
()
amoro-ams/src/main/java/org/apache/amoro/server/table/TableRuntime.java:589
↓ 32 callersMethodvalidate
()
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1451
↓ 31 callersMethodappendBase
(MixedTable mixedTable, List<DataFile> dataFiles)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/OptimizingTestHelpers.java:63
↓ 31 callersMethodcommit
(MixedTable mixedTable, WriteResult result, boolean base)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/FlinkTableTestBase.java:74
↓ 31 callersMethodcompareTo
(ping_args other)
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1415
↓ 31 callersMethodcreateCatalog
Creates a catalog based on the provided catalog meta information. The catalog name is obtained from the catalog meta. @param catalogMeta the catalog
amoro-ams/src/main/java/org/apache/amoro/server/catalog/CatalogManager.java:80
↓ 31 callersMethodexecute
Execute compaction for {@link TableOptimizing.OptimizingInput}
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/OptimizingExecutor.java:31
↓ 31 callersMethodgetCatalogProperties
( Configurations configuration, String catalog)
amoro-ams/src/main/java/org/apache/amoro/server/terminal/TerminalSessionFactory.java:81
↓ 31 callersMethodgetTaskId
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/TaskRuntime.java:192
↓ 31 callersMethodisSetE1
Returns true if field e1 is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:2310
↓ 31 callersMethodlistTables
Show table list of database. @param database database name @return table list of database @throws NoSuchDatabaseException when database not exists.
amoro-common/src/main/java/org/apache/amoro/FormatCatalog.java:33
↓ 31 callersMethodof
( String catalogType, String storageType, TableFormat tableFormat)
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/controller/CatalogController.java:703
↓ 31 callersMethodpartition
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java:170
↓ 31 callersMethodpathSet
(ContentFile<?>... files)
amoro-format-iceberg/src/test/java/org/apache/iceberg/TestIcebergFindFiles.java:373
↓ 31 callersMethodrelease
Release the blocker. @param blocker the blocker to release
amoro-format-iceberg/src/main/java/org/apache/amoro/table/blocker/TableBlockerManager.java:59
↓ 31 callersMethodtoString
()
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:3006
↓ 30 callersMethodLT
()
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:10961
↓ 30 callersMethodLT
()
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:10961
↓ 30 callersMethodarray
( org.apache.spark.sql.types.ArrayType array, org.apache.paimon.types.DataType elementResult)
amoro-format-paimon/src/main/java/org/apache/amoro/formats/paimon/PaimonTypeToSparkType.java:242
↓ 30 callersMethodgetCatalog
(java.lang.String name)
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:23
↓ 30 callersMethodgetOptimizerHandler
()
amoro-common/src/test/java/org/apache/amoro/TestAms.java:53
↓ 30 callersMethodidentifier
()
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:12555
↓ 30 callersMethodidentifier
()
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:11872
↓ 30 callersMethodidentifier
()
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:12555
↓ 30 callersMethodof
(long cost, String methodName)
amoro-common/src/test/java/org/apache/amoro/listener/AmoroRunListener.java:100
↓ 30 callersMethodrange
Create a {@link Projection} of a field range.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/Projection.java:162
↓ 30 callersMethodsetAll
(Map<String, String> properties)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:154
↓ 30 callersMethodwaitOptimizeResult
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/BaseOptimizingChecker.java:108
↓ 29 callersMethodclear
()
amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTable.java:337
↓ 29 callersMethodgenerateRowData
(String fieldName, Object val)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/lookup/filter/TestRowDataPredicateAllFieldTypes.java:252
↓ 29 callersMethodgetIdentifier
Returns a globally unique identifier for the sorter instance, such as Balanced、balanced and BALANCED represent the different sorter instance. The {@li
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/sorter/SorterFactory.java:44
↓ 29 callersMethodmin
(Statistics<?> statistics, int id)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetMetricsRowGroupFilter.java:496
↓ 29 callersMethodsort
(final Expression expr, boolean ascending)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/util/ExpressionHelper.java:40
↓ 29 callersMethodtransform
()
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:7462
↓ 28 callersMethodcall
(OptimizingService.Iface client)
amoro-optimizer/amoro-optimizer-common/src/main/java/org/apache/amoro/optimizer/common/AbstractOptimizerOperator.java:166
↓ 28 callersMethodcreate
create a new session @param metaStore - auth info @param configuration - configuration of session, all properties are defined in {@link SessionCo
amoro-ams/src/main/java/org/apache/amoro/server/terminal/TerminalSessionFactory.java:48
↓ 28 callersMethodfindByThriftId
Find the _Fields constant that matches fieldId, or null if its not found.
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1297
↓ 28 callersMethodgetConfiguration
(HdfsContext context, URI uri)
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/MixedFormatHdfsConfiguration.java:40
↓ 28 callersMethodgetScheme
()
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1515
↓ 28 callersMethodloadTable
(ConnectorSession session, SchemaTableName tableName)
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergMetadata.java:2758
↓ 28 callersMethodplanTasks
Plan the {@link CombinedScanTask tasks} for this scan. @return an Iterable of tasks for this scan
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/KeyedTableScan.java:41
↓ 27 callersMethodassertIds
(List<Record> actualRows, Object... expectIds)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/BaseOptimizingChecker.java:54
↓ 27 callersMethodgetColumns
()
amoro-common/src/main/gen-java/org/apache/amoro/api/Schema.java:192
↓ 27 callersMethodgetRowKind
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/KeyRowData.java:44
↓ 27 callersMethodgetTableName
()
amoro-common/src/main/java/org/apache/amoro/table/TableIdentifier.java:71
↓ 27 callersMethodgetTimestamp
(int pos)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogArrayData.java:44
↓ 27 callersMethodmap
( Types.MapType expectedMap, GroupType map, ParquetValueReader<?> keyReader, P
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/reader/SparkParquetReaders.java:191
↓ 27 callersMethodparseMemorySize
memory conversion of units method, supporting m and g units
amoro-ams/src/main/java/org/apache/amoro/server/manager/FlinkOptimizerContainer.java:355
↓ 27 callersMethodsetParallelism
(int parallelism)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/MockEnvironmentBuilder.java:125
↓ 27 callersMethodtableExists
Check whether table exists. @param tableIdentifier a table identifier @return true if the table exists, false otherwise
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:102
↓ 27 callersMethodtasks
Return the {@link KeyedTableScanTask tasks} in this combined task. @return a Collection of FileScanTask instances.
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/CombinedScanTask.java:31
↓ 26 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:844
↓ 26 callersMethodbuildMetaStore
Build {@link TableMetaStore} from catalog meta.
amoro-common/src/main/java/org/apache/amoro/utils/CatalogUtil.java:110
↓ 26 callersMethodisSetAuthToken
Returns true if field authToken is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1931
↓ 26 callersMethodisSetCatalogName
Returns true if field catalogName is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:8910
↓ 26 callersMethodisSetE
Returns true if field e is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:10343
↓ 26 callersMethodisSetE2
Returns true if field e2 is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:11317
↓ 26 callersMethodmap
( Types.MapType expectedMap, GroupType map, ParquetValueReader<?> keyReader, P
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/reader/SparkParquetReaders.java:191
↓ 26 callersMethodmetricsConfig
(MetricsConfig newMetricsConfig)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:170
← previousnext →301–400 of 26,017, ranked by callers