MCPcopy Create free account

hub / github.com/apache/amoro / functions

Functions26,017 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
↓ 56 callersMethodwithProperty
Adds a key/value property to the table. @param key a key @param value a value @return this object for chaining call
amoro-format-iceberg/src/main/java/org/apache/amoro/table/TableBuilder.java:60
↓ 55 callersMethodgetTableEnv
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/table/CatalogITCaseBase.java:62
↓ 55 callersMethodgetTaskId
()
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingTask.java:148
↓ 53 callersMethodgetBytes
Gets the memory size in bytes.
amoro-common/src/main/java/org/apache/amoro/utils/MemorySize.java:85
↓ 53 callersMethodisNotEmpty
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/source/ChangeLogDataIterator.java:186
↓ 53 callersMethodnewOutputFile
(TaskWriterKey key)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/OutputFileFactory.java:26
↓ 52 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/reader/SparkScanBuilder.java:156
↓ 52 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/reader/SparkScanBuilder.java:155
↓ 52 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/reader/SparkScanBuilder.java:156
↓ 52 callersMethodtoString
()
amoro-format-mixed/amoro-mixed-hive/src/test/java/org/apache/amoro/hive/catalog/HiveCatalogTestHelper.java:100
↓ 51 callersMethodcreateReaderFunc
( Function<MessageType, ParquetValueReader<?>> newReaderFunction)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:802
↓ 51 callersMethodgetAmsHandler
()
amoro-format-iceberg/src/test/java/org/apache/amoro/catalog/CatalogTestBase.java:52
↓ 51 callersMethodgetLocation
(String path)
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergMetadata.java:1204
↓ 51 callersMethoditerator
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetReader.java:96
↓ 51 callersMethodtest
Test if the RowData record satisfies this predicate.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/filter/RowDataPredicate.java:91
↓ 50 callersMethodcount
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hidden/kafka/TestKafkaSourceReader.java:248
↓ 50 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/AmoroTableMetastore.java:14112
↓ 49 callersMethodSTRING
()
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:7961
↓ 49 callersMethoddefineGauge
(String name)
amoro-common/src/main/java/org/apache/amoro/metrics/MetricDefine.java:117
↓ 49 callersMethodgetHiveClient
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestContext.java:112
↓ 48 callersMethodgetCatalogName
For asserting unkeyed table records.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/write/FlinkTaskWriterBaseTest.java:107
↓ 48 callersMethodlength
()
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/BasicMixedFileScanTask.java:112
↓ 48 callersMethodsnapshots
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/BasicUnkeyedTable.java:184
↓ 47 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/MockEnvironmentBuilder.java:183
↓ 47 callersMethoddelete
(T key)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/map/SimpleMap.java:27
↓ 47 callersMethodequals
(Object other)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/table/MixedSparkTable.java:162
↓ 47 callersMethodfileSizeInBytes
()
amoro-format-iceberg/src/main/java/org/apache/amoro/data/DefaultKeyedFile.java:92
↓ 47 callersMethodgetTableName
()
amoro-ams/src/main/java/org/apache/amoro/server/table/blocker/TableBlocker.java:97
↓ 47 callersMethodhashCode
()
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:2972
↓ 46 callersMethodaccept
(ParseTreeVisitor<? extends T> visitor)
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:1142
↓ 46 callersMethodconcat
Combines several files into one @param inputFiles an {@link Iterable} of parquet files. The order of iteration determines the order in which cont
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:999
↓ 46 callersMethodexpression
()
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:7606
↓ 46 callersMethodexpression
()
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:7271
↓ 46 callersMethodexpression
()
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:7606
↓ 46 callersMethodisUnkeyedTable
Returns true if this table is an {@link UnkeyedTable}
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:78
↓ 46 callersMethodoption
Set propertity for this OptimizingInput.
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/TableOptimizing.java:51
↓ 45 callersMethodbind
Returns this method as a BoundMethod for the given receiver. @param receiver an Object to receive the method invocation @return a {@link BoundMethod}
amoro-common/src/main/java/org/apache/amoro/utils/DynMethods.java:90
↓ 45 callersMethodgetPath
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplit.java:99
↓ 45 callersMethodserverTableIdentifier
()
amoro-ams/src/test/java/org/apache/amoro/server/table/AMSTableTestBase.java:290
↓ 45 callersMethodstringType
Defines that the value of the option should be of {@link String} type.
amoro-common/src/main/java/org/apache/amoro/config/ConfigOptions.java:137
↓ 45 callersMethodsummary
()
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/TableOptimizing.java:62
↓ 44 callersMethodmap
( Types.MapType expectedMap, GroupType map, ParquetValueReader<?> keyReader, P
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/reader/SparkParquetReaders.java:191
↓ 44 callersMethodregisterMetric
(MetricRegistry metricRegistry)
amoro-ams/src/main/java/org/apache/amoro/server/table/TableRuntime.java:170
↓ 44 callersMethodtoMillis
(DecimalData v)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/DateTimeUtils.java:373
↓ 43 callersMethodgetCatalogProperties
()
amoro-common/src/main/gen-java/org/apache/amoro/api/CatalogMeta.java:316
↓ 43 callersMethodgetMetadata
()
amoro-ams/src/main/java/org/apache/amoro/server/catalog/ServerCatalog.java:45
↓ 43 callersMethoditerator
()
amoro-format-iceberg/src/main/java/org/apache/iceberg/IcebergFindFiles.java:349
↓ 43 callersMethodkeyMetadata
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java:254
↓ 43 callersMethodof
(TableIdentifier tableIdentifier, TableFormat format)
amoro-common/src/main/java/org/apache/amoro/ServerTableIdentifier.java:126
↓ 43 callersMethodsplit
(long splitSize)
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/BasicMixedFileScanTask.java:125
↓ 43 callersMethodwithPartition
(StructLike newPartition)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:477
↓ 42 callersMethodassertRecordsEqual
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/DataComparator.java:73
↓ 42 callersMethodbuild
(List<Record> expectRecords, List<Record> actualRecords)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/DataComparator.java:102
↓ 42 callersMethodcopyOf
(DeleteFile deleteFile)
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java:68
↓ 42 callersMethodcreateTarget
(Schema schema, Consumer<TableBuilder> consumer)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/MixedTableTestBase.java:86
↓ 42 callersMethodequals
(java.lang.Object that)
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1392
↓ 42 callersMethodnoPrimaryKey
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/PrimaryKeySpec.java:212
↓ 42 callersMethodof
(long mask, long index)
amoro-format-iceberg/src/main/java/org/apache/amoro/data/DataTreeNode.java:46
↓ 42 callersMethodtoRowData
(List<Object[]> data)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/DataUtil.java:112
↓ 41 callersMethodalwaysTrue
()
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/expressions/RewriteNot.java:37
↓ 41 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/AmoroTableMetastore.java:14137
↓ 41 callersMethodisSetTableIdentifier
Returns true if field tableIdentifier is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:13428
↓ 41 callersMethodload
Entrypoint for loading Catalog. @param catalogUrl mixed-format catalog url, thrift://ams-host:port/catalog_name @param properties client side catalog
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/CatalogLoader.java:55
↓ 41 callersMethodtableManager
()
amoro-ams/src/test/java/org/apache/amoro/server/AMSManagerTestBase.java:66
↓ 41 callersMethodwriterOf
(MixedTable table)
amoro-format-mixed/amoro-mixed-hive/src/test/java/org/apache/amoro/hive/io/HiveDataTestHelpers.java:56
↓ 40 callersMethodbeginTransaction
Allocate a new transaction id from this table @param signature signature for this request, signature can be null. @return a new transaction id
amoro-format-iceberg/src/main/java/org/apache/amoro/table/KeyedTable.java:63
↓ 40 callersMethodclose
()
amoro-ams/src/test/java/org/apache/amoro/server/manager/TestAbstractPluginManager.java:45
↓ 40 callersMethodgetHMSClient
the client to operate hive table @return hive metastore client
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/table/SupportHive.java:42
↓ 40 callersMethodgetInt
(int pos)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogArrayData.java:36
↓ 40 callersMethodin
(BoundReference<T> ref, Set<T> literalSet)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetDictionaryRowGroupFilter.java:320
↓ 40 callersMethodprimaryKeyExisted
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/PrimaryKeySpec.java:205
↓ 40 callersMethodproperties
Returns the properties of this table
amoro-common/src/main/java/org/apache/amoro/AmoroTable.java:39
↓ 40 callersMethodtoString
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hybrid/assigner/TestShuffleSplitAssigner.java:145
↓ 39 callersMethodclose
Close the reader
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/OptimizingDataReader.java:42
↓ 39 callersMethodcreateRecord
(int id, String name, long ts, String opTime)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/maintainer/TestDataExpire.java:522
↓ 39 callersMethodcreateTable
create table metadata @param catalogName internal catalog to create the table @param tableMeta table metadata info
amoro-ams/src/main/java/org/apache/amoro/server/table/internal/InternalTableManager.java:32
↓ 39 callersMethodignoreOrder
(Comparator<Record> comparator)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/DataComparator.java:56
↓ 39 callersMethodloadTable
load a table via server catalog. @param identifier managed table identifier @return managed table.
amoro-ams/src/main/java/org/apache/amoro/server/table/TableService.java:47
↓ 39 callersMethodopen
Initialize the lookup table
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/KVTable.java:36
↓ 39 callersMethodparseMillis
(String datetime)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/maintainer/TestDataExpire.java:614
↓ 39 callersMethodwriteHive
(List<Record> records)
amoro-format-mixed/amoro-mixed-hive/src/test/java/org/apache/amoro/hive/io/HiveDataTestHelpers.java:113
↓ 38 callersMethodappend
(int count)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/view/KeyedTableDataView.java:130
↓ 38 callersMethodmock
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/plan/MixedTablePlanTestBase.java:76
↓ 38 callersMethodparse
Parses the given string as as MemorySize. @param text The string to parse @return The parsed MemorySize @throws IllegalArgumentException Thrown, if t
amoro-common/src/main/java/org/apache/amoro/utils/MemorySize.java:224
↓ 38 callersMethodvalues
()
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/SparkInternalRowCastWrapper.java:197
↓ 37 callersMethodaddColumn
(String name, Type type, String doc)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/op/BaseSchemaUpdate.java:55
↓ 37 callersMethodaddFile
Add a Data file and its related Delete files to this evaluator @param dataFile - Data file @param deletes - Delete files @return true if the file is
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/plan/PartitionEvaluator.java:54
↓ 37 callersMethodcomplete
()
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/io/UnkeyedUpsertSparkWriter.java:112
↓ 37 callersMethodgetCatalog
(@Param("catalogName") String catalogName)
amoro-ams/src/main/java/org/apache/amoro/server/persistence/mapper/CatalogMetaMapper.java:57
↓ 37 callersMethodgetClassLoader
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/ClassLoaderUtils.java:168
↓ 37 callersMethodgetInteger
(JsonNode jsonNode, String fieldName)
amoro-common/src/main/java/org/apache/amoro/utils/JacksonUtil.java:83
↓ 37 callersMethodid
()
amoro-format-iceberg/src/test/java/org/apache/amoro/TableTestHelper.java:44
↓ 37 callersMethodintType
Defines that the value of the option should be of {@link Integer} type.
amoro-common/src/main/java/org/apache/amoro/config/ConfigOptions.java:117
↓ 37 callersMethodof
( TableIdentifier tableIdentifier, InternalCatalogBuilder catalogBuilder)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/table/MixedFormatTableLoader.java:51
↓ 37 callersMethodrowSchema
(Schema newSchema)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:569
↓ 37 callersMethodtoRowSet
(Collection<Object[]> data)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/DataUtil.java:62
↓ 37 callersMethodwithSpec
(PartitionSpec newSpec)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:472
↓ 37 callersMethodwriteBaseStore
( MixedTable keyedTable, long txId, List<Record> records, boolean orderedWrite)
amoro-format-iceberg/src/test/java/org/apache/amoro/TableTestHelper.java:65
↓ 36 callersMethodbuilder
(Table table)
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/TableEntriesScan.java:81
↓ 36 callersMethodcopy
()
amoro-format-iceberg/src/main/java/org/apache/amoro/data/PrimaryKeyData.java:89
← previousnext →201–300 of 26,017, ranked by callers