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
↓ 1 callers
Method
getNextPage
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:135
↓ 1 callers
Method
getOriginalSchema
()
src/main/java/org/apache/paimon/trino/TrinoPartitioningHandle.java:46
↓ 1 callers
Method
getPartitionedKeys
(Map<String, Object> tableProperties)
src/main/java/org/apache/paimon/trino/TrinoTableOptions.java:90
↓ 1 callers
Method
getPrimaryKeys
(Map<String, Object> tableProperties)
src/main/java/org/apache/paimon/trino/TrinoTableOptions.java:84
↓ 1 callers
Method
getReadTimeNanos
()
src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:48
↓ 1 callers
Method
getRemainFilter
()
src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:238
↓ 1 callers
Method
getRowKind
()
src/main/java/org/apache/paimon/trino/TrinoRow.java:71
↓ 1 callers
Method
getScanSnapshotId
(ConnectorSession session)
src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:86
↓ 1 callers
Method
getScanTimestampMillis
(ConnectorSession session)
src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:82
↓ 1 callers
Method
getSchemaName
(Map<String, Argument> arguments)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:192
↓ 1 callers
Method
getScheme
()
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIOLoader.java:36
↓ 1 callers
Method
getSerializedTable
()
src/test/java/org/apache/paimon/trino/TrinoTestUtils.java:48
↓ 1 callers
Method
getSessionProperties
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:110
↓ 1 callers
Method
getShort
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:96
↓ 1 callers
Method
getString
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:139
↓ 1 callers
Method
getTableName
(Map<String, Argument> arguments)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:204
↓ 1 callers
Method
getTableProperties
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:115
↓ 1 callers
Method
getTimestamp
(int i, int timestampPrecision)
src/main/java/org/apache/paimon/trino/TrinoRow.java:163
↓ 1 callers
Method
handleAndArguments
Expression filter support the case of "AND" and "IN".
src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:125
↓ 1 callers
Method
handleElementAtArguments
Using paimon, trino only supports element_at function to extract values from map type.
src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:203
↓ 1 callers
Method
innerGetNextBatch
(int maxSize)
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:43
↓ 1 callers
Method
isConfigOption
(Field field)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:151
↓ 1 callers
Method
isEnum
(String className)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:94
↓ 1 callers
Method
isFinished
()
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:64
↓ 1 callers
Method
isFinished
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:130
↓ 1 callers
Method
isNullAt
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:81
↓ 1 callers
Method
listDatabases
()
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:111
↓ 1 callers
Method
listDirectories
(Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:124
↓ 1 callers
Method
listTables
(ConnectorSession session, Optional<String> schemaName)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:479
↓ 1 callers
Method
logicalType
()
src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:79
↓ 1 callers
Method
newFileSystemModule
( String catalogName, ConnectorContext context)
src/main/java/org/apache/paimon/trino/TrinoConnectorFactory.java:190
↓ 1 callers
Method
nextPage
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:153
↓ 1 callers
Method
orderDomains
( List<String> projectedFields, TupleDomain<TrinoColumnHandle> filter)
src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:306
↓ 1 callers
Method
prepareSchema
(ConnectorTableMetadata tableMetadata)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:519
↓ 1 callers
Method
read
()
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:49
↓ 1 callers
Method
read
()
src/main/java/org/apache/paimon/trino/fileio/BufferedSeekableInputStream.java:83
↓ 1 callers
Method
readHadoopXml
(String path, Map<String, String> config)
src/main/java/org/apache/paimon/trino/TrinoConnectorFactory.java:158
↓ 1 callers
Method
reset
()
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:104
↓ 1 callers
Method
schemaEvolutionFieldNames
( List<String> fieldNames, List<DataField> tableFields, List<DataField> dataFields)
src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:336
↓ 1 callers
Method
shouldSkip
(String fieldName)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:82
↓ 1 callers
Method
status
(Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:89
↓ 1 callers
Method
tableMetadata
(TrinoCatalog catalog)
src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:151
↓ 1 callers
Method
testRoundTrip
(TrinoPartitioningHandle expected)
src/test/java/org/apache/paimon/trino/TrinoPartitioningHandleTest.java:41
↓ 1 callers
Method
testRoundTrip
(TrinoTableHandle expected)
src/test/java/org/apache/paimon/trino/TrinoTableHandleTest.java:49
↓ 1 callers
Method
testRoundTrip
(TrinoColumnHandle expected)
src/test/java/org/apache/paimon/trino/TrinoColumnHandleTest.java:43
↓ 1 callers
Method
toBigInteger
(Object value)
src/main/java/org/apache/paimon/trino/DecimalUtils.java:28
↓ 1 callers
Method
toPredicate
(int columnIndex, String field, Type type, Domain domain)
src/main/java/org/apache/paimon/trino/TrinoFilterConverter.java:140
↓ 1 callers
Method
validataBucketMode
(Table table)
src/main/java/org/apache/paimon/trino/TrinoPageSinkProvider.java:93
↓ 1 callers
Method
visit
(CharType charType)
src/main/java/org/apache/paimon/trino/TrinoTypeUtils.java:77
↓ 1 callers
Method
wrap
( ConnectorPageSource connectorPageSource, Optional<DeletionVector> deletionVector)
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:122
↓ 1 callers
Method
wrap
( ConnectorPageSource pageSource, HashMap<String, Integer> fieldToIndex)
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:42
↓ 1 callers
Method
write
(int b)
src/main/java/org/apache/paimon/trino/fileio/PositionOutputStreamWrapper.java:47
↓ 1 callers
Method
writeBlock
(BlockBuilder output, Type type, DataType logicalType, Object value)
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:301
↓ 1 callers
Method
writeSlice
(BlockBuilder output, Type type, Object value)
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:278
Method
BufferedSeekableInputStream
(SeekableInputStream in)
src/main/java/org/apache/paimon/trino/fileio/BufferedSeekableInputStream.java:52
Method
DirectTrinoPageSource
(LinkedList<ConnectorPageSource> pageSourceQueue)
src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:38
Method
FixedBucketTableShuffleFunction
( List<Type> partitionChannelTypes, TrinoPartitioningHandle partitioningHandle,
src/main/java/org/apache/paimon/trino/FixedBucketTableShuffleFunction.java:48
Method
OptionInfo
( String trinoOptionKey, String paimonOptionKey, Class<T> claz
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:172
Method
OptionWithMetaInfo
(ConfigOption<?> option, Field field)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:159
Method
PositionOutputStreamWrapper
(OutputStream outputStream)
src/main/java/org/apache/paimon/trino/fileio/PositionOutputStreamWrapper.java:33
Method
SimpleTableTestHelper
(Path path, RowType rowType)
src/test/java/org/apache/paimon/trino/SimpleTableTestHelper.java:41
Method
TableChangesFunction
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:82
Method
TableChangesFunctionProcessor
( ConnectorSession session, TrinoTableHandle handle, TrinoSplit split,
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunctionProcessor.java:42
Method
TableChangesFunctionProcessorProvider
( TrinoPageSourceProvider icebergPageSourceProvider)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunctionProcessorProvider.java:38
Method
TableChangesFunctionProvider
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunctionProvider.java:34
Method
TrinoCatalog
( Options options, Configuration configuration, TrinoFileSystemFactory tri
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:68
Method
TrinoColumnHandle
( @JsonProperty("columnName") String columnName, @JsonProperty("typeString") String ty
src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:41
Method
TrinoConnector
( ConnectorMetadata trinoMetadata, ConnectorSplitManager trinoSplitManager,
src/main/java/org/apache/paimon/trino/TrinoConnector.java:56
Method
TrinoDirectoryFileStatus
(Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoDirectoryFileStatus.java:29
Method
TrinoFileIO
(TrinoFileSystem trinoFileSystem, @Nullable Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:48
Method
TrinoFileIOLoader
(TrinoFileSystem trinoFileSystem)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIOLoader.java:32
Method
TrinoFileStatus
(long len, Path path, long modificationTmie)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileStatus.java:31
Method
TrinoFilter
( TupleDomain<TrinoColumnHandle> filter, TupleDomain<ColumnHandle> remainFilter)
src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:228
Method
TrinoFilterConverter
(RowType rowType)
src/main/java/org/apache/paimon/trino/TrinoFilterConverter.java:79
Method
TrinoFunctionProvider
( TableChangesFunctionProcessorProvider tableChangesFunctionProcessorProvider)
src/main/java/org/apache/paimon/trino/functions/TrinoFunctionProvider.java:35
Method
TrinoInputStreamWrapper
(TrinoInputStream trinoInputStream)
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:35
Method
TrinoMergePageSourceWrapper
( ConnectorPageSource pageSource, HashMap<String, Integer> fieldToIndex)
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:36
Method
TrinoMergeSink
(ConnectorPageSink pageSink, int dataColumnCount)
src/main/java/org/apache/paimon/trino/TrinoMergeSink.java:41
Method
TrinoMergeTableHandle
(@JsonProperty("tableHandle") TrinoTableHandle tableHandle)
src/main/java/org/apache/paimon/trino/TrinoMergeTableHandle.java:31
Method
TrinoMetadata
(TrinoCatalog catalog)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:106
Method
TrinoMetadataFactory
(Options options, TrinoFileSystemFactory fileSystemFactory)
src/main/java/org/apache/paimon/trino/TrinoMetadataFactory.java:36
Method
TrinoModule
(Map<String, String> config)
src/main/java/org/apache/paimon/trino/TrinoModule.java:41
Method
TrinoNodePartitioningProvider
()
src/main/java/org/apache/paimon/trino/TrinoNodePartitioningProvider.java:34
Method
TrinoOrcDataSource
(TrinoInputFile file, OrcReaderOptions options)
src/main/java/org/apache/paimon/trino/TrinoOrcDataSource.java:36
Method
TrinoPageSink
(BatchTableWrite writer)
src/main/java/org/apache/paimon/trino/TrinoPageSink.java:43
Method
TrinoPageSinkProvider
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/TrinoPageSinkProvider.java:48
Method
TrinoPageSource
( RecordReader<InternalRow> reader, List<ColumnHandle> projectedColumns, O
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:103
Method
TrinoPageSourceProvider
( TrinoFileSystemFactory fileSystemFactory, TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:88
Method
TrinoPageSourceWrapper
( ConnectorPageSource source, Optional<DeletionVector> deletionVector)
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:41
Method
TrinoPartitioningHandle
(@JsonProperty("schema") byte[] schema)
src/main/java/org/apache/paimon/trino/TrinoPartitioningHandle.java:36
Method
TrinoQueryRunner
()
src/test/java/org/apache/paimon/trino/TrinoQueryRunner.java:41
Method
TrinoRow
(Page singlePage, RowKind rowKind)
src/main/java/org/apache/paimon/trino/TrinoRow.java:60
Method
TrinoSessionProperties
()
src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:45
Method
TrinoSplit
( @JsonProperty("splitSerialized") String splitSerialized, @JsonProperty("weight") Dou
src/main/java/org/apache/paimon/trino/TrinoSplit.java:40
Method
TrinoSplitManager
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/TrinoSplitManager.java:46
Method
TrinoSplitSource
(List<TrinoSplit> splits, OptionalLong limit)
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:38
Method
TrinoTableHandle
( String schemaName, String tableName, Map<String, String> dynamicOptions)
src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:65
Method
TrinoTableOptions
()
src/main/java/org/apache/paimon/trino/TrinoTableOptions.java:41
Method
abort
()
src/main/java/org/apache/paimon/trino/TrinoPageSink.java:88
Method
alterDatabase
(String s, List<PropertyChange> list, boolean b)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:140
← previous
next →
101–200 of 631, ranked by callers