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
↓ 2 callersMethodgetAllRecordsInTable
()
xtable-core/src/test/java/org/apache/xtable/TestIcebergTable.java:399
↓ 2 callersMethodgetBoundsMap
( Object timestampColumnStatsValue, Object dateColumnStatsValue, Object groupIdStatsValue,
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergColumnStatsConverter.java:385
↓ 2 callersMethodgetCatalogImpl
()
xtable-api/src/main/java/org/apache/xtable/conversion/CatalogConfig.java:30
↓ 2 callersMethodgetCatalogName
()
xtable-api/src/main/java/org/apache/xtable/conversion/CatalogConfig.java:32
↓ 2 callersMethodgetChangesState
()
xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionSource.java:213
↓ 2 callersMethodgetColumnStatFromValues
( Comparable minValue, Comparable maxValue, InternalField field, long nullCount,
xtable-core/src/main/java/org/apache/xtable/hudi/HudiFileStatsExtractor.java:246
↓ 2 callersMethodgetCommitAtInstant
(Instant instant)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionSource.java:246
↓ 2 callersMethodgetCommitIdentifier
(Long commit)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionSource.java:208
↓ 2 callersMethodgetCommitIdentifier
(Snapshot commit)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java:273
↓ 2 callersMethodgetCommitIdentifier
(HoodieInstant commit)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionSource.java:166
↓ 2 callersMethodgetConversionTarget
()
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSync.java:192
↓ 2 callersMethodgetCreateOrUpdateTableInput
( String tableName, Map<String, String> params, StorageDescriptor sd)
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestIcebergGlueCatalogTableBuilder.java:137
↓ 2 callersMethodgetDataFile
( PartitionSpec partitionSpec, Schema schema, InternalDataFile dataFile)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergDataFileUpdatesSync.java:108
↓ 2 callersMethodgetDatasetConfig
(String datasetConfigPath)
xtable-utilities/src/main/java/org/apache/xtable/utilities/RunSync.java:193
↓ 2 callersMethodgetDate
(String dateStr)
xtable-core/src/test/java/org/apache/xtable/hudi/TestHudiFileStatsExtractor.java:458
↓ 2 callersMethodgetDbRequest
(String dbName)
xtable-aws/src/test/java/org/apache/xtable/glue/GlueCatalogSyncTestBase.java:175
↓ 2 callersMethodgetDefaultMappingProperties
(Schema schema)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergTableManager.java:103
↓ 2 callersMethodgetExtraMetadata
()
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:575
↓ 2 callersMethodgetFilterQuery
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:69
↓ 2 callersMethodgetFormatsWithStatusCode
( Map<String, SyncResult> syncResultsMerged, SyncStatusCode statusCode)
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionController.java:244
↓ 2 callersMethodgetGlueClient
()
xtable-aws/src/main/java/org/apache/xtable/glue/GlueClientFactory.java:35
↓ 2 callersMethodgetHoodieRecordStream
( int numRecords, Object partitionValue, Instant startTimeWindow, Instant endTimeWindow)
xtable-core/src/test/java/org/apache/xtable/TestJavaHudiTable.java:244
↓ 2 callersMethodgetIcebergConversionSource
(Table catalogSales)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergConversionSource.java:386
↓ 2 callersMethodgetInstance
()
xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSync.java:48
↓ 2 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergSchemaSync.java:43
↓ 2 callersMethodgetKeyGeneratorClass
( List<InternalPartitionField> partitionFields, List<InternalField> recordKeyFields)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiTableManager.java:126
↓ 2 callersMethodgetLastLeadingSlashIndex
Finds the index of the last '/' character after the file scheme. @param path input path, assumed to contain a scheme @return the index or throws exce
xtable-core/src/main/java/org/apache/xtable/paths/PathUtils.java:55
↓ 2 callersMethodgetLatestSnapshot
()
xtable-core/src/test/java/org/apache/xtable/TestIcebergTable.java:322
↓ 2 callersMethodgetMSC
()
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSClientProvider.java:45
↓ 2 callersMethodgetMaxFromColumnStats
(List<ColumnStat> columnStats)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiFileStatsExtractor.java:170
↓ 2 callersMethodgetMaxValues
(List<ColumnStat> validColumnStats)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaStatsExtractor.java:132
↓ 2 callersMethodgetMetaClient
( TypedProperties keyGenProperties, HoodieTableType hoodieTableType, Configuration conf)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:590
↓ 2 callersMethodgetMetadataFileLocation
(BaseTable table)
xtable-aws/src/main/java/org/apache/xtable/glue/table/IcebergGlueCatalogTableBuilder.java:118
↓ 2 callersMethodgetMetadataFileLocation
(BaseTable table)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/table/IcebergHMSCatalogTableBuilder.java:123
↓ 2 callersMethodgetMinValues
(List<ColumnStat> validColumnStats)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaStatsExtractor.java:128
↓ 2 callersMethodgetNestedRecord
(Integer nestedIntValue)
xtable-core/src/test/java/org/apache/xtable/hudi/TestHudiFileStatsExtractor.java:451
↓ 2 callersMethodgetOrderByColumn
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:61
↓ 2 callersMethodgetPartitionEvents
Gets the partition events for changed partitions. <p>This compares the list of all partitions of a table stored in the catalog and on the storage: (1
xtable-core/src/main/java/org/apache/xtable/hudi/catalog/HudiCatalogPartitionSyncTool.java:366
↓ 2 callersMethodgetPartitionSyncTool
( String tableFormat, String partitionValueExtractorClass, CatalogPartitionSyncOperations ca
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogUtils.java:48
↓ 2 callersMethodgetPartitionValuesToPathMapping
Gets the partition values to the absolute path mapping based on the partition information from the catalog. @param partitionsInCatalog Partitions in
xtable-core/src/main/java/org/apache/xtable/hudi/catalog/HudiCatalogPartitionSyncTool.java:458
↓ 2 callersMethodgetPreviousGlueTableColumn
( String tableFormat, String colName, String colType)
xtable-aws/src/test/java/org/apache/xtable/glue/TestGlueSchemaExtractor.java:129
↓ 2 callersMethodgetRecords
()
xtable-core/src/test/java/org/apache/xtable/hudi/TestHudiFileStatsExtractor.java:298
↓ 2 callersMethodgetRelativePath
Constructs the relative path to the file from the table's base path. @param path the path to the file, input can be full or relative @param basePath
xtable-core/src/main/java/org/apache/xtable/paths/PathUtils.java:33
↓ 2 callersMethodgetRemovedFiles
( String partitionPath, List<String> deletedPaths, List<InternalPartitionField> partitioning
xtable-core/src/main/java/org/apache/xtable/hudi/HudiDataFileExtractor.java:256
↓ 2 callersMethodgetSchemaFields
()
xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaStatsExtractor.java:216
↓ 2 callersMethodgetSchemaPartitionKeys
(List<InternalPartitionField> partitioningFields)
xtable-aws/src/main/java/org/apache/xtable/glue/table/HudiGlueCatalogTableBuilder.java:173
↓ 2 callersMethodgetSchemaWithoutPartitionKeys
(InternalTable table)
xtable-aws/src/main/java/org/apache/xtable/glue/table/HudiGlueCatalogTableBuilder.java:163
↓ 2 callersMethodgetSerDeParameters
(InternalTable table)
xtable-aws/src/main/java/org/apache/xtable/glue/table/DeltaGlueCatalogTableBuilder.java:109
↓ 2 callersMethodgetSparkConf
(Path tempDir)
xtable-core/src/test/java/org/apache/xtable/hudi/HudiTestUtil.java:115
↓ 2 callersMethodgetSyncResult
( ConversionTarget conversionTarget, SyncMode mode, InternalTable tableState, SyncFile
xtable-api/src/main/java/org/apache/xtable/spi/sync/TableFormatSync.java:153
↓ 2 callersMethodgetTable
(Long version)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionSource.java:81
↓ 2 callersMethodgetTableChange
(Instant instant, String sourceIdentifier)
xtable-core/src/test/java/org/apache/xtable/conversion/TestConversionController.java:527
↓ 2 callersMethodgetTableRequest
(String dbName, String tableName)
xtable-aws/src/test/java/org/apache/xtable/glue/GlueCatalogSyncTestBase.java:179
↓ 2 callersMethodgetTableSyncConfig
( SyncMode syncMode, String tableName, GenericTable table, List<String> targetTableFormats)
xtable-core/src/test/java/org/apache/xtable/loadtest/LoadTest.java:136
↓ 2 callersMethodgetTargetCatalog
(String suffix)
xtable-core/src/test/java/org/apache/xtable/conversion/TestConversionController.java:610
↓ 2 callersFunctiongr
(p)
website/static/js/webflow.js:22
↓ 2 callersMethodgroupRecordsByPartition
(List<Record> records)
xtable-core/src/test/java/org/apache/xtable/TestIcebergTable.java:280
↓ 2 callersMethodinitJavaWriteClient
( Schema schema, TypedProperties keyGenProperties, HoodieArchivalConfig archivalConfig)
xtable-core/src/test/java/org/apache/xtable/TestJavaHudiTable.java:302
↓ 2 callersMethodinitSparkWriteClient
( Schema schema, TypedProperties keyGenProperties)
xtable-core/src/test/java/org/apache/xtable/TestSparkHudiTable.java:265
↓ 2 callersMethodinsertRecords
( int numRecords, boolean checkForNoErrors)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:210
↓ 2 callersMethodinsertRecordsForSpecialPartition
(int numRows)
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:43
↓ 2 callersMethodinsertValueAtPath
(Map<String, Object> jsonObject, String[] pathParts, Object value)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaStatsExtractor.java:163
↓ 2 callersMethodisIncrementalSyncSafeFrom
(Instant instant)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionSource.java:198
↓ 2 callersMethodisTimeBased
()
xtable-api/src/main/java/org/apache/xtable/model/schema/PartitionTransformType.java:36
↓ 2 callersFunctionks
(e,t)
website/static/js/webflow.js:22
↓ 2 callersMethodloadIcebergCatalogConfig
(byte[] customConfigs)
xtable-utilities/src/main/java/org/apache/xtable/utilities/RunSync.java:341
↓ 2 callersMethodloadTableFromFs
(String tableBasePath)
xtable-aws/src/main/java/org/apache/xtable/glue/table/IcebergGlueCatalogTableBuilder.java:114
↓ 2 callersMethodloadTableFromFs
(String tableBasePath)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/table/IcebergHMSCatalogTableBuilder.java:119
↓ 2 callersFunctionm
()
website/static/js/webflow.js:22
↓ 2 callersMethodmain
(String[] args)
xtable-utilities/src/main/java/org/apache/xtable/utilities/RunCatalogSync.java:113
↓ 2 callersMethodmergeAndDedupLists
Merges commits from two lists and returns new list of sorted commits by eliminating duplicates. @param list1 First sorted input list of commits @para
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionSource.java:280
↓ 2 callersMethodmockHadoopTables
()
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/table/TestIcebergHMSCatalogTableBuilder.java:73
↓ 2 callersMethodmockIcebergHadoopTables
()
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestIcebergGlueCatalogTableBuilder.java:69
↓ 2 callersMethodmockIcebergMetadataFileLocation
()
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestIcebergGlueCatalogTableBuilder.java:74
↓ 2 callersMethodmockMetadataFileLocation
()
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/table/TestIcebergHMSCatalogTableBuilder.java:78
↓ 2 callersMethodnewPartitionAddEvent
(String storagePartition)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogPartitionEvent.java:38
↓ 2 callersMethodnewPartitionDropEvent
(String storagePartition)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogPartitionEvent.java:46
↓ 2 callersMethodnewPartitionUpdateEvent
(String storagePartition)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogPartitionEvent.java:42
↓ 2 callersFunctionnf
(e)
website/static/js/webflow.js:22
↓ 2 callersMethodnoConversionForSchema
(InternalSchema fieldSchema)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaValueConverter.java:129
↓ 2 callersMethodnumIcebergMetadataJsonFiles
(Path path)
xtable-utilities/src/test/java/org/apache/xtable/utilities/ITRunSync.java:120
↓ 2 callersMethodonlyScheduleCompaction
()
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:309
↓ 2 callersMethodparsePartitionFieldSpecs
(String input)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiSourceConfig.java:69
↓ 2 callersMethodreadResourceFile
(String resourcePath)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergConversionSource.java:403
↓ 2 callersMethodrunSync
(CommandLine cmd)
xtable-utilities/src/main/java/org/apache/xtable/utilities/RunSync.java:286
↓ 2 callersMethodrunVacuum
()
xtable-core/src/test/java/org/apache/xtable/TestSparkDeltaTable.java:204
↓ 2 callersFunctions_
()
website/static/js/webflow.js:22
↓ 2 callersMethodsanitizeBasePath
(String tableBasePath)
xtable-api/src/main/java/org/apache/xtable/conversion/ExternalTable.java:64
↓ 2 callersMethodsetupCommonMocks
()
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestHudiGlueCatalogTableBuilder.java:67
↓ 2 callersMethodsetupCommonMocks
()
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestIcebergGlueCatalogTableBuilder.java:65
↓ 2 callersMethodsetupCommonMocks
()
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestDeltaGlueCatalogTableBuilder.java:47
↓ 2 callersMethodsetupCommonMocks
()
xtable-core/src/test/java/org/apache/xtable/hudi/catalog/TestHudiCatalogPartitionSyncTool.java:119
↓ 2 callersMethodsetupCommonMocks
()
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/table/TestHudiHMSCatalogTableBuilder.java:61
↓ 2 callersMethodsetupMetaClientMocks
()
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestHudiGlueCatalogTableBuilder.java:72
↓ 2 callersMethodsetupMetaClientMocks
()
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/table/TestHudiHMSCatalogTableBuilder.java:66
↓ 2 callersFunctionsf
(e)
website/static/js/webflow.js:22
↓ 2 callersMethodsyncFilesForDiff
(InternalFilesDiff internalFilesDiff)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:253
↓ 2 callersMethodsyncPartitionSpec
(List<InternalPartitionField> partitionSpec)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:222
↓ 2 callersMethodsyncTableAcrossCatalogs
Synchronizes the source table in conversion config to multiple target catalogs. If the configuration for the target table uses a different table forma
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionController.java:125
↓ 2 callersMethodsyncTableFormats
Synchronizes the given source table format metadata in ConversionConfig to multiple target formats. @param config A per table level config containing
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionController.java:174
← previousnext →501–600 of 1,922, ranked by callers