MCPcopy Create free account

hub / github.com/apache/amoro / functions

Functions26,017 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
↓ 26 callersMethodpartition
(RewriteFilesInput input)
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/KeyedTableCommit.java:219
↓ 26 callersMethodpropertyAsBoolean
( Map<String, String> properties, String property, boolean defaultValue)
amoro-common/src/main/java/org/apache/amoro/utils/PropertyUtil.java:27
↓ 26 callersMethodresolveSQLFilterToExpression
This method takes in an SQL filter expression and a ResolvedSchema object, and returns a List of ResolvedExpression objects.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/lookup/filter/TestRowDataPredicateBase.java:60
↓ 26 callersMethodtableService
()
amoro-ams/src/test/java/org/apache/amoro/server/AMSServiceTestBase.java:67
↓ 26 callersMethodwrap
(byte[] bytes)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/RocksDBCacheState.java:158
↓ 25 callersMethodassertArrayEquals
(RowData[] excepts, List<RowData> actual)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hybrid/reader/TestRowDataReaderFunction.java:181
↓ 25 callersMethodbuildReader
( Schema expectedSchema, MessageType fileSchema)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/data/parquet/AdaptHiveGenericParquetReaders.java:40
↓ 25 callersMethodcatalog
The catalog name that this event source related to. @return Catalog name
amoro-common/src/main/java/org/apache/amoro/events/TableEvent.java:29
↓ 25 callersMethodcopy
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java:284
↓ 25 callersMethodexpireSnapshots
Expire snapshots. The optimizing based on the snapshot that the current table relies on will not expire according to TableRuntime.
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/TableMaintainer.java:48
↓ 25 callersMethodgetLong
(int pos)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogArrayData.java:38
↓ 25 callersMethodgetMixedTable
()
amoro-format-iceberg/src/test/java/org/apache/amoro/utils/TestUnkeyedExpressionUtil.java:65
↓ 25 callersMethodgetRuntimeContext
()
amoro-common/src/main/java/org/apache/amoro/table/TableMetaStore.java:281
↓ 25 callersMethodgetSnapshotId
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergMetadata.java:2770
↓ 25 callersMethodisSetSuccess
Returns true if field success is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:3182
↓ 25 callersMethodnewOverwrite
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/table/UnkeyedHiveTable.java:135
↓ 25 callersMethodnode
Returns the {@link DataTreeNode} file belong
amoro-format-iceberg/src/main/java/org/apache/amoro/data/PrimaryKeyedFile.java:31
↓ 25 callersMethodpollTask
(java.lang.String authToken, int threadId)
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:19
↓ 25 callersMethodtoString
()
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/RecordWithAction.java:108
↓ 25 callersMethodvalueExpression
()
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:8414
↓ 25 callersMethodvalueExpression
()
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:8414
↓ 24 callersMethodLT
()
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:10310
↓ 24 callersMethodapply
()
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedUpdate.java:129
↓ 24 callersMethodcompare
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/lookup/TestKVTable.java:534
↓ 24 callersMethoddeepCopy
@param partition @return
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java:1823
↓ 24 callersMethodgetBoolean
(int pos)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogArrayData.java:34
↓ 24 callersMethodlength
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/delete/DummyFileScanTask.java:69
↓ 24 callersMethodpartition
()
amoro-format-iceberg/src/main/java/org/apache/amoro/data/DefaultKeyedFile.java:147
↓ 24 callersMethodrecordPartition
(String opTime)
amoro-format-iceberg/src/test/java/org/apache/amoro/io/MixedDataTestHelpers.java:109
↓ 24 callersMethodvalues
Return Iterator of key-value pairs from RocksIterator. @param columnFamilyName Column Family Name
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/map/RocksDBBackend.java:351
↓ 24 callersMethodwrap
(T structLike)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/StructForDelete.java:48
↓ 23 callersMethodaddAll
(Iterable<WriteTaskCommit> results)
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:90
↓ 23 callersMethodaddAll
(Iterable<WriteTaskCommit> results)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:90
↓ 23 callersMethodbooleanType
Defines that the value of the option should be of {@link Boolean} type.
amoro-common/src/main/java/org/apache/amoro/config/ConfigOptions.java:112
↓ 23 callersMethodbuilderFor
(MixedTable table)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/GenericTaskWriters.java:44
↓ 23 callersMethodcreateDatabase
(Database db)
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:60
↓ 23 callersMethoddefaultResourceGroup
()
amoro-ams/src/test/java/org/apache/amoro/server/AMSManagerTestBase.java:74
↓ 23 callersMethoddropDatabase
drop database from catalog. @param databaseName database name
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:77
↓ 23 callersMethodentries
()
amoro-format-iceberg/src/main/java/org/apache/iceberg/IcebergFindFiles.java:241
↓ 23 callersMethodgetCatalogType
()
amoro-common/src/main/gen-java/org/apache/amoro/api/CatalogMeta.java:208
↓ 23 callersMethodlastedAddedFiles
(Table tableStore)
amoro-format-mixed/amoro-mixed-hive/src/test/java/org/apache/amoro/hive/io/HiveDataTestHelpers.java:144
↓ 23 callersMethodnewInstance
(Object... args)
amoro-common/src/main/java/org/apache/amoro/utils/DynConstructors.java:68
↓ 23 callersMethodnoDefaultValue
Creates a string-valued option with no default value. String-valued options are the only ones that can have no default value. @return The created Con
amoro-common/src/main/java/org/apache/amoro/config/ConfigOptions.java:196
↓ 23 callersMethodreadData
Reading data of optimizing task, If a task contains a delete operation, then the read result is MOR.
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/OptimizingDataReader.java:33
↓ 23 callersMethodspecId
()
amoro-format-iceberg/src/main/java/org/apache/amoro/data/DefaultKeyedFile.java:72
↓ 23 callersMethodtoLocalDateTime
(long timestamp)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/DateTimeUtils.java:290
↓ 23 callersMethodtoRows
(Collection<Object[]> data)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/DataUtil.java:52
↓ 23 callersMethodvalidateConfig
(Configurations configurations)
amoro-ams/src/main/java/org/apache/amoro/server/AmoroManagementConfValidator.java:28
↓ 22 callersMethodTIMESTAMP
()
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:13701
↓ 22 callersMethodand
(Expression leftResult, Expression rightResult)
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/expressions/RewriteNot.java:52
↓ 22 callersMethodbuild
()
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/ParallelIcebergGenerics.java:105
↓ 22 callersMethodcommitTransaction
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/op/HiveOperationTransaction.java:152
↓ 22 callersMethodfieldNames
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/PrimaryKeySpec.java:129
↓ 22 callersMethodgetClient
()
amoro-common/src/main/java/org/apache/amoro/hive/HMSClientImpl.java:41
↓ 22 callersMethodgetDefaultProp
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/maintainer/TestDataExpire.java:606
↓ 22 callersMethodgetOptional
(ConfigOption<T> option)
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:535
↓ 22 callersMethodgetOptions
Get properties.
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/TableOptimizing.java:57
↓ 22 callersMethodgetPartition
Get the partition represented by a Pair of {@link PartitionSpec#specId()} and partition {@link StructLike}. @return the Pair of the partition spec id
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/plan/PartitionEvaluator.java:45
↓ 22 callersMethodisDirectory
Check if a location is a directory. @param location source location @return true if the location is a directory
amoro-format-iceberg/src/main/java/org/apache/amoro/io/SupportsFileSystemOperations.java:43
↓ 22 callersMethodlistTables
Show table list of database. @param database database name @return Table list of database in catalog
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:85
↓ 22 callersMethodnewBuilder
(SparkSession spark)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/command/MigrateToMixedFormatCommand.java:264
↓ 22 callersMethodrollback
Rollback all resource created during {@link #create()}
amoro-ams/src/main/java/org/apache/amoro/server/table/internal/InternalTableCreator.java:35
↓ 22 callersFunctionrun_cmd
(cmd)
dev/merge_amoro_pr.py:67
↓ 22 callersMethodtoString
Converts a collection of MixedFileScanTask objects to a string representation. The string representation includes details about each file, such as its
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/FileScanTaskUtil.java:39
↓ 22 callersMethodtype
@return event type
amoro-common/src/main/java/org/apache/amoro/events/Event.java:29
↓ 21 callersMethodalterTable
(String defaultDatabaseName, String tblName, Table table)
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:51
↓ 21 callersMethodappendLog
(String log)
amoro-ams/src/main/java/org/apache/amoro/server/terminal/ExecutionResult.java:35
↓ 21 callersMethodapply
(CloseableIterable<T> records, Predicate<T> predicate)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/MixedDeleteFilter.java:406
↓ 21 callersMethodbuilder
(MixedTable table, int availableCore)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/CompleteOptimizingFlow.java:106
↓ 21 callersMethodbuilderFor
( Table table, Schema writeSchema, StructType dsSchema)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/io/InternalRowFileAppenderFactory.java:72
↓ 21 callersMethodclear
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/split/TemporalJoinSplits.java:120
↓ 21 callersMethodcreateTable
(Table tbl)
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:68
↓ 21 callersMethoddata
(PartitionSpec spec, String partitionPath)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/MixedDataFiles.java:110
↓ 21 callersMethodevaluator
()
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/plan/AbstractPartitionPlan.java:100
↓ 21 callersMethodgetCatalogMeta
Gets the catalog metadata for the given catalog name. @return the catalog meta information
amoro-ams/src/main/java/org/apache/amoro/server/catalog/CatalogManager.java:41
↓ 21 callersMethodgetFileDir
Parse file directory path from file path @param filePath file path @return file directory path parsed from file path
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/TableFileUtil.java:73
↓ 21 callersMethodgetLocations
()
amoro-common/src/main/gen-java/org/apache/amoro/api/TableMeta.java:276
↓ 21 callersMethodgetOperationTable
()
amoro-format-iceberg/src/test/java/org/apache/amoro/trace/TestTableTracer.java:88
↓ 21 callersMethodgetSnapshotId
(Table table, boolean refresh)
amoro-ams/src/main/java/org/apache/amoro/server/utils/IcebergTableUtil.java:82
↓ 21 callersMethodisSetDatabase
Returns true if field database is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:8935
↓ 21 callersMethodnewAppend
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/op/HiveOperationTransaction.java:107
↓ 21 callersMethodnewRowDelta
()
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedTransaction.java:125
↓ 21 callersMethodproject
(Schema schema)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/ParallelIcebergGenerics.java:80
↓ 21 callersMethodread
Returns a builder to configure a read of the given table that produces generic records. @param table an Iceberg table @return a builder to configure
amoro-format-iceberg/src/main/java/org/apache/amoro/io/reader/ParallelIcebergGenerics.java:41
↓ 21 callersMethodsetProperty
Set an arbitrary property for the LogKafkaSource and LogKafkaConsumer. The valid keys can be found in {@link ConsumerConfig} and {@link KafkaSourceOpt
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/log/kafka/LogKafkaSourceBuilder.java:343
↓ 20 callersMethodassertType
(Type expect, Type actual)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/Asserts.java:41
↓ 20 callersMethodcommitTransaction
()
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedTransaction.java:150
↓ 20 callersMethoddataFileFieldIndex
(String fieldName)
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/TableEntriesScan.java:415
↓ 20 callersMethoddatabaseExists
Check whether database exists. @param database a database name @return true if the database exists, false otherwise
amoro-common/src/main/java/org/apache/amoro/AmoroCatalog.java:39
↓ 20 callersMethoddeserialize
(ByteBuffer buffer)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/StatisticsFileUtil.java:240
↓ 20 callersMethodequals
(Object other)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/table/MixedSparkTable.java:162
↓ 20 callersMethodfiles
(MixedTable table)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/TestTableUtil.java:179
↓ 20 callersMethodgenerateRecord
( TableTestHelper tableTestHelper, int from, int to, String opTime)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/OptimizingTestHelpers.java:54
↓ 20 callersMethodgetCatalogName
()
amoro-common/src/main/gen-java/org/apache/amoro/api/CatalogMeta.java:183
↓ 20 callersMethodgetDatabase
()
amoro-common/src/main/java/org/apache/amoro/table/TableIdentifier.java:67
↓ 20 callersMethodgetFile
( String basePath, int number, PartitionSpec spec, String partitionPath, Metrics
amoro-format-iceberg/src/test/java/org/apache/amoro/DataFileTestHelpers.java:34
↓ 20 callersMethodgetKeySpec
()
amoro-common/src/main/gen-java/org/apache/amoro/api/TableMeta.java:204
↓ 20 callersMethodgetOptimizingConfig
()
amoro-ams/src/main/java/org/apache/amoro/server/table/TableRuntime.java:509
↓ 20 callersMethodgetOptimizingType
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingProcess.java:41
↓ 20 callersMethodgetServerCatalog
Retrieves the ServerCatalog with the given catalog name. @param catalogName the name of the ServerCatalog to retrieve @return the ServerCatalog objec
amoro-ams/src/main/java/org/apache/amoro/server/catalog/CatalogManager.java:57
← previousnext →401–500 of 26,017, ranked by callers