MCPcopy Create free account

hub / github.com/apache/incubator-xtable / functions

Functions1,922 in github.com/apache/incubator-xtable

⨍ Functions 1,922◇ Types & classes 310
↓ 7 callersMethodgetTableDataLocation
( String tableFormat, String tableLocation, Map<String, String> properties)
xtable-core/src/main/java/org/apache/xtable/catalog/TableFormatUtils.java:40
↓ 7 callersMethodreload
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:65
↓ 7 callersMethodsyncChanges
Syncs a set of changes to the target table formats. @param conversionTargetWithMetadata a map of conversion targets to their last sync metadata @para
xtable-api/src/main/java/org/apache/xtable/spi/sync/TableFormatSync.java:98
↓ 7 callersMethodsyncSchema
(InternalSchema schema)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:186
↓ 7 callersMethodtableExists
(TableIdentifier identifier)
xtable-core/src/test/java/org/apache/xtable/iceberg/StubCatalog.java:63
↓ 6 callersFunctionBt
(e)
website/static/js/webflow.js:22
↓ 6 callersMethodaddCommentToDefault
(Types.NestedField updated, int fieldId)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSchemaSync.java:361
↓ 6 callersMethodbeginSync
(InternalTable table)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:260
↓ 6 callersMethodbuildArgsForPartition
( String sourceFormat, List<String> targetFormats, String hudiPartitionConfig, String
xtable-core/src/test/java/org/apache/xtable/ITConversionController.java:1021
↓ 6 callersMethodbuildFileWithoutStats
Builds a {@link InternalDataFile} without any statistics or rowCount value set. @param partitionValues values extracted from the partition path @para
xtable-core/src/main/java/org/apache/xtable/hudi/HudiDataFileExtractor.java:394
↓ 6 callersMethodbuildSyncResult
(SyncMode syncMode, Instant lastSyncedInstant)
xtable-core/src/test/java/org/apache/xtable/conversion/TestConversionController.java:534
↓ 6 callersMethodcompleteSync
()
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:274
↓ 6 callersMethodconvertInstantToCommit
(Instant instant)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiInstantUtils.java:73
↓ 6 callersMethodconvertTable
Converts a source table to one or more target table formats. @param convertTableRequest the conversion request containing source table details and ta
xtable-service/src/main/java/org/apache/xtable/service/ConversionService.java:188
↓ 6 callersMethodcreateInstanceOfClass
(String className, Object... constructorArgs)
xtable-core/src/main/java/org/apache/xtable/reflection/ReflectionUtils.java:35
↓ 6 callersMethoddataFilesAdded
Filters files of type {@link InternalDataFile} from the list of files added to the source table and returns the list.
xtable-api/src/main/java/org/apache/xtable/model/storage/InternalFilesDiff.java:66
↓ 6 callersMethodfromFiles
(List<InternalDataFile> files)
xtable-api/src/main/java/org/apache/xtable/model/storage/PartitionFileGroup.java:38
↓ 6 callersMethodgetCurrentSnapshot
Extracts the {@link InternalSnapshot} as of latest state. @return {@link InternalSnapshot} representing the current snapshot.
xtable-api/src/main/java/org/apache/xtable/spi/extractor/ConversionSource.java:60
↓ 6 callersMethodgetCurrentTable
Extracts the {@link InternalTable} as of latest state. This method is less expensive as compared to {@link ConversionSource#getCurrentSnapshot()} as i
xtable-api/src/main/java/org/apache/xtable/spi/extractor/ConversionSource.java:53
↓ 6 callersMethodgetDataFiles
Filters storage files of type {@link InternalDataFile} and returns them.
xtable-api/src/main/java/org/apache/xtable/model/storage/PartitionFileGroup.java:56
↓ 6 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergPartitionValueConverter.java:71
↓ 6 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionTargetFactory.java:35
↓ 6 callersMethodgetInternalTable
()
xtable-core/src/test/java/org/apache/xtable/conversion/TestConversionController.java:562
↓ 6 callersMethodgetOutputFormatClassName
(HoodieFileFormat baseFileFormat)
xtable-core/src/main/java/org/apache/xtable/hudi/catalog/HudiInputFormatUtils.java:89
↓ 6 callersMethodgetSerDeClassName
(HoodieFileFormat baseFileFormat)
xtable-core/src/main/java/org/apache/xtable/hudi/catalog/HudiInputFormatUtils.java:101
↓ 6 callersMethodgetStartCommitInstant
()
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:255
↓ 6 callersMethodgetStatMap
(long dateColumnStats)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergColumnStatsConverter.java:425
↓ 6 callersMethodgetTable
Retrieves a table from AWS Glue based on the provided catalog and table identifiers. @param glueClient The AWS Glue client used to connect to AWS Glu
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogTableUtils.java:43
↓ 6 callersMethodgetTableParameters
()
xtable-aws/src/main/java/org/apache/xtable/glue/table/DeltaGlueCatalogTableBuilder.java:100
↓ 6 callersMethodgetTableSyncConfig
(List<String> targetTableFormats, SyncMode syncMode)
xtable-core/src/test/java/org/apache/xtable/conversion/TestConversionController.java:574
↓ 6 callersMethodgetValueFromConfig
(CommandLine cmd, String configFlag)
xtable-utilities/src/main/java/org/apache/xtable/utilities/RunSync.java:236
↓ 6 callersMethodincrementalSync
( ConversionTarget conversionTarget, List<InternalDataFile> filesToAdd, List<InternalDataFil
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:515
↓ 6 callersMethodinitTableAndGetMetaClient
( String tableBasePath, String partitionFields)
xtable-core/src/test/java/org/apache/xtable/hudi/HudiTestUtil.java:54
↓ 6 callersMethodisIncrementalSyncSafeFrom
(Instant instant)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java:249
↓ 6 callersMethodsyncMetadata
(TableSyncMetadata metadata)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:240
↓ 6 callersMethodtoXTable
( InternalTable internalTable, StructLike structLike, PartitionSpec partitionSpec)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergPartitionValueConverter.java:75
↓ 6 callersMethodvalidateDeltaTable
( Path basePath, Set<InternalDataFile> internalDataFiles, Expression filterExpression)
xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaSync.java:477
↓ 6 callersMethodvalidateTableChange
( List<String> filePathsBefore, List<String> filePathsAfter, TableChange tableChange)
xtable-core/src/test/java/org/apache/xtable/ValidationTestHelper.java:68
↓ 6 callersMethodvalidateTableChangeDiffSize
( Table table, Snapshot snapshot, int addedFiles, int removedFiles, int numberOfColumns)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergConversionSource.java:312
↓ 6 callersFunctionw
(N,_)
website/static/js/webflow.js:22
↓ 5 callersFunctionCt
(e)
website/static/js/webflow.js:22
↓ 5 callersFunctionIe
(p)
website/static/js/webflow.js:22
↓ 5 callersFunctionS
($)
website/static/js/webflow.js:10
↓ 5 callersFunctionU
(l)
website/static/js/webflow.js:10
↓ 5 callersMethodaddColumnToDefault
(Schema schema, Types.NestedField field, Integer parentId)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSchemaSync.java:338
↓ 5 callersMethodassertFileGroupCorrectness
( HoodieTableMetaClient metaClient, String partitionPath, List<Pair<String, String>> fileIdA
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:576
↓ 5 callersMethodcommitTransaction
()
xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionTarget.java:312
↓ 5 callersMethodconstructFullyQualifiedName
(String columnName, String parentPath)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergSchemaSync.java:187
↓ 5 callersMethodconvertFromDeltaColumnStatValue
(Object value, InternalSchema fieldSchema)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaValueConverter.java:62
↓ 5 callersMethodcreateConversionTargetForName
Create an instance of the ConversionTarget via the default no-arg constructor. Expectation is that target conversion specific settings may be provided
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionTargetFactory.java:64
↓ 5 callersMethoddataFilesRemoved
Filters files of type {@link InternalDataFile} from the list of files removed to the source table and returns the list.
xtable-api/src/main/java/org/apache/xtable/model/storage/InternalFilesDiff.java:79
↓ 5 callersMethoddeleteRows
(List<T> rows)
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:47
↓ 5 callersMethodextractColumnName
(String expr, Pattern regexPattern)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaPartitionExtractor.java:534
↓ 5 callersMethodextractSnapshotChanges
Extracts the changes between the snapshot files and the base files in the Hudi table currently. @param partitionedDataFiles files grouped by partitio
xtable-core/src/main/java/org/apache/xtable/hudi/BaseFileUpdatesExtractor.java:77
↓ 5 callersMethodforStandardSchemaAndPartitioning
( String tableName, String partitionField, Path tempDir, Configuration hadoopConf)
xtable-core/src/test/java/org/apache/xtable/TestIcebergTable.java:85
↓ 5 callersMethodfromIceberg
Generates internal representation of the Iceberg partition spec. @param iceSpec the Iceberg partition spec @param iceSchema the Iceberg schema @retur
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergPartitionSpecExtractor.java:143
↓ 5 callersFunctiong
(l)
website/static/js/webflow.js:10
↓ 5 callersMethodgetCommitsBacklog
Retrieves {@link CommitsBacklog}, i.e. commits that have not been processed yet. based on the provided {@link InstantsForIncrementalSync}. @param ins
xtable-api/src/main/java/org/apache/xtable/spi/extractor/ConversionSource.java:77
↓ 5 callersMethodgetCommitsBacklog
(InstantsForIncrementalSync lastSyncInstant)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java:214
↓ 5 callersMethodgetCurrentSnapshot
()
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java:145
↓ 5 callersMethodgetCustomConfigurations
(String Configpath)
xtable-utilities/src/main/java/org/apache/xtable/utilities/RunSync.java:301
↓ 5 callersMethodgetDataFile
(String physicalPath)
xtable-api/src/test/java/org/apache/xtable/spi/extractor/TestExtractFromSource.java:143
↓ 5 callersMethodgetDateFormat
(String dataFormatString)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaValueConverter.java:55
↓ 5 callersMethodgetExpectedColumnStats
Get expected col stats for a file. @param fileName name of the file @return stats matching the column stats in {@link ColumnStatMapUtil#getColumnStat
xtable-core/src/test/java/org/apache/xtable/hudi/TestBaseFileUpdatesExtractor.java:426
↓ 5 callersMethodgetFileFormat
(String extension)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiDataFileExtractor.java:411
↓ 5 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergColumnStatsConverter.java:49
↓ 5 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergPartitionSpecSync.java:39
↓ 5 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/hudi/catalog/HudiCatalogTablePropertiesExtractor.java:49
↓ 5 callersMethodgetInstance
()
xtable-hudi-support/xtable-hudi-support-utils/src/main/java/org/apache/xtable/hudi/idtracking/IdTracker.java:60
↓ 5 callersMethodgetLastSyncResult
(List<SyncResult> syncResults)
xtable-core/src/test/java/org/apache/xtable/conversion/TestConversionController.java:510
↓ 5 callersMethodgetMetaClient
()
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:329
↓ 5 callersMethodgetNullCount
(List<ColumnStat> validColumnStats)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaStatsExtractor.java:152
↓ 5 callersMethodgetOrCreateTable
( IcebergCatalogConfig catalogConfig, TableIdentifier tableIdentifier, String basePath,
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergTableManager.java:68
↓ 5 callersMethodgetTable
(Snapshot snapshot)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java:108
↓ 5 callersMethodgetTableChangeForCommit
(Snapshot snapshot)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java:183
↓ 5 callersMethodgetTableFormat
Get table format from given table properties @param properties catalog table properties @return table format name <li>In case of ICEBERG, table_t
xtable-core/src/main/java/org/apache/xtable/catalog/TableFormatUtils.java:79
↓ 5 callersMethodgetTargetClient
()
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:726
↓ 5 callersMethodgetTargetCommitIdentifier
(String sourceIdentifier)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:298
↓ 5 callersMethodgetTestHmsTableStorageDescriptor
(List<FieldSchema> columns)
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/table/TestIcebergHMSCatalogTableBuilder.java:164
↓ 5 callersMethodgetTimeTravelOption
(String tableFormat, Instant time)
xtable-core/src/test/java/org/apache/xtable/ITConversionController.java:804
↓ 5 callersMethodinsertRecordsForPartition
(int numRows, String partitionValue)
xtable-core/src/test/java/org/apache/xtable/TestIcebergTable.java:167
↓ 5 callersMethodnewTable
(String dbName, String tableName)
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/HMSCatalogSyncTestBase.java:153
↓ 5 callersMethodpartitionValueExtraction
( scala.collection.Map<String, String> values, List<InternalPartitionField> partitionFields)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaPartitionExtractor.java:293
↓ 5 callersMethodsyncFilesForSnapshot
(List<PartitionFileGroup> partitionedDataFiles)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:245
↓ 5 callersMethodsyncMetadata
Syncs the {@link TableSyncMetadata} to the target for tracking metadata between runs. This is required for incremental sync. @param metadata the curr
xtable-api/src/main/java/org/apache/xtable/spi/sync/ConversionTarget.java:59
↓ 5 callersFunctionte
(p)
website/static/js/webflow.js:22
↓ 5 callersMethodupdatePartitionsToTable
Updates the specified partitions for a table in the catalog. @param tableIdentifier an object identifying the table whose partitions are to be update
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogPartitionSyncOperations.java:59
↓ 5 callersMethodupsertRecords
( List<HoodieRecord<HoodieAvroPayload>> records, boolean checkForNoErrors)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:279
↓ 5 callersMethodupsertRows
(List<T> rows)
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:45
↓ 5 callersFunctionv
()
website/static/js/webflow.js:22
↓ 5 callersMethodvalidateDeltaPartitioning
(InternalSnapshot internalSnapshot)
xtable-core/src/test/java/org/apache/xtable/delta/ITDeltaConversionSource.java:696
↓ 5 callersMethodvalidateTable
( InternalTable internalTable, String tableName, String tableFormat, InternalSchema re
xtable-core/src/test/java/org/apache/xtable/testutil/ITTestUtils.java:42
↓ 4 callersFunctionE
(b)
website/static/js/webflow.js:22
↓ 4 callersFunctionG
(N)
website/static/js/webflow.js:22
↓ 4 callersFunctionI
($)
website/static/js/webflow.js:10
↓ 4 callersFunctionKn
(e,t,r)
website/static/js/webflow.js:22
↓ 4 callersFunctionLe
(e,t,r)
website/static/js/webflow.js:22
↓ 4 callersFunctionT
(b)
website/static/js/webflow.js:22
↓ 4 callersFunctionTn
(e)
website/static/js/webflow.js:22
↓ 4 callersMethodaddStatsToFiles
Adds column stats and row count information to the provided stream of files. @param metadataTable the metadata table for the hudi table if it exists,
xtable-core/src/main/java/org/apache/xtable/hudi/HudiFileStatsExtractor.java:87
← previousnext →201–300 of 1,922, ranked by callers