MCPcopy Create free account

hub / github.com/apache/amoro / functions

Functions26,017 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
↓ 2,730 callersMethodgetToken
(String tokenIdentifier)
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java:2088
↓ 1,535 callersMethodput
(T key, K value)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/map/SimpleMap.java:25
↓ 1,415 callersMethodmatch
(List<Record> records)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/flow/view/TableDataView.java:26
↓ 1,034 callersMethodsize
Returns the number of key-value mappings in this map.
amoro-format-iceberg/src/main/java/org/apache/amoro/log/data/LogMapData.java:27
↓ 981 callersMethodsync
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/AutomaticDoubleWriteStatus.java:86
↓ 980 callersMethodget
(T key)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/map/SimpleMap.java:29
↓ 864 callersMethodget
Get the result by the key. @throws IOException Serialize the rowData failed.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/KVTable.java:43
↓ 659 callersMethodadd
(CommitRequest value, LogGlobalState globalState)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/hidden/GlobalFlipCommitter.java:105
↓ 648 callersMethodappend
(byte[] newData)
amoro-format-iceberg/src/main/java/org/apache/amoro/log/MessageBytes.java:29
↓ 605 callersMethodset
Add a key/value property to the partition. @param partitionData partition to add property @param key a String key @param value a String value @return
amoro-format-iceberg/src/main/java/org/apache/amoro/op/UpdatePartitionProperties.java:47
↓ 596 callersMethodget
Get a plugin by its name @param pluginName related to Plugin.name() @return plugin instance
amoro-ams/src/main/java/org/apache/amoro/server/manager/PluginManager.java:52
↓ 574 callersMethodforEach
Visit all installed plugins. @param visitor function to visit all installed plugins.
amoro-ams/src/main/java/org/apache/amoro/server/manager/AbstractPluginManager.java:184
↓ 531 callersMethodget
(Type type)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/RecordGenerator.java:138
↓ 485 callersMethodadd
(MemorySize that)
amoro-common/src/main/java/org/apache/amoro/utils/MemorySize.java:190
↓ 480 callersMethodgetClass
Returns the class associated with the given key as a string. @param <T> The type of the class to return. @param key The key pointing to the associate
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:83
↓ 431 callersMethodgetName
@return the name of the state. If multiple stages are involved, it should be the name of the current stage.
amoro-common/src/main/java/org/apache/amoro/process/ProcessState.java:38
↓ 396 callersMethodschema
Returns the {@link Schema} of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:43
↓ 370 callersMethodasKeyedTable
Returns this cast to {@link KeyedTable} if it is one @return this cast to {@link KeyedTable} if it is one @throws IllegalStateException if this is no
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:103
↓ 361 callersMethodadd
(StructLike struct)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/StructLikeSet.java:60
↓ 360 callersMethodtarget
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:178
↓ 350 callersMethodgetState
Get {@link ProcessState} of the process @return the state of the process
amoro-common/src/main/java/org/apache/amoro/process/AmoroProcess.java:69
↓ 339 callersMethodspec
Returns the {@link PartitionSpec} of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:49
↓ 324 callersMethodof
(MixedTable table)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/io/TaskWriters.java:85
↓ 323 callersMethodrecover
recover a path which had been deleted as recoverable. @param path a path had been deleted. @return if the target of path has been recovered.
amoro-format-iceberg/src/main/java/org/apache/amoro/io/SupportFileRecycleOperations.java:48
↓ 298 callersMethodof
(MixedTable table)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/io/TaskWriters.java:85
↓ 297 callersMethodwrite
(T row)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/writer/RowLevelWriter.java:33
↓ 286 callersMethodof
(MixedTable table)
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/io/TaskWriters.java:85
↓ 284 callersMethodgetMixedTable
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/plan/TestKeyedPartitionPlan.java:211
↓ 280 callersMethodcollect
(OutputTag<X> outputTag, StreamRecord<X> streamRecord)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/MixedFormatWriter.java:206
↓ 277 callersMethodof
Create a {@link Projection} of the provided {@code indexes}. @see #toTopLevelIndexes()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/Projection.java:142
↓ 276 callersMethodname
()
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/command/MixedFormatSparkCommand.java:27
↓ 272 callersMethodproperties
Returns a map of string properties of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:52
↓ 269 callersMethodrequired
(Boolean isRequired)
amoro-common/src/main/java/org/apache/amoro/table/descriptor/AMSColumnInfo.java:85
↓ 264 callersMethodgetMixedTable
()
amoro-format-iceberg/src/test/java/org/apache/amoro/catalog/TableTestBase.java:96
↓ 257 callersMethodcontains
(Long tableId)
amoro-ams/src/main/java/org/apache/amoro/server/table/TableService.java:37
↓ 244 callersMethodisKeyedTable
Returns true if this table is an {@link KeyedTable}
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:83
↓ 242 callersMethodparse
(String fileName)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/util/ClassLoaderUtils.java:91
↓ 234 callersMethodid
Returns the {@link TableIdentifier} of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:37
↓ 222 callersMethodgetMixedTable
()
amoro-format-mixed/amoro-mixed-hive/src/test/java/org/apache/amoro/hive/utils/TestHiveMetaSynchronizer.java:78
↓ 221 callersMethodadd
(T value)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetWriter.java:129
↓ 219 callersMethodgetValue
@return The current value of metric
amoro-common/src/main/java/org/apache/amoro/metrics/Gauge.java:32
↓ 217 callersMethodasUnkeyedTable
Returns this cast to {@link UnkeyedTable} if it is one @return this cast to {@link UnkeyedTable} if it is one @throws IllegalStateException if this i
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:93
↓ 210 callersMethodmap
(Types.MapType map, Supplier<Type> keyFuture, Supplier<Type> valueFuture)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/utils/ChangeFieldName.java:108
↓ 199 callersMethodformat
Table format
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/SparkTableFormat.java:28
↓ 194 callersMethodcommit
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingProcess.java:47
↓ 187 callersMethodcreate
( RowDataStateFactory rowDataStateFactory, List<String> primaryKeys, List<String> joinKeys,
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/TableFactory.java:29
↓ 180 callersMethodvalueOf
(int code)
amoro-common/src/main/java/org/apache/amoro/Action.java:68
↓ 178 callersMethodfilter
Config this scan with filter by the {@link Expression}. @param expr a filter expression @return scan based on this with results filtered by the expre
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/KeyedTableScan.java:34
↓ 177 callersMethodio
Returns a {@link AuthenticatedFileIO} to read and write files in this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:58
↓ 175 callersMethodwithDescription
Creates a new config option, using this option's key and default value, and adding the given description. The given description is used when generatio
amoro-common/src/main/java/org/apache/amoro/config/ConfigOption.java:94
↓ 170 callersMethodloadTable
Get an mixed-format table by table identifier. @param tableIdentifier a table identifier @return instance of {@link UnkeyedTable} or {@link KeyedTabl
amoro-format-iceberg/src/main/java/org/apache/amoro/mixed/MixedFormatCatalog.java:94
↓ 169 callersMethodfields
()
amoro-format-iceberg/src/main/java/org/apache/amoro/table/PrimaryKeySpec.java:77
↓ 169 callersMethodformat
Returns the {@link TableFormat} of this table
amoro-common/src/main/java/org/apache/amoro/AmoroTable.java:36
↓ 168 callersMethoddefaultValue
Returns the default value, or null, if there is no default value. @return The default value, or null.
amoro-common/src/main/java/org/apache/amoro/config/ConfigOption.java:123
↓ 165 callersMethodgetDatabase
(String databaseName)
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:70
↓ 164 callersMethodisEmpty
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/assigner/StaticSplitAssigner.java:119
↓ 159 callersMethodname
Returns the name of this table
amoro-common/src/main/java/org/apache/amoro/AmoroTable.java:31
↓ 158 callersMethodpath
()
amoro-format-iceberg/src/main/java/org/apache/amoro/data/DefaultKeyedFile.java:77
↓ 157 callersMethodcompare
(TableRuntime one, TableRuntime another)
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/sorter/BalancedSorter.java:37
↓ 157 callersMethodsql
(String query, Object... args)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/catalog/TestMixedCatalog.java:450
↓ 155 callersMethodquickDateWithZone
(int day)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/AbstractOptimizingTest.java:87
↓ 154 callersMethodchangeTable
Returns the base table store
amoro-format-iceberg/src/main/java/org/apache/amoro/table/KeyedTable.java:44
↓ 154 callersMethodnewRecord
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/RecordGenerator.java:64
↓ 153 callersMethodfile
The {@link PrimaryKeyedFile} to scan. @return the file to scan
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/MixedFileScanTask.java:33
↓ 152 callersMethodupdateProperties
Create a new {@link UpdateProperties} to update table properties and commit the changes. @return a new {@link UpdateProperties}
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:75
↓ 151 callersMethoddoAs
Run the given action with login user. @param callable the method to execute @param <T> the return type of the run method @return the value from the r
amoro-format-iceberg/src/main/java/org/apache/amoro/io/AuthenticatedFileIO.java:38
↓ 150 callersMethodcollect
()
amoro-metrics/amoro-metrics-prometheus/src/main/java/org/apache/amoro/metrics/promethues/MetricsCollector.java:51
↓ 149 callersMethodgetKey
(RowData value)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/shuffle/ReadShuffleRulePolicy.java:71
↓ 148 callersMethodbaseTable
Returns the base table store
amoro-format-iceberg/src/main/java/org/apache/amoro/table/KeyedTable.java:41
↓ 147 callersMethodgetTableName
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/TableNameResolve.java:60
↓ 146 callersMethodgenerateTestRecord
(int id, String name, long ts, String opTime)
amoro-format-iceberg/src/test/java/org/apache/amoro/TableTestHelper.java:56
↓ 144 callersMethodcontainsKey
(K key)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/map/SimpleSpillableMap.java:95
↓ 143 callersMethodlocation
Returns the location of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:55
↓ 140 callersMethodconvert
Converts elements of type {@code From} into elements of type {@code To}. @param source The element to be converted. @param context The context with c
amoro-format-iceberg/src/main/java/org/apache/amoro/log/Converter.java:39
↓ 139 callersMethodname
Returns the name of this table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/MixedTable.java:46
↓ 138 callersMethodaddAll
(Iterable<WriteTaskCommit> results)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:90
↓ 138 callersMethodkey
Starts building a new {@link ConfigOption}. @param key The key for the config option. @return The builder for the config option with the given key.
amoro-common/src/main/java/org/apache/amoro/config/ConfigOptions.java:81
↓ 136 callersMethodcommit
(String fileLocation, String committedLocation)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/utils/HiveCommitUtil.java:73
↓ 135 callersMethodexists
Check if a path exists. @param path source pathmkdir @return true if the path exists;
amoro-format-iceberg/src/main/java/org/apache/amoro/io/AuthenticatedFileIO.java:46
↓ 133 callersMethodgetType
@param name @return the type @throws MetaException @throws TException @throws NoSuchObjectException @see org.apache.hadoop.hive.metastore.api.ThriftHi
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java:1435
↓ 132 callersMethodfieldId
(Integer fieldId)
amoro-common/src/main/java/org/apache/amoro/table/descriptor/AMSPartitionField.java:101
↓ 132 callersMethodgetTableIdentifier
Get the table identifier containing server side id and table format. @return the table identifier
amoro-common/src/main/java/org/apache/amoro/TableRuntime.java:58
↓ 132 callersMethodnext
fetch row from result-set @return - return false if there is no more data.
amoro-ams/src/main/java/org/apache/amoro/server/terminal/TerminalSession.java:38
↓ 130 callersMethodspark
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:146
↓ 129 callersMethodtableTestHelper
()
amoro-format-iceberg/src/test/java/org/apache/amoro/catalog/TableTestBase.java:118
↓ 127 callersMethodof
(String catalog, String database, String tableName)
amoro-common/src/main/java/org/apache/amoro/table/TableIdentifier.java:43
↓ 127 callersMethodtype
Returns the type of file
amoro-format-iceberg/src/main/java/org/apache/amoro/data/PrimaryKeyedFile.java:28
↓ 126 callersMethodcommit
Commit all optimizing result.
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/OptimizingCommitterFactory.java:39
↓ 125 callersMethodempty
@return - return true if current statement shouldn't return result-set.
amoro-ams/src/main/java/org/apache/amoro/server/terminal/TerminalSession.java:44
↓ 123 callersMethodrow
(RowKind rowKind, Object... objects)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/lookup/TestKVTable.java:564
↓ 122 callersMethodisEmpty
()
amoro-ams/src/main/java/org/apache/amoro/server/terminal/StatementResult.java:92
↓ 121 callersMethodtableTestHelper
()
amoro-ams/src/test/java/org/apache/amoro/server/table/AMSTableTestBase.java:267
↓ 120 callersMethodfromString
(String level)
amoro-common/src/main/java/org/apache/amoro/config/DataExpirationConfig.java:51
↓ 118 callersMethodmap
(Types.MapType map, DataType keyResult, DataType valueResult)
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/component/reverser/IcebergTypeToSparkType.java:87
↓ 115 callersMethodadd
(WriteTaskCommit result)
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:84
↓ 113 callersMethodio
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/amoro/hive/table/SupportHive.java:28
↓ 109 callersMethodequals
(java.lang.Object that)
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:2956
↓ 108 callersMethodcopyFrom
(NumberContext ctx)
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:12750
↓ 108 callersMethodcopyFrom
(NumberContext ctx)
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:12750
↓ 106 callersMethodasList
Defines that the option's type should be a list of previously defined atomic type.
amoro-common/src/main/java/org/apache/amoro/config/ConfigOptions.java:217
next →1–100 of 26,017, ranked by callers