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
↓ 3 callersMethodgetTable
(HoodieInstant commit)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionSource.java:74
↓ 3 callersMethodgetTableParameters
()
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/table/DeltaHMSCatalogTableBuilder.java:79
↓ 3 callersMethodgetTestParameters
()
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/table/TestDeltaHMSCatalogTableBuilder.java:127
↓ 3 callersMethodgetTestStorageDescriptor
(List<Column> columns)
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestIcebergGlueCatalogTableBuilder.java:147
↓ 3 callersMethodgetTestStorageDescriptor
(List<Column> columns)
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestDeltaGlueCatalogTableBuilder.java:95
↓ 3 callersMethodgetTestStorageDescriptor
(List<FieldSchema> columns)
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/table/TestDeltaHMSCatalogTableBuilder.java:113
↓ 3 callersMethodgetVersion
()
xtable-core/src/test/java/org/apache/xtable/TestSparkDeltaTable.java:196
↓ 3 callersMethodhasStorageDescriptorLocationChanged
Returns whether the location of the table in catalog is same as the one currently in storage. @param storageDescriptorLocation location of the table
xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogUtils.java:39
↓ 3 callersMethodinitializeHudiTable
Initializes a Hudi table with properties matching the provided {@link InternalTable} @param tableDataPath the base path for the data files in the tab
xtable-core/src/main/java/org/apache/xtable/hudi/HudiTableManager.java:87
↓ 3 callersMethodisIncrementalSyncSafeFrom
(Instant instant)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionSource.java:161
↓ 3 callersMethodmain
(String[] args)
xtable-utilities/src/main/java/org/apache/xtable/utilities/RunSync.java:240
↓ 3 callersMethodnewHmsTable
( CatalogTableIdentifier tblIdentifier, StorageDescriptor storageDescriptor, Map<String, Str
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogTableBuilderFactory.java:58
↓ 3 callersMethodsetBaseHoodieClientMocks
( HoodieEngineContext localEngineContext, HoodieWriteConfig config)
xtable-hudi-support/xtable-hudi-support-extensions/src/test/java/org/apache/xtable/hudi/extensions/TestAddFieldIdsClientInitCallback.java:190
↓ 3 callersMethodsetup
()
xtable-aws/src/test/java/org/apache/xtable/glue/TestGlueCatalogConversionSource.java:74
↓ 3 callersMethodsyncTable
( Map<CatalogTableIdentifier, CatalogSyncClient> catalogSyncClients, InternalTable table)
xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSync.java:52
↓ 3 callersMethodtableExists
( IcebergCatalogConfig catalogConfig, TableIdentifier tableIdentifier, String basePath)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergTableManager.java:61
↓ 3 callersMethodupsertRows
(List<Row> upsertRows)
xtable-core/src/test/java/org/apache/xtable/TestSparkDeltaTable.java:123
↓ 3 callersMethodvalidatePendingCommits
(Table table, Snapshot lastSync, Snapshot... snapshots)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergConversionSource.java:295
↓ 3 callersMethodwaitForNumIcebergCommits
(Path metadataPath, int count)
xtable-utilities/src/test/java/org/apache/xtable/utilities/ITRunSync.java:109
↓ 3 callersFunctionx
(b)
website/static/js/webflow.js:22
↓ 2 callersFunction$v
(e,t)
website/static/js/webflow.js:22
↓ 2 callersFunctionAn
(e,t,r)
website/static/js/webflow.js:22
↓ 2 callersFunctionFh
(e)
website/static/js/webflow.js:22
↓ 2 callersFunctionHr
(e,t=5,r=10)
website/static/js/webflow.js:22
↓ 2 callersFunctionIa
(e,t,r,n,i)
website/static/js/webflow.js:22
↓ 2 callersFunctionIl
(e)
website/static/js/webflow.js:22
↓ 2 callersFunctionIn
(e)
website/static/js/webflow.js:22
↓ 2 callersFunctionK
(_)
website/static/js/webflow.js:10
↓ 2 callersFunctionKc
(e)
website/static/js/webflow.js:22
↓ 2 callersFunctionL
()
website/static/js/webflow.js:22
↓ 2 callersFunctionLs
()
website/static/js/webflow.js:22
↓ 2 callersFunctionOn
(e,t,r)
website/static/js/webflow.js:22
↓ 2 callersFunctionPh
(e,t)
website/static/js/webflow.js:22
↓ 2 callersFunctionQv
(e)
website/static/js/webflow.js:22
↓ 2 callersFunctionTf
(e)
website/static/js/webflow.js:22
↓ 2 callersFunctionUh
({actionGroup:e,event:t,elementApi:r})
website/static/js/webflow.js:22
↓ 2 callersFunctionVh
({actionList:e={},event:t,elementApi:r})
website/static/js/webflow.js:22
↓ 2 callersFunctionY
(p,M)
website/static/js/webflow.js:22
↓ 2 callersFunctionYv
(e,t)
website/static/js/webflow.js:22
↓ 2 callersFunctionZv
(e,t,r)
website/static/js/webflow.js:22
↓ 2 callersMethod_init
(ExternalCatalogConfig catalogConfig, Configuration configuration)
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogConversionSource.java:96
↓ 2 callersMethod_init
( ExternalCatalogConfig catalogConfig, String tableFormat, Configuration configuration)
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogSyncClient.java:228
↓ 2 callersMethod_init
( String tableDataPath, String tableName, long logRetentionInHours, SparkSession spark
xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionTarget.java:122
↓ 2 callersMethod_init
( TargetTable targetTable, Configuration configuration, IcebergSchemaExtractor schemaExtract
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionTarget.java:94
↓ 2 callersMethod_init
( String tableDataPath, int timelineRetentionInHours, int maxNumDeltaCommitsBeforeCompaction
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:145
↓ 2 callersMethod_init
( ExternalCatalogConfig catalogConfig, String tableFormat, Configuration configuration)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogSyncClient.java:197
↓ 2 callersMethod_init
(ExternalCatalogConfig catalogConfig, Configuration configuration)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogConversionSource.java:103
↓ 2 callersFunction_l
(e)
website/static/js/webflow.js:22
↓ 2 callersMethodaddUpdates
Return a mapping of fieldId in the latest schema to an update action to perform. This allows updates to happen in the same order as the source system.
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergSchemaSync.java:71
↓ 2 callersMethodapplyDiff
( InternalFilesDiff internalFilesDiff, InternalSchema tableSchema, String tableBasePath)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaDataFileUpdatesExtractor.java:85
↓ 2 callersMethodapplyDiff
( Transaction transaction, InternalFilesDiff internalFilesDiff, Schema schema, Partiti
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergDataFileUpdatesSync.java:70
↓ 2 callersMethodassertSchema
(HoodieTableMetaClient metaClient, boolean includeMetaFields)
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:541
↓ 2 callersFunctionbn
(e,t)
website/static/js/webflow.js:22
↓ 2 callersFunctionbs
(e,t,r,n)
website/static/js/webflow.js:10
↓ 2 callersMethodbuildFromString
(String partitionColumnName, String expr)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaPartitionExtractor.java:460
↓ 2 callersMethodbuildPerTableResult
( List<String> tableFormats, SyncResult syncResult)
xtable-core/src/test/java/org/apache/xtable/conversion/TestConversionController.java:514
↓ 2 callersMethodbuildResultForError
(SyncMode mode, Instant startTime, Exception e)
xtable-api/src/main/java/org/apache/xtable/spi/sync/TableFormatSync.java:195
↓ 2 callersMethodbuildSparkSession
(Configuration conf)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaConversionUtils.java:33
↓ 2 callersMethodbuilderFrom
(InternalSchema schema)
xtable-api/src/main/java/org/apache/xtable/model/schema/InternalSchema.java:64
↓ 2 callersFunctionc_
({store:e,actionListId:t,eventId:r})
website/static/js/webflow.js:22
↓ 2 callersFunctioncf
(e,t)
website/static/js/webflow.js:22
↓ 2 callersMethodcontainsUUIDFields
(List<String> rows)
xtable-core/src/test/java/org/apache/xtable/ITConversionController.java:998
↓ 2 callersMethodconvertAddActionToInternalDataFile
( AddFile addFile, Snapshot deltaSnapshot, FileFormat fileFormat, List<InternalPartiti
xtable-core/src/main/java/org/apache/xtable/delta/DeltaActionsConverter.java:51
↓ 2 callersMethodconvertBytesToBigDecimal
(ByteBuffer value, int scale)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiFileStatsExtractor.java:224
↓ 2 callersMethodconvertDiff
Converts the provided {@link InternalFilesDiff}. @param internalFilesDiff the diff to apply to the Hudi table @param commit The current commit starte
xtable-core/src/main/java/org/apache/xtable/hudi/BaseFileUpdatesExtractor.java:172
↓ 2 callersMethodconvertFields
( InternalSchema schema, AtomicInteger fieldIdTracker)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergSchemaExtractor.java:143
↓ 2 callersMethodconvertFromDeltaPartitionValue
( String value, InternalType fieldType, PartitionTransformType partitionTransformType,
xtable-core/src/main/java/org/apache/xtable/delta/DeltaValueConverter.java:157
↓ 2 callersMethodconvertFromIcebergValue
(Type fieldType, ByteBuffer value)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergColumnStatsConverter.java:122
↓ 2 callersMethodconvertFromXTablePath
(String path)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiSchemaExtractor.java:58
↓ 2 callersMethodconvertToDeltaColumnStatValue
(Object value, InternalSchema fieldSchema)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaValueConverter.java:102
↓ 2 callersMethodconvertToDeltaPartitionFormat
( List<InternalPartitionField> partitionFields)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaPartitionExtractor.java:232
↓ 2 callersMethodconvertToFileFormat
(String provider)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaActionsConverter.java:91
↓ 2 callersMethodcopyField
(Schema.Field input)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:620
↓ 2 callersMethodcopyRecords
( List<HoodieRecord<HoodieAvroPayload>> records)
xtable-core/src/test/java/org/apache/xtable/TestJavaHudiTable.java:279
↓ 2 callersMethodcreateAddFileAction
( InternalDataFile dataFile, InternalSchema schema, String tableBasePath)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaDataFileUpdatesExtractor.java:112
↓ 2 callersMethodcreateIcebergGlueCatalogSyncHelper
()
xtable-aws/src/test/java/org/apache/xtable/glue/table/TestIcebergGlueCatalogTableBuilder.java:60
↓ 2 callersMethodcreateInstanceOfClassFromStaticMethod
( String className, String methodName, Class<?>[] argClasses, Object[] args)
xtable-core/src/main/java/org/apache/xtable/reflection/ReflectionUtils.java:61
↓ 2 callersMethodcreatePartition
( HierarchicalTableIdentifier tableIdentifier, CatalogPartition partition, StorageDescriptor
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogPartitionSyncOperations.java:201
↓ 2 callersMethodcreatePartitionInput
(Table table, CatalogPartition partition)
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogPartitionSyncOperations.java:322
↓ 2 callersMethodcreateProps
(String... keyValues)
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/TestHMSCatalogConfig.java:57
↓ 2 callersMethodcreateTable
(InternalTable table, CatalogTableIdentifier tableIdentifier)
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogSyncClient.java:160
↓ 2 callersMethodcreateTable
(InternalTable table, CatalogTableIdentifier tableIdentifier)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogSyncClient.java:146
↓ 2 callersMethodcreateWriteStatus
( String fileName, String partitionPath, String commitTime, long recordCount, lo
xtable-core/src/test/java/org/apache/xtable/hudi/HudiTestUtil.java:90
↓ 2 callersMethoddeletePartition
(Q partitionValue)
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:49
↓ 2 callersMethoddropColumnInDefault
(Integer fieldId, Integer parentId)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSchemaSync.java:391
↓ 2 callersMethoddropTable
(InternalTable table, CatalogTableIdentifier tableIdentifier)
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogSyncClient.java:207
↓ 2 callersMethoddropTable
(InternalTable table, CatalogTableIdentifier tblIdentifier)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogSyncClient.java:181
↓ 2 callersMethodextractPathsFromDataFile
(Set<InternalDataFile> dataFiles)
xtable-core/src/test/java/org/apache/xtable/ValidationTestHelper.java:98
↓ 2 callersFunctionf_
(e,t,r)
website/static/js/webflow.js:22
↓ 2 callersMethodfindInstanceByCatalogType
( Class<T> serviceClass, String catalogType, Function<T, String> catalogTypeExtractor)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogConversionFactory.java:91
↓ 2 callersMethodfromIceberg
Deserializes Iceberg schema representation to internal schema representation @param iceSchema Iceberg schema @return Internal representation of deser
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergSchemaExtractor.java:108
↓ 2 callersMethodfromInternalSchema
(InternalSchema internalSchema)
xtable-core/src/main/java/org/apache/xtable/schema/SparkSchemaExtractor.java:43
↓ 2 callersMethodfromProperties
(Properties properties)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiSourceConfig.java:51
↓ 2 callersMethodgenerateInsertRecord
( Instant startTimeWindow, Instant endTimeWindow, Types.StructType structType)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergDataHelper.java:243
↓ 2 callersMethodgenerateInsertRecordForPartition
(int numRecords, Object partitionValue)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergDataHelper.java:174
↓ 2 callersMethodgenerateRandomRowForGivenYearAndLevel
(int year, String level)
xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaHelper.java:173
↓ 2 callersMethodgenerateUpdatesForRecords
( List<HoodieRecord<HoodieAvroPayload>> records)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:393
↓ 2 callersMethodgenerateValueForField
( Types.NestedField field, String keyValue, Instant timeLowerBound, Instant timeUpperB
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergDataHelper.java:264
↓ 2 callersMethodgenerateWriteConfig
(Schema schema, TypedProperties keyGenProperties)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:415
↓ 2 callersMethodgetAllPartitionPathsOnStorage
Gets all relative partitions paths in the Hudi table on storage. @return All relative partitions paths.
xtable-core/src/main/java/org/apache/xtable/hudi/catalog/HudiCatalogPartitionSyncTool.java:213
← previousnext →401–500 of 1,922, ranked by callers