Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/paimon-trino
/ functions
Functions
631 in github.com/apache/paimon-trino
⨍
Functions
631
◇
Types & classes
71
Method
alterFunction
( Identifier identifier, List<FunctionChange> changes, boolean ignoreIfNotExists)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:322
Method
alterPartitions
(Identifier identifier, List<PartitionStatistics> partitions)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:294
Method
analyze
( ConnectorSession session, ConnectorTransactionHandle transaction, Map<St
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:120
Method
appendPage
(Page page)
src/main/java/org/apache/paimon/trino/TrinoPageSink.java:47
Method
applyFilter
( ConnectorSession session, ConnectorTableHandle handle, Constraint constraint)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:670
Method
applyLimit
( ConnectorSession session, ConnectorTableHandle handle, long limit)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:726
Method
applyProjection
( ConnectorSession session, ConnectorTableHandle handle, List<ConnectorExp
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:690
Method
authTableQuery
(Identifier identifier, @Nullable List<String> select)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:331
Method
available
()
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:94
Method
beginCreateTable
( ConnectorSession session, ConnectorTableMetadata tableMetadata, Optional
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:143
Method
beginInsert
( ConnectorSession session, ConnectorTableHandle tableHandle, List<ColumnH
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:169
Method
beginMerge
( ConnectorSession session, ConnectorTableHandle tableHandle, Map<Integer,
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:269
Method
beginTransaction
( IsolationLevel isolationLevel, boolean readOnly, boolean autoCommit)
src/main/java/org/apache/paimon/trino/TrinoConnector.java:82
Method
caseSensitive
()
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:106
Method
catalogLoader
()
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:342
Method
close
()
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:61
Method
close
()
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:107
Method
close
()
src/main/java/org/apache/paimon/trino/TrinoOrcDataSource.java:41
Method
close
()
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:92
Method
close
()
src/main/java/org/apache/paimon/trino/fileio/PositionOutputStreamWrapper.java:70
Method
close
()
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:59
Method
close
()
src/main/java/org/apache/paimon/trino/fileio/BufferedSeekableInputStream.java:148
Method
close
()
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:347
Method
commitSnapshot
( Identifier identifier, @Nullable String tableUuid, Snapshot snapshot,
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:227
Method
configure
(Binder binder)
src/main/java/org/apache/paimon/trino/TrinoModule.java:45
Method
configure
(Binder binder)
src/main/java/org/apache/paimon/trino/TrinoConnectorFactory.java:186
Method
configure
(CatalogContext catalogContext)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:58
Method
createBranch
(Identifier identifier, String branch, @Nullable String fromTag)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:261
Method
createFunction
(Identifier identifier, Function function, boolean ignoreIfExists)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:310
Method
createMergeSink
( ConnectorTransactionHandle transactionHandle, ConnectorSession session,
src/main/java/org/apache/paimon/trino/TrinoPageSinkProvider.java:107
Method
createPartitions
(Identifier identifier, List<Map<String, String>> partitions)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:282
Method
createQueryRunner
()
src/test/java/org/apache/paimon/trino/TrinoITCase.java:82
Method
createQueryRunner
()
src/test/java/org/apache/paimon/trino/TrinoDistributedQueryTest.java:29
Method
createSchema
( ConnectorSession session, String schemaName, Map<String, Object> propert
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:305
Method
createTable
(Identifier identifier, Schema schema, boolean ignoreIfExists)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:184
Method
defaultMethod
(DataType logicalType)
src/main/java/org/apache/paimon/trino/TrinoTypeUtils.java:212
Method
delete
(Path path, boolean recursive)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:145
Method
dropBranch
(Identifier identifier, String branch)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:267
Method
dropFunction
(Identifier identifier, boolean ignoreIfNotExists)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:316
Method
dropPartitions
(Identifier identifier, List<Map<String, String>> partitions)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:288
Method
dropSchema
(ConnectorSession session, String schemaName, boolean cascade)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:323
Method
dropTable
(ConnectorSession session, ConnectorTableHandle tableHandle)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:559
Method
dropTable
(Identifier identifier, boolean b)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:180
Method
equals
(Object o)
src/main/java/org/apache/paimon/trino/TrinoPartitioningHandle.java:54
Method
fastForward
(Identifier identifier, String branch)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:272
Method
finish
()
src/main/java/org/apache/paimon/trino/TrinoMergeSink.java:108
Method
finish
()
src/main/java/org/apache/paimon/trino/TrinoPageSink.java:67
Method
finishCreateTable
( ConnectorSession session, ConnectorOutputTableHandle tableHandle, Collec
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:157
Method
finishInsert
( ConnectorSession session, ConnectorInsertTableHandle insertHandle, List<
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:178
Method
finishMerge
( ConnectorSession session, ConnectorMergeTableHandle mergeTableHandle, Li
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:278
Method
flush
()
src/main/java/org/apache/paimon/trino/fileio/PositionOutputStreamWrapper.java:65
Method
getAddresses
()
src/main/java/org/apache/paimon/trino/TrinoSplit.java:71
Method
getArray
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:175
Method
getBucket
(Page page, int position)
src/main/java/org/apache/paimon/trino/FixedBucketTableShuffleFunction.java:81
Method
getBucketFunction
( ConnectorTransactionHandle transactionHandle, ConnectorSession session,
src/main/java/org/apache/paimon/trino/TrinoNodePartitioningProvider.java:37
Method
getColumnHandles
( ConnectorSession session, ConnectorTableHandle tableHandle)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:574
Method
getColumnMetadata
()
src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:83
Method
getColumnMetadata
( ConnectorSession session, ConnectorTableHandle tableHandle, ColumnHandle columnHandle)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:585
Method
getCompletedBytes
()
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:47
Method
getCompletedBytes
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:120
Method
getCompletedBytes
()
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:47
Method
getDynamicOptions
()
src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:102
Method
getFieldCount
()
src/main/java/org/apache/paimon/trino/TrinoRow.java:66
Method
getFileStatus
(Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:84
Method
getFunction
(Identifier identifier)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:305
Method
getFunctionProvider
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:130
Method
getInsertLayout
( ConnectorSession session, ConnectorTableHandle tableHandle)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:114
Method
getLen
()
src/main/java/org/apache/paimon/trino/fileio/TrinoFileStatus.java:37
Method
getLen
()
src/main/java/org/apache/paimon/trino/fileio/TrinoDirectoryFileStatus.java:33
Method
getMap
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:182
Method
getMemoryUsage
()
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:102
Method
getMemoryUsage
()
src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:112
Method
getMemoryUsage
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:148
Method
getMemoryUsage
()
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:87
Method
getMergeRowIdColumnHandle
( ConnectorSession session, ConnectorTableHandle tableHandle)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:225
Method
getMetadata
( ConnectorSession session, ConnectorTransactionHandle transactionHandle)
src/main/java/org/apache/paimon/trino/TrinoConnector.java:89
Method
getMetrics
()
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:117
Method
getMetrics
()
src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:117
Method
getModificationTime
()
src/main/java/org/apache/paimon/trino/fileio/TrinoFileStatus.java:52
Method
getModificationTime
()
src/main/java/org/apache/paimon/trino/fileio/TrinoDirectoryFileStatus.java:49
Method
getNextBatch
(int maxSize)
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:56
Method
getNextPage
()
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:67
Method
getNextPage
()
src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:58
Method
getNextPage
()
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:62
Method
getNodePartitioningProvider
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:120
Method
getPageSinkProvider
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:105
Method
getPageSourceProvider
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:100
Method
getPath
()
src/main/java/org/apache/paimon/trino/fileio/TrinoFileStatus.java:47
Method
getPath
()
src/main/java/org/apache/paimon/trino/fileio/TrinoDirectoryFileStatus.java:44
Method
getPos
()
src/main/java/org/apache/paimon/trino/fileio/PositionOutputStreamWrapper.java:42
Method
getPos
()
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:44
Method
getPos
()
src/main/java/org/apache/paimon/trino/fileio/BufferedSeekableInputStream.java:64
Method
getReadTimeNanos
()
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:57
Method
getReadTimeNanos
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:125
Method
getReadTimeNanos
()
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:52
Method
getRow
(int i, int i1)
src/main/java/org/apache/paimon/trino/TrinoRow.java:188
Method
getRowChangeParadigm
( ConnectorSession session, ConnectorTableHandle tableHandle)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:218
Method
getSessionProperties
()
src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:78
Method
getSplitInfo
()
src/main/java/org/apache/paimon/trino/TrinoSplit.java:76
Method
getSplitManager
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:95
← previous
next →
201–300 of 631, ranked by callers