Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/incubator-xtable
/ functions
Functions
1,922 in github.com/apache/incubator-xtable
⨍
Functions
1,922
◇
Types & classes
310
↓ 711 callers
Method
get
(int pos, Class<T> javaClass)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:183
↓ 434 callers
Method
schema
(CLIENT client)
xtable-api/src/main/java/org/apache/xtable/spi/extractor/SchemaExtractor.java:29
↓ 348 callers
Method
put
(int i, Object v)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:193
↓ 293 callers
Function
u
(e,t)
website/static/js/webflow.js:10
↓ 268 callers
Method
of
(Schema schema, Object... values)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:166
↓ 214 callers
Method
size
()
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:178
↓ 123 callers
Method
toList
(int size)
xtable-core/src/main/java/org/apache/xtable/collectors/CustomCollectors.java:27
↓ 91 callers
Method
call
(BaseHoodieClient hoodieClient)
xtable-hudi-support/xtable-hudi-support-extensions/src/main/java/org/apache/xtable/hudi/extensions/AddFieldIdsClientInitCallback.java:59
↓ 88 callers
Method
getTableName
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:148
↓ 86 callers
Method
getDatabaseName
@return the database (or schema) name; required
xtable-api/src/main/java/org/apache/xtable/model/catalog/HierarchicalTableIdentifier.java:30
↓ 82 callers
Method
getBasePath
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:53
↓ 79 callers
Method
create
( HoodieTableMetaClient metaClient, String instantTime, int timelineRetentionInHours,
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:179
↓ 73 callers
Method
getSchema
()
xtable-core/src/test/java/org/apache/xtable/testutil/ColumnStatMapUtil.java:203
↓ 71 callers
Method
getPrimitiveInternalField
( String fieldName, String schemaName, InternalType dataType, boolean isNullable, int fieldId)
xtable-core/src/test/java/org/apache/xtable/catalog/TestSchemaExtractorBase.java:29
↓ 70 callers
Method
getTable
Return the TABLE object used by the catalog implementation. Eg: HMS uses org.apache.hadoop.hive.metastore.api.Table, Glue uses software.amazon.awssdk.
xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSyncClient.java:59
↓ 65 callers
Method
scalar
(Object value)
xtable-api/src/main/java/org/apache/xtable/model/stat/Range.java:67
↓ 65 callers
Method
set
(int pos, T value)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:188
↓ 59 callers
Function
e
(r)
website/static/js/webflow.js:22
↓ 57 callers
Method
of
@deprecated Use {@link #of(Instant, List, String, String)} instead. This method exists for backward compatibility and will be removed in a future
xtable-api/src/main/java/org/apache/xtable/model/metadata/TableSyncMetadata.java:64
↓ 54 callers
Method
getTableName
@return the table name; required
xtable-api/src/main/java/org/apache/xtable/model/catalog/HierarchicalTableIdentifier.java:33
↓ 53 callers
Method
commit
()
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:381
↓ 52 callers
Method
toIceberg
(InternalSchema internalSchema)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergSchemaExtractor.java:65
↓ 48 callers
Method
sync
Runs a sync for the given source table configuration in ConversionConfig. @param config A per table level config containing tableBasePath, partitionF
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionController.java:97
↓ 40 callers
Method
vector
(Object minValue, Object maxValue)
xtable-api/src/main/java/org/apache/xtable/model/stat/Range.java:74
↓ 36 callers
Method
toHierarchicalTableIdentifier
( CatalogTableIdentifier tableIdentifier)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogUtils.java:39
↓ 35 callers
Method
getValues
( List<ColumnStat> validColumnStats, Function<ColumnStat, Object> valueExtractor)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaStatsExtractor.java:136
↓ 35 callers
Method
sync
(ConversionTarget conversionTarget)
xtable-api/src/main/java/org/apache/xtable/spi/sync/TableFormatSync.java:192
↓ 34 callers
Method
getAllActiveFiles
()
xtable-core/src/test/java/org/apache/xtable/TestSparkDeltaTable.java:214
↓ 34 callers
Method
getAllLatestBaseFilePaths
()
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:292
↓ 34 callers
Method
getConversionSourceInstance
Returns an instance of the {@link ConversionSource} for the given table format. The {@link ConversionSource} is source table aware. A source table may
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionSourceProvider.java:47
↓ 32 callers
Method
checkDatasetEquivalence
( String sourceFormat, GenericTable<?, ?> sourceTable, List<String> targetFormats, Int
xtable-core/src/test/java/org/apache/xtable/ITConversionController.java:837
↓ 32 callers
Function
n
(l)
website/static/js/webflow.js:10
↓ 31 callers
Method
getState
(Instant latestCommitTime)
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:709
↓ 31 callers
Method
insertRows
(int numRows)
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:41
↓ 30 callers
Method
createTable
Create a table in the catalog using the canonical InternalTable representation and tableIdentifier.
xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSyncClient.java:65
↓ 30 callers
Function
ee
(e,t,r)
website/static/js/webflow.js:10
↓ 30 callers
Method
getCreateTableRequest
(InternalTable table, CatalogTableIdentifier tableIdentifier)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogTableBuilder.java:29
↓ 30 callers
Method
insertRecords
( int numRecords, boolean checkForNoErrors)
xtable-core/src/test/java/org/apache/xtable/TestJavaHudiTable.java:208
↓ 29 callers
Method
getCurrentGlueTableColumn
( String tableFormat, String colName, String colType, Integer fieldId, boolean isNullable)
xtable-aws/src/test/java/org/apache/xtable/glue/TestGlueSchemaExtractor.java:103
↓ 29 callers
Method
of
(Map<String, String> properties)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogConfig.java:57
↓ 29 callers
Method
table
(CLIENT tableServiceClient)
xtable-api/src/main/java/org/apache/xtable/spi/extractor/TableExtractor.java:29
↓ 28 callers
Method
toInternalSchema
(Schema schema)
xtable-core/src/main/java/org/apache/xtable/avro/AvroSchemaConverter.java:76
↓ 26 callers
Method
getDataFile
(int index, List<PartitionValue> partitionValues)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSync.java:792
↓ 26 callers
Method
getInstance
()
xtable-api/src/main/java/org/apache/xtable/spi/sync/TableFormatSync.java:53
↓ 26 callers
Method
getTableFormat
Returns the TableFormat name the client syncs to
xtable-api/src/main/java/org/apache/xtable/spi/sync/ConversionTarget.java:91
↓ 26 callers
Method
mockColStatsForFile
(InternalDataFile dataFile, int times)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSync.java:865
↓ 26 callers
Method
syncSnapshot
( Map<String, ConversionTarget> conversionTargetByFormat, ExtractFromSource<COMMIT> source)
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionController.java:279
↓ 25 callers
Method
of
Creates GlueCatalogConfig from given key-value map
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogConfig.java:81
↓ 24 callers
Method
getId
Returns the string identifier for the table within its catalog context
xtable-api/src/main/java/org/apache/xtable/model/catalog/CatalogTableIdentifier.java:24
↓ 24 callers
Method
getMetadata
( HoodieInstant instant, HoodieTableMetaClient metaClient)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:334
↓ 24 callers
Function
se
(e,t)
website/static/js/webflow.js:10
↓ 23 callers
Method
close
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:63
↓ 23 callers
Method
getCatalogId
Returns the user-defined unique identifier for the catalog, allows user to sync table to multiple catalogs of the same name/type eg: HMS catalog with
xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSyncClient.java:40
↓ 23 callers
Method
getSourceTable
Returns the source table object present in the catalog.
xtable-api/src/main/java/org/apache/xtable/spi/extractor/CatalogConversionSource.java:36
↓ 23 callers
Method
init
Initializes the client with provided configuration
xtable-api/src/main/java/org/apache/xtable/spi/sync/ConversionTarget.java:94
↓ 23 callers
Method
values
()
xtable-api/src/main/java/org/apache/xtable/model/storage/TableFormat.java:31
↓ 22 callers
Method
finalizeSchema
(Schema targetSchema, InternalSchema inputSchema)
xtable-core/src/main/java/org/apache/xtable/avro/AvroSchemaConverter.java:481
↓ 22 callers
Method
fromInternalSchema
Converts the {@link InternalSchema} to Avro {@link Schema}. @param internalSchema internal schema representation @return an Avro schema
xtable-core/src/main/java/org/apache/xtable/avro/AvroSchemaConverter.java:317
↓ 22 callers
Method
fromJson
(String metadata)
xtable-api/src/main/java/org/apache/xtable/model/metadata/TableSyncMetadata.java:91
↓ 22 callers
Method
insertRows
(int numRows)
xtable-core/src/test/java/org/apache/xtable/TestSparkDeltaTable.java:94
↓ 22 callers
Method
syncPartitions
Syncs all partitions on storage to the catalog. @param oneTable The object representing the table whose partitions are being synced. This object
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogPartitionSyncTool.java:40
↓ 21 callers
Method
getFieldSchema
(String name, String type)
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/TestHMSSchemaExtractor.java:42
↓ 21 callers
Method
next
()
xtable-core/src/main/java/org/apache/xtable/delta/DeltaDataFileExtractor.java:95
↓ 21 callers
Method
parseFromInstantTime
Copied mostly from {@link org.apache.hudi.common.table.timeline.HoodieActiveTimeline#parseDateFromInstantTime(String)} but forces the timestamp to use
xtable-core/src/main/java/org/apache/xtable/hudi/HudiInstantUtils.java:57
↓ 21 callers
Method
snapshot
(CLIENT tableServiceClient)
xtable-api/src/main/java/org/apache/xtable/spi/extractor/SnapshotExtractor.java:31
↓ 20 callers
Method
addIdTracking
Adds IdTracking information to the properties of a schema and returns a schema with the property set. @param schema The schema to update the IdTracki
xtable-hudi-support/xtable-hudi-support-utils/src/main/java/org/apache/xtable/hudi/idtracking/IdTracker.java:104
↓ 20 callers
Method
getColumnStats
()
xtable-core/src/test/java/org/apache/xtable/testutil/ColumnStatMapUtil.java:225
↓ 20 callers
Method
getInstance
()
xtable-aws/src/main/java/org/apache/xtable/glue/GlueSchemaExtractor.java:59
↓ 20 callers
Method
getUpdateTableRequest
( InternalTable table, TABLE catalogTable, CatalogTableIdentifier tableIdentifier)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogTableBuilder.java:31
↓ 20 callers
Function
i
(l,h,y)
website/static/js/webflow.js:10
↓ 20 callers
Method
startCommit
()
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:251
↓ 20 callers
Function
t
(l,h)
website/static/js/webflow.js:10
↓ 19 callers
Method
generateRecords
(int numRecords)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:216
↓ 19 callers
Method
getDataFile
( int index, List<PartitionValue> partitionValues, Path basePath)
xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaSync.java:543
↓ 19 callers
Method
getInstance
()
xtable-core/src/main/java/org/apache/xtable/avro/AvroSchemaConverter.java:72
↓ 19 callers
Method
getStorageLocation
Returns the storage location of the table synced to the catalog.
xtable-api/src/main/java/org/apache/xtable/spi/sync/CatalogSyncClient.java:46
↓ 19 callers
Function
r
(l)
website/static/js/webflow.js:10
↓ 18 callers
Method
getAllActiveFiles
()
xtable-core/src/test/java/org/apache/xtable/TestIcebergTable.java:326
↓ 18 callers
Method
getColumn
(String name, String type)
xtable-aws/src/test/java/org/apache/xtable/glue/TestGlueSchemaExtractor.java:95
↓ 18 callers
Method
getTestFile
(String partitionPath, String fileName)
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:675
↓ 17 callers
Method
forStandardSchema
Create a test table instance for general testing. The table is created with the schema defined in basic_schema.avsc which contains many data types to
xtable-core/src/test/java/org/apache/xtable/TestJavaHudiTable.java:82
↓ 17 callers
Method
getTableProperties
Retrieves the properties indicating the last synchronization state for the given table. <p>This method provides a default implementation that returns
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogPartitionSyncOperations.java:82
↓ 17 callers
Method
iterator
Initializes an iterator for Delta Lake files. @return Delta table file iterator
xtable-core/src/main/java/org/apache/xtable/delta/DeltaDataFileExtractor.java:53
↓ 17 callers
Method
validateSnapshot
( InternalSnapshot internalSnapshot, List<String> allActivePaths)
xtable-core/src/test/java/org/apache/xtable/ValidationTestHelper.java:36
↓ 16 callers
Function
c
(l,h,y)
website/static/js/webflow.js:10
↓ 16 callers
Method
getFilesDiff
(int id)
xtable-api/src/test/java/org/apache/xtable/spi/sync/TestTableFormatSync.java:458
↓ 16 callers
Method
hasNext
()
xtable-core/src/main/java/org/apache/xtable/delta/DeltaDataFileExtractor.java:90
↓ 15 callers
Method
extractPartitionValues
( List<InternalPartitionField> partitionColumns, String partitionPath)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiPartitionValuesExtractor.java:47
↓ 15 callers
Method
findFieldByPath
Finds the field at the specified path in the provided schema. Currently, can only access nested fields within Records and not Maps or Arrays. @param
xtable-core/src/main/java/org/apache/xtable/schema/SchemaFieldFinder.java:47
↓ 15 callers
Method
getInstance
()
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergPartitionSpecExtractor.java:53
↓ 15 callers
Method
getInstance
()
xtable-core/src/main/java/org/apache/xtable/schema/SchemaFieldFinder.java:35
↓ 15 callers
Method
getSchemaWithFields
(List<String> fields)
xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaPartitionExtractor.java:539
↓ 15 callers
Method
getTableSyncConfig
( String sourceTableFormat, SyncMode syncMode, String tableName, GenericTable table,
xtable-core/src/test/java/org/apache/xtable/ITConversionController.java:1046
↓ 15 callers
Function
o
()
website/static/js/webflow.js:10
↓ 15 callers
Method
toColumns
Extract column list from InternalTable schema @param tableFormat tableFormat to handle format specific type conversion @param tableSchema InternalTab
xtable-aws/src/main/java/org/apache/xtable/glue/GlueSchemaExtractor.java:70
↓ 15 callers
Method
toColumns
Extract HMS schema from InternalTable schema @param tableFormat tableFormat to handle format specific type conversion @param tableSchema InternalTabl
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSSchemaExtractor.java:51
↓ 15 callers
Method
validateTableChanges
( List<List<String>> allActiveFiles, List<TableChange> allTableChanges)
xtable-core/src/test/java/org/apache/xtable/ValidationTestHelper.java:52
↓ 14 callers
Method
createForFormat
Create a fully initialized instance of the ConversionTarget represented by the given Table Format name. Initialization is done with the config provide
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionTargetFactory.java:48
↓ 14 callers
Method
createRecord
( Long longValue, String stringValue, Integer nestedIntValue, List<Integer> listValues
xtable-core/src/test/java/org/apache/xtable/hudi/TestHudiFileStatsExtractor.java:417
↓ 14 callers
Method
insertRecordsWithCommitAlreadyStarted
( List<HoodieRecord<HoodieAvroPayload>> inserts, String commitInstant, boolean checkForNoErr
xtable-core/src/test/java/org/apache/xtable/TestJavaHudiTable.java:161
next →
1–100 of 1,922, ranked by callers