MCPcopy Create free account

hub / github.com/apache/amoro / functions

Functions26,017 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
↓ 106 callersMethodgetDataFile
(int number)
amoro-format-iceberg/src/test/java/org/apache/amoro/trace/TestTableTracer.java:108
↓ 106 callersMethodnewAppend
()
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedTransaction.java:100
↓ 106 callersMethodof
(long transactionId, long fileOffset)
amoro-format-iceberg/src/main/java/org/apache/amoro/data/ChangedLsn.java:39
↓ 105 callersMethodcopyFrom
(NumberContext ctx)
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:12067
↓ 105 callersMethodof
(R result)
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/response/OkResponse.java:45
↓ 104 callersMethodcurrentSnapshot
Returns the current snapshot of this table
amoro-common/src/main/java/org/apache/amoro/AmoroTable.java:45
↓ 104 callersMethodenterRule
(ParseTreeListener listener)
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:1134
↓ 104 callersMethodenterRule
(ParseTreeListener listener)
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:1134
↓ 104 callersMethodexitRule
(ParseTreeListener listener)
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:1138
↓ 104 callersMethodexitRule
(ParseTreeListener listener)
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:1138
↓ 104 callersMethodgetId
@return unique identifier of the process.
amoro-common/src/main/java/org/apache/amoro/process/ProcessState.java:32
↓ 103 callersMethodenterRule
(ParseTreeListener listener)
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:1109
↓ 103 callersMethodexitRule
(ParseTreeListener listener)
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:1113
↓ 102 callersMethodbuild
()
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/model/OptimizerInstanceInfo.java:226
↓ 102 callersMethodcreate
(Map<Object, Object> result)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogMapData.java:45
↓ 102 callersMethodgetProperties
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/kafka/testutils/KafkaConfigGenerate.java:34
↓ 100 callersMethodfilter
@return if the rowData is filtered, return true.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/KVTable.java:61
↓ 100 callersMethodremove
Remove the given property key from the partition. @param partitionData partition to remove property @param key a String key @return this for method c
amoro-format-iceberg/src/main/java/org/apache/amoro/op/UpdatePartitionProperties.java:57
↓ 98 callersMethodequals
(Object o)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/Projection.java:166
↓ 97 callersMethodbuilder
()
amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/MixedFormatQueryRunner.java:43
↓ 97 callersMethodequals
(Object o)
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/model/TableMeta.java:48
↓ 95 callersMethodkeySet
Returns the keys of all key/value pairs stored inside this configuration object. @return the keys of all key/value pairs stored inside this configura
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:453
↓ 94 callersMethodadd
(WriteTaskCommit result)
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:84
↓ 94 callersMethodadd
(WriteTaskCommit result)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:84
↓ 94 callersMethodappendFile
(DataFile file)
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedAppendFiles.java:56
↓ 93 callersMethodbuilderFor
(Schema schema)
amoro-format-iceberg/src/main/java/org/apache/amoro/table/PrimaryKeySpec.java:58
↓ 93 callersMethodkey
()
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/map/RocksDBBackend.java:526
↓ 93 callersMethodsetField
(String name, Object value)
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/RecordWithAction.java:56
↓ 92 callersMethodarguments
()
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/sql/connector/expressions/FileIndexBucket.java:75
↓ 92 callersMethodarguments
()
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/sql/connector/expressions/FileIndexBucket.java:75
↓ 92 callersMethodarguments
()
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/sql/connector/expressions/FileIndexBucket.java:75
↓ 92 callersMethodcreateRowData
(int i)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/write/hidden/kafka/TestHiddenLogOperators.java:300
↓ 89 callersMethodclose
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/KVTable.java:79
↓ 89 callersMethodcolumns
@return - list of column name for result-set.
amoro-ams/src/main/java/org/apache/amoro/server/terminal/TerminalSession.java:31
↓ 89 callersMethodrun
(C client)
amoro-common/src/main/java/org/apache/amoro/client/ClientPool.java:29
↓ 88 callersMethodread
(org.apache.amoro.shade.thrift.org.apache.thrift.protocol.TProtocol iprot)
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:2996
↓ 87 callersMethodgetHiveConf
()
amoro-common/src/test/java/org/apache/amoro/hive/TestHMS.java:66
↓ 86 callersMethodbuild
()
amoro-format-iceberg/src/test/java/org/apache/amoro/io/TestBasicTableTrashManager.java:267
↓ 83 callersMethodprimaryKeySpec
Returns the {@link PrimaryKeySpec} of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/KeyedTable.java:32
↓ 82 callersMethodclose
()
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:34
↓ 82 callersMethodsnapshotId
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/TableSnapshot.java:23
↓ 82 callersMethodsource
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:183
↓ 81 callersMethodprovider
(TableFormat format)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:248
↓ 80 callersMethodtable
The table name that this event source related to. @return Table name
amoro-common/src/main/java/org/apache/amoro/events/TableEvent.java:43
↓ 79 callersMethodcompareTo
(ping_args other)
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:2979
↓ 79 callersMethodnewScan
Create a new {@link KeyedTableScan scan} for this table. @return a table scan for this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/KeyedTable.java:55
↓ 79 callersMethodof
(String splitId)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hybrid/enumerator/TestTemporalJoinSplitsThreadSafe.java:85
↓ 78 callersMethodformat
Returns the {@link TableFormat} of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:40
↓ 77 callersMethodaddAll
(Configurations other)
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:466
↓ 76 callersMethodappend
Appends the internal byte array from offset size with the contents of src from offset start to limit. This increases the size of the internal byte arr
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/ByteArrayWrapper.java:110
↓ 76 callersMethodnewRecord
(Object... val)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/TestMixedIcebergOptimizing.java:348
↓ 76 callersMethodvalidate
()
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:3015
↓ 75 callersMethodallOf
(List<SimpleFuture> futures)
amoro-common/src/main/java/org/apache/amoro/process/SimpleFuture.java:121
↓ 75 callersMethodapply
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/op/UpdateHiveFiles.java:628
↓ 74 callersMethoddataFiles
()
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/RewriteFilesInput.java:123
↓ 74 callersMethodid
Returns the {@link TableIdentifier} of this table
amoro-common/src/main/java/org/apache/amoro/AmoroTable.java:28
↓ 74 callersMethodsql
(String sqlText)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/test/java/org/apache/amoro/spark/test/suites/sql/TestMixedFormatSessionCatalog.java:53
↓ 74 callersMethodsql
(String sqlText)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/test/java/org/apache/amoro/spark/test/suites/sql/TestMixedFormatSessionCatalog.java:52
↓ 73 callersMethodbuildTableIdentifier
()
amoro-common/src/main/java/org/apache/amoro/table/TableIdentifier.java:59
↓ 73 callersMethodprocessElement
(StreamRecord<Tuple2<Boolean, RowData>> element)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/table/TestWatermark.java:246
↓ 73 callersMethodsql
(String sqlText)
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/test/java/org/apache/amoro/spark/test/suites/sql/TestMixedFormatSessionCatalog.java:52
↓ 71 callersMethodcheckState
(boolean checkRollingback)
amoro-ams/src/main/java/org/apache/amoro/server/persistence/NestedSqlSession.java:82
↓ 71 callersMethodjoin
Return until completedFuture is done, which means task or process is truly finished
amoro-common/src/main/java/org/apache/amoro/process/SimpleFuture.java:96
↓ 70 callersMethodbuild
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/CompleteOptimizingFlow.java:331
↓ 70 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-trino/src/test/java/org/apache/amoro/trino/mixed/MixedFormatQueryRunner.java:72
↓ 70 callersMethodgetFields
@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:1572
↓ 69 callersMethodpropertyAsLong
( Map<String, String> properties, String property, long defaultValue)
amoro-common/src/main/java/org/apache/amoro/utils/PropertyUtil.java:70
↓ 68 callersMethodisEmpty
()
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/SortedPosDeleteWriter.java:152
↓ 68 callersMethodrefresh
Refresh the current table metadata.
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:61
↓ 68 callersMethodwithPrimaryKeySpec
Set a primary key for the table. @param primaryKeySpec a primary key spec @return this object for chaining call
amoro-format-iceberg/src/main/java/org/apache/amoro/table/TableBuilder.java:68
↓ 67 callersMethodcontainsKey
Checks whether there is an entry with the specified key. @param key key of entry @return true if the key is stored, false otherwise
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:511
↓ 67 callersMethodof
( List<? extends StructLike> notInView, List<? extends StructLike> inViewButDuplicate, List<
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/view/MatchResult.java:44
↓ 66 callersMethodgetAs
(Class<T> mapperClz, Function<T, R> func)
amoro-ams/src/main/java/org/apache/amoro/server/persistence/PersistentBase.java:100
↓ 66 callersMethodoptimizingService
()
amoro-ams/src/test/java/org/apache/amoro/server/AMSServiceTestBase.java:71
↓ 65 callersMethodnewRecord
(Object... val)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/TestIcebergHadoopOptimizing.java:378
↓ 64 callersMethodfindByThriftId
Find the _Fields constant that matches fieldId, or null if its not found.
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:2861
↓ 64 callersMethodgetMixedFormatCatalog
generate {@link MixedFormatCatalog}
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/MixedFormatCatalogFactory.java:28
↓ 64 callersMethodgetScheme
()
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:3079
↓ 64 callersMethodgetString
(int pos)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogArrayData.java:48
↓ 63 callersMethodcreateViewSource
(Schema schema, List<Record> data)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:222
↓ 62 callersMethodgetMessage
()
amoro-common/src/main/gen-java/org/apache/amoro/api/MetaException.java:122
↓ 62 callersMethodstartsWith
(BoundReference<T> ref, Literal<T> lit)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetDictionaryRowGroupFilter.java:375
↓ 62 callersMethodtransform
( Iterable<IcebergFindFiles.IcebergManifestEntry> entries)
amoro-format-iceberg/src/test/java/org/apache/iceberg/TestIcebergFindFiles.java:382
↓ 61 callersMethodpath
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java:157
↓ 60 callersMethodwithTags
(String... tags)
amoro-common/src/main/java/org/apache/amoro/metrics/MetricDefine.java:132
↓ 59 callersMethodcreateRecord
(int id, String name, long ts, String opTime)
amoro-format-iceberg/src/test/java/org/apache/amoro/io/MixedDataTestHelpers.java:85
↓ 59 callersMethoddropTable
Drop a table and delete all data and metadata files. @param tableIdentifier a table identifier @param purge if true, delete all data and metadata fil
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:128
↓ 59 callersMethodgetTable
(String dbName, String tableName)
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:49
↓ 59 callersMethodpropertyAsInt
( Map<String, String> properties, String property, int defaultValue)
amoro-common/src/main/java/org/apache/amoro/utils/PropertyUtil.java:53
↓ 59 callersMethodtoString
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/view/MatchResult.java:61
↓ 59 callersMethodtransactionId
Returns the id of transaction which file added into table
amoro-format-iceberg/src/main/java/org/apache/amoro/data/PrimaryKeyedFile.java:34
↓ 59 callersMethodvalues
Get all registered formats @return registered formats
amoro-common/src/main/java/org/apache/amoro/TableFormat.java:55
↓ 58 callersMethodcreateWriterFunc
( Function<MessageType, ParquetValueWriter<?>> newCreateWriterFunc)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:164
↓ 58 callersMethodisPartitionedTable
()
amoro-format-iceberg/src/test/java/org/apache/amoro/catalog/TableTestBase.java:113
↓ 58 callersMethodmap
( Types.MapType expectedMap, GroupType map, ParquetValueReader<?> keyReader, P
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/AdaptHiveFlinkParquetReaders.java:161
↓ 58 callersMethodmax
(Statistics<?> statistics, int id)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetMetricsRowGroupFilter.java:501
↓ 57 callersMethodcollect
(RowData rowData)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hidden/kafka/TestKafkaSourceReader.java:220
↓ 57 callersMethodtoWithClause
(Map<String, String> props)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/catalog/TestMixedCatalog.java:511
↓ 57 callersMethodwithPartitionSpec
Sets a partition spec for table. @param partitionSpec partition spec @return this object for chaining call
amoro-format-iceberg/src/main/java/org/apache/amoro/table/TableBuilder.java:35
↓ 56 callersMethodexec
(String query, Object... args)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/table/CatalogITCaseBase.java:54
← previousnext →101–200 of 26,017, ranked by callers