MCPcopy Create free account

hub / github.com/apache/amoro / functions

Functions26,017 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
↓ 20 callersMethodgetTableRuntimeMetas
()
amoro-ams/src/test/java/org/apache/amoro/server/table/TestSyncTableOfExternalCatalog.java:590
↓ 20 callersMethodgetType
()
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/model/TableMeta.java:40
↓ 20 callersMethodisNullAt
(int pos)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogArrayData.java:60
↓ 20 callersMethodloadHiveTable
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:243
↓ 20 callersMethodnewInputFile
(String path)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/AuthenticatedHadoopFileIO.java:56
↓ 20 callersMethodoperations
Blocked operations. @return operations
amoro-format-iceberg/src/main/java/org/apache/amoro/table/blocker/Blocker.java:47
↓ 20 callersMethodplanWithCurrentFiles
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/plan/MixedTablePlanTestBase.java:329
↓ 20 callersMethodpoll
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java:420
↓ 20 callersMethodputNotNullProperties
( Map<String, String> properties, String key, String value)
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/utils/PropertiesUtil.java:31
↓ 20 callersMethodselect
(List<String> newColumns)
amoro-format-iceberg/src/main/java/org/apache/iceberg/IcebergFindFiles.java:226
↓ 20 callersMethodtableCatalog
(TableFormat format)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/SparkUnifiedCatalogBase.java:308
↓ 20 callersMethodvalidateHiveTableValues
( HiveMetaStoreClient hiveClient, MixedTable table, List<DataFile> exceptFiles)
amoro-format-mixed/amoro-mixed-hive/src/test/java/org/apache/amoro/hive/op/UpdateHiveFilesTestHelpers.java:48
↓ 20 callersMethodwrite
(MixedTable table, LocationKind locationKind, List<Record> records)
amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTable.java:343
↓ 20 callersMethodwriteChangeStore
( KeyedTable keyedTable, Long txId, ChangeAction action, List<Record> records, b
amoro-format-iceberg/src/test/java/org/apache/amoro/TableTestHelper.java:58
↓ 19 callersMethodalwaysTrue
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetDictionaryRowGroupFilter.java:130
↓ 19 callersMethodbuilderFor
(Table table, Schema writeSchema, StructType dsSchema)
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/io/InternalRowFileAppenderFactory.java:72
↓ 19 callersMethodbuilderFor
( Table table, Schema writeSchema, StructType dsSchema)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/io/InternalRowFileAppenderFactory.java:72
↓ 19 callersMethodcatalogManager
()
amoro-ams/src/test/java/org/apache/amoro/server/AMSManagerTestBase.java:62
↓ 19 callersMethodcomplete
This method will trigger all callback functions in the same thread and wait until all callback functions are completed. If throws exception, completed
amoro-common/src/main/java/org/apache/amoro/process/SimpleFuture.java:82
↓ 19 callersMethodcompoundKey
(Object... components)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/FlinkSchemaUtil.java:424
↓ 19 callersMethoddurationType
Defines that the value of the option should be of {@link Duration} type.
amoro-common/src/main/java/org/apache/amoro/config/ConfigOptions.java:142
↓ 19 callersMethodencryption
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/op/HiveOperationTransaction.java:363
↓ 19 callersMethodhiveLocation
Base path to store hive data files @return path to store hive file
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/table/SupportHive.java:35
↓ 19 callersMethodloadMixedTable
(MixedFormatTableLoader tableLoader)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/MixedFormatUtils.java:72
↓ 19 callersMethodnamed
(String newName)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:139
↓ 19 callersMethodnewAutoCreateIcebergTagAction
(Table table, LocalDateTime now)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/maintainer/TestAutoCreateIcebergTagAction.java:58
↓ 19 callersMethodof
(OpType opType, byte[] keyBytes, byte[] valueBytes)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/LookupRecord.java:33
↓ 19 callersMethodpath
(String name)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common-iceberg-bridge/src/main/java/org/apache/iceberg/flink/data/AdaptHiveParquetWithFlinkSchemaVisitor.java:226
↓ 19 callersMethodread
(InputFile file)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:735
↓ 19 callersMethodserialize
(T data)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/StatisticsFileUtil.java:238
↓ 19 callersMethodsql
(String sqlText)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:154
↓ 19 callersMethodtoString
()
amoro-common/src/main/java/org/apache/amoro/config/ConfigOption.java:158
↓ 19 callersMethodvalueExpression
()
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:8048
↓ 18 callersMethodackTask
(java.lang.String authToken, int threadId, OptimizingTaskId taskId)
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:21
↓ 18 callersMethodaddColumn
(String name, Type type, String doc)
amoro-format-iceberg/src/main/java/org/apache/amoro/op/KeyedSchemaUpdate.java:63
↓ 18 callersMethodbuild
()
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedUpdate.java:212
↓ 18 callersMethodbuildEqualityWriter
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:609
↓ 18 callersMethodbuildPositionWriter
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:646
↓ 18 callersMethodbuilder
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/InternalCatalogBuilder.java:129
↓ 18 callersMethodbuilderFor
(MixedTable table)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/io/writer/AdaptHiveGenericTaskWriterBuilder.java:328
↓ 18 callersMethodcompleteTask
(java.lang.String authToken, OptimizingTaskResult taskResult)
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:23
↓ 18 callersMethoddispose
()
amoro-ams/src/main/java/org/apache/amoro/server/table/TableService.java:29
↓ 18 callersMethodequals
(Object other)
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/table/MixedSparkTable.java:162
↓ 18 callersMethodequals
Return true if the bytes in each wrapper are equal. @param other the object to compare to. @return true if the two objects are equal.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/ByteArrayWrapper.java:168
↓ 18 callersMethodfromBytes
(byte[] data)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/FormatVersion.java:59
↓ 18 callersMethodgetAuthConfigs
()
amoro-common/src/main/gen-java/org/apache/amoro/api/CatalogMeta.java:280
↓ 18 callersMethodgetConfig
()
amoro-optimizer/amoro-optimizer-common/src/main/java/org/apache/amoro/optimizer/common/AbstractOptimizerOperator.java:125
↓ 18 callersMethodgetFormat
()
amoro-ams/src/main/java/org/apache/amoro/server/table/TableRuntime.java:469
↓ 18 callersMethodgetMetrics
()
amoro-ams/src/main/java/org/apache/amoro/server/metrics/MetricRegistry.java:128
↓ 18 callersMethodgetResourceId
()
amoro-common/src/main/java/org/apache/amoro/resource/Resource.java:63
↓ 18 callersMethodgetTableConfiguration
Get the table configuration. @return the table configuration
amoro-common/src/main/java/org/apache/amoro/TableRuntime.java:65
↓ 18 callersMethodgetTableRuntime
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/plan/MixedTablePlanTestBase.java:558
↓ 18 callersMethodgetTestFormat
()
amoro-format-iceberg/src/test/java/org/apache/amoro/catalog/CatalogTestBase.java:94
↓ 18 callersMethodhasNext
()
amoro-format-iceberg/src/main/java/org/apache/amoro/io/CloseableIteratorWrapper.java:62
↓ 18 callersMethodoriginalCatalog
Get the original flink catalog for the given table, if the flink catalog is not exists in the cache, would create a new original flink catalog for thi
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/catalog/FlinkUnifiedCatalog.java:466
↓ 18 callersMethodparseTableConfig
Parse table configuration from table properties @param properties table properties @return table configuration
amoro-ams/src/main/java/org/apache/amoro/server/table/TableConfigurations.java:55
↓ 18 callersMethodproject
(Schema newSchema)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:773
↓ 18 callersMethodpropertyAsBoolean
( Map<String, String> properties, String property, boolean defaultValue)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/CompatiblePropertyUtil.java:31
↓ 18 callersMethodquery
()
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:1084
↓ 18 callersMethodrequiredSchema
()
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/DeleteFilter.java:115
↓ 18 callersMethodsetSuccessIsSet
(boolean value)
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:14116
↓ 18 callersMethodsnapshot
(long snapshotId)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/op/HiveOperationTransaction.java:263
↓ 18 callersMethodwhenMatched
if condition(target, source) test for true. then apply action(target, source) to target records. @param condition - condition(target, source): bool @
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/ExpectResultUtil.java:163
↓ 18 callersMethodwithProperties
Adds key/value properties to the table. @param properties key/value properties @return this object for chaining call
amoro-format-iceberg/src/main/java/org/apache/amoro/table/TableBuilder.java:51
↓ 18 callersMethodwriteToBase
(MixedTable table, List<Record> data)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/TestTableUtil.java:332
↓ 17 callersMethodassertScanResult
( List<TableFileScanHelper.FileScanResult> result, int size, Integer deleteCnt)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/scan/TableFileScanHelperTestBase.java:45
↓ 17 callersMethodassertTaskStatus
(TaskRuntime.Status expectedStatus)
amoro-ams/src/test/java/org/apache/amoro/server/TestDefaultOptimizingService.java:699
↓ 17 callersMethodbucket
(int numBuckets, String... columns)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/util/ExpressionHelper.java:32
↓ 17 callersMethodbuildWriter
(WriteOperationKind writeOperationKind)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/FlinkTaskWriterBuilder.java:96
↓ 17 callersMethodcaseSensitive
(boolean caseSensitive)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/op/OverwriteHiveFiles.java:97
↓ 17 callersMethodcontext
(ProviderContext context)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/FlinkSink.java:112
↓ 17 callersMethoddefineCounter
(String name)
amoro-common/src/main/java/org/apache/amoro/metrics/MetricDefine.java:113
↓ 17 callersMethodequals
(Object o)
amoro-common/src/main/java/org/apache/amoro/table/TableMetaStore.java:304
↓ 17 callersMethodfileName
(TaskWriterKey key)
amoro-format-iceberg/src/main/java/org/apache/amoro/data/FileNameRules.java:82
↓ 17 callersMethodgetChanges
()
amoro-common/src/main/gen-java/org/apache/amoro/api/TableCommitMeta.java:285
↓ 17 callersMethodgetContainers
check if optimizerGroup can be deleted url = /optimize/containers/get
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/controller/OptimizerController.java:94
↓ 17 callersMethodgetField
(GenericInternalRow intermediate, int pos)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/reader/SparkParquetReaders.java:543
↓ 17 callersMethodgetFile
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/IcebergTableMaintainer.java:1069
↓ 17 callersMethodgetSchema
@param db @param tableName @throws UnknownTableException @throws UnknownDBException @throws MetaException @throws TException @see org.apache.hadoo
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java:1752
↓ 17 callersMethodgetServerCatalog
()
amoro-ams/src/test/java/org/apache/amoro/server/catalog/TestServerCatalog.java:137
↓ 17 callersMethodgetSummary
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingProcess.java:49
↓ 17 callersMethodgetTableType
()
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/model/HiveTableInfo.java:60
↓ 17 callersMethodimpl
Checks for an implementation, first finding the given class by name. @param className name of a class @param methodName name of a method (different f
amoro-common/src/main/java/org/apache/amoro/utils/DynMethods.java:248
↓ 17 callersMethodinvokeConsistency
(Runnable runnable)
amoro-ams/src/main/java/org/apache/amoro/server/table/TableRuntime.java:651
↓ 17 callersMethodnewHiveSubdirectory
(long transactionId)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/utils/HiveTableUtil.java:107
↓ 17 callersMethodnewTransaction
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/BasicUnkeyedTable.java:269
↓ 17 callersMethodof
( TableIdentifier tableIdentifier, String ddl, DDLType ddlType, Long commitTime)
amoro-common/src/main/java/org/apache/amoro/table/descriptor/DDLInfo.java:29
↓ 17 callersMethodopenNestedSession
()
amoro-ams/src/main/java/org/apache/amoro/server/persistence/NestedSqlSession.java:57
↓ 17 callersMethodpath
(String name)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/iceberg/spark/data/AdaptHiveParquetWithSparkSchemaVisitor.java:231
↓ 17 callersMethodprepareSnapshotPreBarrier
(long checkpointId)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/MixedFormatWriter.java:132
↓ 17 callersMethodrefresh
Refresh catalog meta
amoro-common/src/main/java/org/apache/amoro/UnifiedCatalog.java:51
↓ 17 callersMethodtableMetadata
@return Persistent {@link TableMetadata} object
amoro-ams/src/main/java/org/apache/amoro/server/table/internal/InternalTableHandler.java:33
↓ 17 callersMethodwithNameMapping
(NameMapping newNameMapping)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:839
↓ 16 callersMethodbuildWriter
(WriteOperationKind writeOperationKind)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/TaskWriterBuilder.java:32
↓ 16 callersMethodcomplete
(OptimizerThread thread, OptimizingTaskResult result)
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/TaskRuntime.java:84
↓ 16 callersMethodday
( String sourceName, int sourceId, SortDirection direction, NullOrder nullOrder)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/util/SortOrderToSpark.java:65
↓ 16 callersMethoddeletes
()
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/BasicMixedFileScanTask.java:94
↓ 16 callersMethoddifference
Perform a difference of this {@link Projection} with another {@link Projection}. The result of this operation is a new {@link Projection} retaining th
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/Projection.java:90
↓ 16 callersMethodencryption
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/BasicUnkeyedTable.java:280
↓ 16 callersMethodfloorMod
(long x, long y)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/DateTimeUtils.java:1056
← previousnext →501–600 of 26,017, ranked by callers