MCPcopy Create free account

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

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

↓ 711 callersMethodget
(int pos, Class<T> javaClass)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:183
↓ 434 callersMethodschema
(CLIENT client)
xtable-api/src/main/java/org/apache/xtable/spi/extractor/SchemaExtractor.java:29
↓ 348 callersMethodput
(int i, Object v)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:193
↓ 293 callersFunctionu
(e,t)
website/static/js/webflow.js:10
↓ 268 callersMethodof
(Schema schema, Object... values)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:166
↓ 214 callersMethodsize
()
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:178
↓ 123 callersMethodtoList
(int size)
xtable-core/src/main/java/org/apache/xtable/collectors/CustomCollectors.java:27
↓ 91 callersMethodcall
(BaseHoodieClient hoodieClient)
xtable-hudi-support/xtable-hudi-support-extensions/src/main/java/org/apache/xtable/hudi/extensions/AddFieldIdsClientInitCallback.java:59
↓ 88 callersMethodgetTableName
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:148
↓ 86 callersMethodgetDatabaseName
@return the database (or schema) name; required
xtable-api/src/main/java/org/apache/xtable/model/catalog/HierarchicalTableIdentifier.java:30
↓ 82 callersMethodgetBasePath
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:53
↓ 79 callersMethodcreate
( HoodieTableMetaClient metaClient, String instantTime, int timelineRetentionInHours,
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:179
↓ 73 callersMethodgetSchema
()
xtable-core/src/test/java/org/apache/xtable/testutil/ColumnStatMapUtil.java:203
↓ 71 callersMethodgetPrimitiveInternalField
( String fieldName, String schemaName, InternalType dataType, boolean isNullable, int fieldId)
xtable-core/src/test/java/org/apache/xtable/catalog/TestSchemaExtractorBase.java:29
↓ 70 callersMethodgetTable
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 callersMethodscalar
(Object value)
xtable-api/src/main/java/org/apache/xtable/model/stat/Range.java:67
↓ 65 callersMethodset
(int pos, T value)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergPartitionValueConverter.java:188
↓ 59 callersFunctione
(r)
website/static/js/webflow.js:22
↓ 57 callersMethodof
@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 callersMethodgetTableName
@return the table name; required
xtable-api/src/main/java/org/apache/xtable/model/catalog/HierarchicalTableIdentifier.java:33
↓ 53 callersMethodcommit
()
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:381
↓ 52 callersMethodtoIceberg
(InternalSchema internalSchema)
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergSchemaExtractor.java:65
↓ 48 callersMethodsync
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 callersMethodvector
(Object minValue, Object maxValue)
xtable-api/src/main/java/org/apache/xtable/model/stat/Range.java:74
↓ 36 callersMethodtoHierarchicalTableIdentifier
( CatalogTableIdentifier tableIdentifier)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogUtils.java:39
↓ 35 callersMethodgetValues
( List<ColumnStat> validColumnStats, Function<ColumnStat, Object> valueExtractor)
xtable-core/src/main/java/org/apache/xtable/delta/DeltaStatsExtractor.java:136
↓ 35 callersMethodsync
(ConversionTarget conversionTarget)
xtable-api/src/main/java/org/apache/xtable/spi/sync/TableFormatSync.java:192
↓ 34 callersMethodgetAllActiveFiles
()
xtable-core/src/test/java/org/apache/xtable/TestSparkDeltaTable.java:214
↓ 34 callersMethodgetAllLatestBaseFilePaths
()
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:292
↓ 34 callersMethodgetConversionSourceInstance
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 callersMethodcheckDatasetEquivalence
( String sourceFormat, GenericTable<?, ?> sourceTable, List<String> targetFormats, Int
xtable-core/src/test/java/org/apache/xtable/ITConversionController.java:837
↓ 32 callersFunctionn
(l)
website/static/js/webflow.js:10
↓ 31 callersMethodgetState
(Instant latestCommitTime)
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:709
↓ 31 callersMethodinsertRows
(int numRows)
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:41
↓ 30 callersMethodcreateTable
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 callersFunctionee
(e,t,r)
website/static/js/webflow.js:10
↓ 30 callersMethodgetCreateTableRequest
(InternalTable table, CatalogTableIdentifier tableIdentifier)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogTableBuilder.java:29
↓ 30 callersMethodinsertRecords
( int numRecords, boolean checkForNoErrors)
xtable-core/src/test/java/org/apache/xtable/TestJavaHudiTable.java:208
↓ 29 callersMethodgetCurrentGlueTableColumn
( String tableFormat, String colName, String colType, Integer fieldId, boolean isNullable)
xtable-aws/src/test/java/org/apache/xtable/glue/TestGlueSchemaExtractor.java:103
↓ 29 callersMethodof
(Map<String, String> properties)
xtable-hive-metastore/src/main/java/org/apache/xtable/hms/HMSCatalogConfig.java:57
↓ 29 callersMethodtable
(CLIENT tableServiceClient)
xtable-api/src/main/java/org/apache/xtable/spi/extractor/TableExtractor.java:29
↓ 28 callersMethodtoInternalSchema
(Schema schema)
xtable-core/src/main/java/org/apache/xtable/avro/AvroSchemaConverter.java:76
↓ 26 callersMethodgetDataFile
(int index, List<PartitionValue> partitionValues)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSync.java:792
↓ 26 callersMethodgetInstance
()
xtable-api/src/main/java/org/apache/xtable/spi/sync/TableFormatSync.java:53
↓ 26 callersMethodgetTableFormat
Returns the TableFormat name the client syncs to
xtable-api/src/main/java/org/apache/xtable/spi/sync/ConversionTarget.java:91
↓ 26 callersMethodmockColStatsForFile
(InternalDataFile dataFile, int times)
xtable-core/src/test/java/org/apache/xtable/iceberg/TestIcebergSync.java:865
↓ 26 callersMethodsyncSnapshot
( Map<String, ConversionTarget> conversionTargetByFormat, ExtractFromSource<COMMIT> source)
xtable-core/src/main/java/org/apache/xtable/conversion/ConversionController.java:279
↓ 25 callersMethodof
Creates GlueCatalogConfig from given key-value map
xtable-aws/src/main/java/org/apache/xtable/glue/GlueCatalogConfig.java:81
↓ 24 callersMethodgetId
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 callersMethodgetMetadata
( HoodieInstant instant, HoodieTableMetaClient metaClient)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiConversionTarget.java:334
↓ 24 callersFunctionse
(e,t)
website/static/js/webflow.js:10
↓ 23 callersMethodclose
()
xtable-core/src/test/java/org/apache/xtable/GenericTable.java:63
↓ 23 callersMethodgetCatalogId
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 callersMethodgetSourceTable
Returns the source table object present in the catalog.
xtable-api/src/main/java/org/apache/xtable/spi/extractor/CatalogConversionSource.java:36
↓ 23 callersMethodinit
Initializes the client with provided configuration
xtable-api/src/main/java/org/apache/xtable/spi/sync/ConversionTarget.java:94
↓ 23 callersMethodvalues
()
xtable-api/src/main/java/org/apache/xtable/model/storage/TableFormat.java:31
↓ 22 callersMethodfinalizeSchema
(Schema targetSchema, InternalSchema inputSchema)
xtable-core/src/main/java/org/apache/xtable/avro/AvroSchemaConverter.java:481
↓ 22 callersMethodfromInternalSchema
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 callersMethodfromJson
(String metadata)
xtable-api/src/main/java/org/apache/xtable/model/metadata/TableSyncMetadata.java:91
↓ 22 callersMethodinsertRows
(int numRows)
xtable-core/src/test/java/org/apache/xtable/TestSparkDeltaTable.java:94
↓ 22 callersMethodsyncPartitions
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 callersMethodgetFieldSchema
(String name, String type)
xtable-hive-metastore/src/test/java/org/apache/xtable/hms/TestHMSSchemaExtractor.java:42
↓ 21 callersMethodnext
()
xtable-core/src/main/java/org/apache/xtable/delta/DeltaDataFileExtractor.java:95
↓ 21 callersMethodparseFromInstantTime
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 callersMethodsnapshot
(CLIENT tableServiceClient)
xtable-api/src/main/java/org/apache/xtable/spi/extractor/SnapshotExtractor.java:31
↓ 20 callersMethodaddIdTracking
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 callersMethodgetColumnStats
()
xtable-core/src/test/java/org/apache/xtable/testutil/ColumnStatMapUtil.java:225
↓ 20 callersMethodgetInstance
()
xtable-aws/src/main/java/org/apache/xtable/glue/GlueSchemaExtractor.java:59
↓ 20 callersMethodgetUpdateTableRequest
( InternalTable table, TABLE catalogTable, CatalogTableIdentifier tableIdentifier)
xtable-core/src/main/java/org/apache/xtable/catalog/CatalogTableBuilder.java:31
↓ 20 callersFunctioni
(l,h,y)
website/static/js/webflow.js:10
↓ 20 callersMethodstartCommit
()
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:251
↓ 20 callersFunctiont
(l,h)
website/static/js/webflow.js:10
↓ 19 callersMethodgenerateRecords
(int numRecords)
xtable-core/src/test/java/org/apache/xtable/TestAbstractHudiTable.java:216
↓ 19 callersMethodgetDataFile
( int index, List<PartitionValue> partitionValues, Path basePath)
xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaSync.java:543
↓ 19 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/avro/AvroSchemaConverter.java:72
↓ 19 callersMethodgetStorageLocation
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 callersFunctionr
(l)
website/static/js/webflow.js:10
↓ 18 callersMethodgetAllActiveFiles
()
xtable-core/src/test/java/org/apache/xtable/TestIcebergTable.java:326
↓ 18 callersMethodgetColumn
(String name, String type)
xtable-aws/src/test/java/org/apache/xtable/glue/TestGlueSchemaExtractor.java:95
↓ 18 callersMethodgetTestFile
(String partitionPath, String fileName)
xtable-core/src/test/java/org/apache/xtable/hudi/ITHudiConversionTarget.java:675
↓ 17 callersMethodforStandardSchema
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 callersMethodgetTableProperties
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 callersMethoditerator
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 callersMethodvalidateSnapshot
( InternalSnapshot internalSnapshot, List<String> allActivePaths)
xtable-core/src/test/java/org/apache/xtable/ValidationTestHelper.java:36
↓ 16 callersFunctionc
(l,h,y)
website/static/js/webflow.js:10
↓ 16 callersMethodgetFilesDiff
(int id)
xtable-api/src/test/java/org/apache/xtable/spi/sync/TestTableFormatSync.java:458
↓ 16 callersMethodhasNext
()
xtable-core/src/main/java/org/apache/xtable/delta/DeltaDataFileExtractor.java:90
↓ 15 callersMethodextractPartitionValues
( List<InternalPartitionField> partitionColumns, String partitionPath)
xtable-core/src/main/java/org/apache/xtable/hudi/HudiPartitionValuesExtractor.java:47
↓ 15 callersMethodfindFieldByPath
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 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergPartitionSpecExtractor.java:53
↓ 15 callersMethodgetInstance
()
xtable-core/src/main/java/org/apache/xtable/schema/SchemaFieldFinder.java:35
↓ 15 callersMethodgetSchemaWithFields
(List<String> fields)
xtable-core/src/test/java/org/apache/xtable/delta/TestDeltaPartitionExtractor.java:539
↓ 15 callersMethodgetTableSyncConfig
( String sourceTableFormat, SyncMode syncMode, String tableName, GenericTable table,
xtable-core/src/test/java/org/apache/xtable/ITConversionController.java:1046
↓ 15 callersFunctiono
()
website/static/js/webflow.js:10
↓ 15 callersMethodtoColumns
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 callersMethodtoColumns
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 callersMethodvalidateTableChanges
( List<List<String>> allActiveFiles, List<TableChange> allTableChanges)
xtable-core/src/test/java/org/apache/xtable/ValidationTestHelper.java:52
↓ 14 callersMethodcreateForFormat
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 callersMethodcreateRecord
( Long longValue, String stringValue, Integer nestedIntValue, List<Integer> listValues
xtable-core/src/test/java/org/apache/xtable/hudi/TestHudiFileStatsExtractor.java:417
↓ 14 callersMethodinsertRecordsWithCommitAlreadyStarted
( 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