MCPcopy Create free account

hub / github.com/apache/amoro / functions

Functions26,017 in github.com/apache/amoro

⨍ Functions 26,017◇ Types & classes 3,104
↓ 16 callersMethodfromEpochMillis
(long millis)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/maintainer/TestAutoCreateIcebergTagAction.java:362
↓ 16 callersMethodgetDbName
()
amoro-ams/src/main/java/org/apache/amoro/server/persistence/TableRuntimeMeta.java:92
↓ 16 callersMethodgetExpirationField
()
amoro-common/src/main/java/org/apache/amoro/config/DataExpirationConfig.java:78
↓ 16 callersMethodgetField
(GenericInternalRow intermediate, int pos)
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/reader/SparkParquetReaders.java:543
↓ 16 callersMethodgetField
(GenericInternalRow intermediate, int pos)
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/reader/SparkParquetReaders.java:543
↓ 16 callersMethodgetInput
()
amoro-common/src/main/java/org/apache/amoro/process/StagedTaskDescriptor.java:76
↓ 16 callersMethodgetPartition
(String dbName, String tblName, List<String> partVals)
amoro-common/src/main/java/org/apache/amoro/hive/HMSClient.java:45
↓ 16 callersMethodisSetBlockerId
Returns true if field blockerId is set (has been assigned a value) and false otherwise
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:15381
↓ 16 callersMethodputToCatalogProperties
(java.lang.String key, java.lang.String val)
amoro-common/src/main/gen-java/org/apache/amoro/api/CatalogMeta.java:309
↓ 16 callersMethodreadKeyedTable
(KeyedTable keyedTable, Expression expression)
amoro-format-iceberg/src/test/java/org/apache/amoro/io/MixedDataTestHelpers.java:224
↓ 16 callersMethodsnapshot
(long snapshotId)
amoro-format-iceberg/src/main/java/org/apache/amoro/table/BasicUnkeyedTable.java:179
↓ 16 callersMethodsplit
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/hybrid/assigner/Split.java:65
↓ 16 callersMethoduseSnapshot
(long snapshotId)
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/ChangeTableIncrementalScan.java:51
↓ 16 callersMethodwrapIcebergDataFile
(DataFile dataFile, Long dataSequenceNumber)
amoro-format-iceberg/src/test/java/org/apache/amoro/io/MixedDataTestHelpers.java:474
↓ 16 callersMethodwriteBase
(MixedTable table, List<Record> insertRows)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/AbstractOptimizingTest.java:252
↓ 16 callersMethodwriteUpdate
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hybrid/reader/TestRowDataReaderFunction.java:192
↓ 16 callersMethodymdToUnixDate
(int year, int month, int day)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/DateTimeUtils.java:268
↓ 15 callersMethodaddDeletes
(DeleteFile deletes)
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedRowDelta.java:60
↓ 15 callersMethodassertTableSet
(KVTable<RowData> table, RowData key, RowData... expects)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/lookup/TestKVTable.java:514
↓ 15 callersMethodcheckTagCount
(Table table, int count)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/maintainer/TestAutoCreateIcebergTagAction.java:378
↓ 15 callersMethodclear
()
amoro-ams/src/test/java/org/apache/amoro/server/dashboard/TestOverviewManager.java:78
↓ 15 callersMethodconvertSqlFilterToIcebergExpression
Convert SQL filter to Iceberg {@link Expression}. @param sqlFilter the SQL filter @param tableColumns the list of table columns @return the Iceberg {
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/ExpressionUtil.java:120
↓ 15 callersMethodcreate
Creates the table. @return the created table
amoro-format-iceberg/src/main/java/org/apache/amoro/table/TableBuilder.java:75
↓ 15 callersMethoddeleteFiles
()
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:58
↓ 15 callersMethoddropCatalog
Drops a catalog with the given name. @param catalogName the name of the catalog to be dropped
amoro-ams/src/main/java/org/apache/amoro/server/catalog/CatalogManager.java:87
↓ 15 callersMethodequals
(Object o)
amoro-format-iceberg/src/test/java/org/apache/amoro/log/FormatTestBase.java:398
↓ 15 callersMethodexpectMergeResult
( List<Record> target, List<Record> source, Function<Record, Object> keyExtractor)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/ExpectResultUtil.java:132
↓ 15 callersMethodgetAction
@return the action of the process.
amoro-common/src/main/java/org/apache/amoro/process/ProcessState.java:44
↓ 15 callersMethodgetActualValue
@return rowData if in the flink application
amoro-format-iceberg/src/main/java/org/apache/amoro/log/LogData.java:93
↓ 15 callersMethodgetFileName
Parse file name from file path. @param filePath file path @return file name parsed from file path, e.g. data-1.parquet.
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/TableFileUtil.java:45
↓ 15 callersMethodgetGroupName
()
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/model/TableOptimizingInfo.java:111
↓ 15 callersMethodgetIface
()
amoro-common/src/main/java/org/apache/amoro/PooledAmsClient.java:42
↓ 15 callersMethodgetMaxSequenceKeepingTxIdInOrder
Select all the files whose sequence <= maxSequence as Selected-Files, seek the maxSequence to find as many Selected-Files as possible, and also - the
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/scan/KeyedTableFileScanHelper.java:91
↓ 15 callersMethodgetMetric
( Map<MetricKey, Metric> metrics, ServerTableIdentifier identifier, MetricDefine metricDefine)
amoro-ams/src/test/java/org/apache/amoro/server/table/TestTableSummaryMetrics.java:216
↓ 15 callersMethodgetPath
()
amoro-common/src/main/gen-java/org/apache/amoro/api/DataFile.java:266
↓ 15 callersMethodgetServerUrl
()
amoro-common/src/test/java/org/apache/amoro/TestAms.java:45
↓ 15 callersMethodgetStorageConfigs
()
amoro-common/src/main/gen-java/org/apache/amoro/api/CatalogMeta.java:244
↓ 15 callersMethodgetThreadCount
()
amoro-common/src/main/java/org/apache/amoro/resource/Resource.java:75
↓ 15 callersMethodgetUriPath
remove Uniform Resource Identifier (URI) in file path @param path file path with Uniform Resource Identifier (URI) @return file path without Uniform
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/TableFileUtil.java:200
↓ 15 callersMethodhashCode
()
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1408
↓ 15 callersMethodinsertDataFile
( Table table, List<Record> records, StructLike partitionData)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/AbstractOptimizingTest.java:99
↓ 15 callersMethodisDone
()
amoro-common/src/main/java/org/apache/amoro/process/SimpleFuture.java:67
↓ 15 callersMethodrecords
(int size)
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/RecordGenerator.java:82
↓ 15 callersMethodresults
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/ExpectResultUtil.java:182
↓ 15 callersMethodscanFiles
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/scan/TableFileScanHelperTestBase.java:93
↓ 15 callersMethodsetE1IsSet
(boolean value)
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:14141
↓ 15 callersMethodsetRowKind
(RowKind kind)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/KeyRowData.java:49
↓ 15 callersMethodsetValueInternal
(String key, T value)
amoro-common/src/main/java/org/apache/amoro/config/Configurations.java:588
↓ 15 callersMethodtoString
()
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplit.java:173
↓ 15 callersMethodunsupportedException
(Type type, PrimitiveField field)
amoro-format-mixed/amoro-mixed-trino/src/main/java/io/trino/parquet/reader/ColumnReaderFactory.java:405
↓ 15 callersMethodwithFormat
(TableFormat format)
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/ConvertStructUtil.java:95
↓ 14 callersMethodasFileSystemIO
Return this cast to {@link SupportsFileSystemOperations} if it is.
amoro-format-iceberg/src/main/java/org/apache/amoro/io/AuthenticatedFileIO.java:85
↓ 14 callersMethodassertEqualExpressions
(Expression exp1, Expression exp2)
amoro-format-iceberg/src/test/java/org/apache/amoro/utils/TestExpressionUtil.java:124
↓ 14 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/utils/TestTable.java:153
↓ 14 callersMethodcollect
(OneInputStreamOperatorTestHarness<RowData, RowData> harness)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/write/hidden/kafka/TestHiddenLogOperators.java:351
↓ 14 callersMethoddataSequenceNumber
()
amoro-format-iceberg/src/main/java/org/apache/amoro/data/DefaultKeyedFile.java:157
↓ 14 callersMethoddoAsTransaction
(Runnable... operations)
amoro-ams/src/main/java/org/apache/amoro/server/persistence/PersistentBase.java:88
↓ 14 callersMethodfiles
()
amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:41
↓ 14 callersMethodfiles
()
amoro-format-mixed/amoro-mixed-spark/v3.2/amoro-mixed-spark-3.2/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:41
↓ 14 callersMethodfiles
()
amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/java/org/apache/amoro/spark/writer/WriteTaskCommit.java:41
↓ 14 callersMethodgetContainerProperties
()
amoro-ams/src/main/java/org/apache/amoro/server/manager/AbstractResourceContainer.java:76
↓ 14 callersMethodgetEpicNo
The epic number indicates a batch of data in the log queue(e.g. Kafka), the EpicNo is similar to the checkpoint id in the flink application. @return
amoro-format-iceberg/src/main/java/org/apache/amoro/log/LogData.java:62
↓ 14 callersMethodgetFieldName
()
amoro-common/src/main/gen-java/org/apache/amoro/api/OptimizingService.java:1336
↓ 14 callersMethodgetInternalCatalog
Retrieves the InternalCatalog with the given catalog name. @param catalogName the name of the ServerCatalog to retrieve @return the InternalCatalog o
amoro-ams/src/main/java/org/apache/amoro/server/catalog/CatalogManager.java:65
↓ 14 callersMethodgetMebiBytes
Gets the memory size in Mebibytes (= 1024 Kibibytes).
amoro-common/src/main/java/org/apache/amoro/utils/MemorySize.java:95
↓ 14 callersMethodgetMetrics
Get all metrics of this metric set @return all metrics
amoro-common/src/main/java/org/apache/amoro/metrics/MetricSet.java:31
↓ 14 callersMethodgetTargetCatalog
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/SessionCatalogBase.java:107
↓ 14 callersMethodgetTaskDescriptor
()
amoro-ams/src/main/java/org/apache/amoro/server/optimizing/TaskRuntime.java:76
↓ 14 callersMethodisInteger
(String s)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/util/DateTimeUtils.java:1414
↓ 14 callersMethodlistDatabases
Show database list of metastore. @return database list of metastore
amoro-common/src/main/java/org/apache/amoro/AmoroCatalog.java:31
↓ 14 callersMethodmixedEquityDeletes
Returns a list of {@link MixedFileScanTask} for equality delete files
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/KeyedTableScanTask.java:48
↓ 14 callersMethodnewFastAppend
()
amoro-format-iceberg/src/main/java/org/apache/amoro/op/MixedTransaction.java:105
↓ 14 callersMethodnotNull
(BoundReference<T> ref)
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquetDictionaryRowGroupFilter.java:161
↓ 14 callersMethodoptions
Set properties for this OptimizingInput.
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/TableOptimizing.java:54
↓ 14 callersMethodoverwrite
()
amoro-format-mixed/amoro-mixed-hive/src/main/java/org/apache/iceberg/parquet/AdaptHiveParquet.java:175
↓ 14 callersMethodplanFullTable
( KeyedTable keyedTable, AtomicInteger splitCount)
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/FlinkSplitPlanner.java:62
↓ 14 callersMethodpropertyAsString
( Map<String, String> properties, String property, String defaultValue)
amoro-common/src/main/java/org/apache/amoro/utils/PropertyUtil.java:87
↓ 14 callersMethodputToProperties
(java.lang.String key, java.lang.String val)
amoro-common/src/main/gen-java/org/apache/amoro/api/Blocker.java:226
↓ 14 callersMethodscan
()
amoro-format-iceberg/src/main/java/org/apache/amoro/optimizing/scan/TableFileScanHelper.java:48
↓ 14 callersMethodsetTableIdentifierIsSet
(boolean value)
amoro-common/src/main/gen-java/org/apache/amoro/api/AmoroTableMetastore.java:13432
↓ 14 callersMethodstart
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/lookup/BasicLookupFunction.java:153
↓ 14 callersMethodtoByteArray
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/read/AdaptHiveFlinkParquetReaders.java:843
↓ 14 callersMethodtoString
()
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/response/Response.java:53
↓ 14 callersMethodunifiedCatalog
()
amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/test/java/org/apache/amoro/spark/test/SparkTestBase.java:140
↓ 14 callersMethodunlock
(long lockid)
amoro-format-mixed/amoro-mixed-trino/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java:2177
↓ 14 callersMethodupdateRecords
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/read/hybrid/reader/TestRowDataReaderFunction.java:268
↓ 14 callersMethoduseMixedTableOperations
Wrap table operation with authorization logic for {@link Table}.
amoro-format-iceberg/src/main/java/org/apache/amoro/utils/MixedFormatCatalogUtil.java:97
↓ 14 callersMethodwriteChange
( KeyedTable table, List<Record> insertRows, List<Record> deleteRows)
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/AbstractOptimizingTest.java:230
↓ 13 callersMethodactive
to check current session is alive. DO-NOT-THROW-ANYTHING of this method. @return - false if session is not able to execute statement.
amoro-ams/src/main/java/org/apache/amoro/server/terminal/TerminalSession.java:72
↓ 13 callersMethodassertOptimizeHangUp
()
amoro-ams/src/test/java/org/apache/amoro/server/optimizing/BaseOptimizingChecker.java:178
↓ 13 callersMethodbodyAsClass
(Context ctx, Class<T> clz)
amoro-ams/src/main/java/org/apache/amoro/server/RestCatalogService.java:387
↓ 13 callersMethodbuild
()
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/FlinkSink.java:183
↓ 13 callersMethodbuildFor
( Map<String, String> flinkConf, Map<String, String> containerProperties)
amoro-ams/src/main/java/org/apache/amoro/server/manager/FlinkOptimizerContainer.java:680
↓ 13 callersMethodbuilder
()
amoro-ams/src/main/java/org/apache/amoro/server/dashboard/model/OptimizerInstanceInfo.java:45
↓ 13 callersMethodcomplete
()
amoro-format-iceberg/src/main/java/org/apache/amoro/io/writer/BaseTaskWriter.java:122
↓ 13 callersMethodcurrent
()
amoro-ams/src/main/java/org/apache/amoro/server/table/internal/IcebergInternalTableOperations.java:59
↓ 13 callersMethoddataTasks
Returns a list of {@link MixedFileScanTask} for insert files and base files
amoro-format-iceberg/src/main/java/org/apache/amoro/scan/KeyedTableScanTask.java:51
↓ 13 callersMethoddelete
(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:27
↓ 13 callersMethodequals
(Object o)
amoro-ams/src/main/java/org/apache/amoro/server/table/DefaultTableService.java:546
↓ 13 callersMethodfield
(int index)
amoro-format-iceberg/src/main/java/org/apache/amoro/table/PrimaryKeySpec.java:81
← previousnext →601–700 of 26,017, ranked by callers