MCPcopy Create free account

hub / github.com/apache/paimon-trino / functions

Functions631 in github.com/apache/paimon-trino

↓ 1 callersMethodgetNextPage
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:135
↓ 1 callersMethodgetOriginalSchema
()
src/main/java/org/apache/paimon/trino/TrinoPartitioningHandle.java:46
↓ 1 callersMethodgetPartitionedKeys
(Map<String, Object> tableProperties)
src/main/java/org/apache/paimon/trino/TrinoTableOptions.java:90
↓ 1 callersMethodgetPrimaryKeys
(Map<String, Object> tableProperties)
src/main/java/org/apache/paimon/trino/TrinoTableOptions.java:84
↓ 1 callersMethodgetReadTimeNanos
()
src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:48
↓ 1 callersMethodgetRemainFilter
()
src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:238
↓ 1 callersMethodgetRowKind
()
src/main/java/org/apache/paimon/trino/TrinoRow.java:71
↓ 1 callersMethodgetScanSnapshotId
(ConnectorSession session)
src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:86
↓ 1 callersMethodgetScanTimestampMillis
(ConnectorSession session)
src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:82
↓ 1 callersMethodgetSchemaName
(Map<String, Argument> arguments)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:192
↓ 1 callersMethodgetScheme
()
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIOLoader.java:36
↓ 1 callersMethodgetSerializedTable
()
src/test/java/org/apache/paimon/trino/TrinoTestUtils.java:48
↓ 1 callersMethodgetSessionProperties
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:110
↓ 1 callersMethodgetShort
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:96
↓ 1 callersMethodgetString
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:139
↓ 1 callersMethodgetTableName
(Map<String, Argument> arguments)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:204
↓ 1 callersMethodgetTableProperties
()
src/main/java/org/apache/paimon/trino/TrinoConnector.java:115
↓ 1 callersMethodgetTimestamp
(int i, int timestampPrecision)
src/main/java/org/apache/paimon/trino/TrinoRow.java:163
↓ 1 callersMethodhandleAndArguments
Expression filter support the case of "AND" and "IN".
src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:125
↓ 1 callersMethodhandleElementAtArguments
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 callersMethodinnerGetNextBatch
(int maxSize)
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:43
↓ 1 callersMethodisConfigOption
(Field field)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:151
↓ 1 callersMethodisEnum
(String className)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:94
↓ 1 callersMethodisFinished
()
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:64
↓ 1 callersMethodisFinished
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:130
↓ 1 callersMethodisNullAt
(int i)
src/main/java/org/apache/paimon/trino/TrinoRow.java:81
↓ 1 callersMethodlistDatabases
()
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:111
↓ 1 callersMethodlistDirectories
(Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:124
↓ 1 callersMethodlistTables
(ConnectorSession session, Optional<String> schemaName)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:479
↓ 1 callersMethodlogicalType
()
src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:79
↓ 1 callersMethodnewFileSystemModule
( String catalogName, ConnectorContext context)
src/main/java/org/apache/paimon/trino/TrinoConnectorFactory.java:190
↓ 1 callersMethodnextPage
()
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:153
↓ 1 callersMethodorderDomains
( List<String> projectedFields, TupleDomain<TrinoColumnHandle> filter)
src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:306
↓ 1 callersMethodprepareSchema
(ConnectorTableMetadata tableMetadata)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:519
↓ 1 callersMethodread
()
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:49
↓ 1 callersMethodread
()
src/main/java/org/apache/paimon/trino/fileio/BufferedSeekableInputStream.java:83
↓ 1 callersMethodreadHadoopXml
(String path, Map<String, String> config)
src/main/java/org/apache/paimon/trino/TrinoConnectorFactory.java:158
↓ 1 callersMethodreset
()
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:104
↓ 1 callersMethodschemaEvolutionFieldNames
( List<String> fieldNames, List<DataField> tableFields, List<DataField> dataFields)
src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:336
↓ 1 callersMethodshouldSkip
(String fieldName)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:82
↓ 1 callersMethodstatus
(Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:89
↓ 1 callersMethodtableMetadata
(TrinoCatalog catalog)
src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:151
↓ 1 callersMethodtestRoundTrip
(TrinoPartitioningHandle expected)
src/test/java/org/apache/paimon/trino/TrinoPartitioningHandleTest.java:41
↓ 1 callersMethodtestRoundTrip
(TrinoTableHandle expected)
src/test/java/org/apache/paimon/trino/TrinoTableHandleTest.java:49
↓ 1 callersMethodtestRoundTrip
(TrinoColumnHandle expected)
src/test/java/org/apache/paimon/trino/TrinoColumnHandleTest.java:43
↓ 1 callersMethodtoBigInteger
(Object value)
src/main/java/org/apache/paimon/trino/DecimalUtils.java:28
↓ 1 callersMethodtoPredicate
(int columnIndex, String field, Type type, Domain domain)
src/main/java/org/apache/paimon/trino/TrinoFilterConverter.java:140
↓ 1 callersMethodvalidataBucketMode
(Table table)
src/main/java/org/apache/paimon/trino/TrinoPageSinkProvider.java:93
↓ 1 callersMethodvisit
(CharType charType)
src/main/java/org/apache/paimon/trino/TrinoTypeUtils.java:77
↓ 1 callersMethodwrap
( ConnectorPageSource connectorPageSource, Optional<DeletionVector> deletionVector)
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:122
↓ 1 callersMethodwrap
( ConnectorPageSource pageSource, HashMap<String, Integer> fieldToIndex)
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:42
↓ 1 callersMethodwrite
(int b)
src/main/java/org/apache/paimon/trino/fileio/PositionOutputStreamWrapper.java:47
↓ 1 callersMethodwriteBlock
(BlockBuilder output, Type type, DataType logicalType, Object value)
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:301
↓ 1 callersMethodwriteSlice
(BlockBuilder output, Type type, Object value)
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:278
MethodBufferedSeekableInputStream
(SeekableInputStream in)
src/main/java/org/apache/paimon/trino/fileio/BufferedSeekableInputStream.java:52
MethodDirectTrinoPageSource
(LinkedList<ConnectorPageSource> pageSourceQueue)
src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:38
MethodFixedBucketTableShuffleFunction
( List<Type> partitionChannelTypes, TrinoPartitioningHandle partitioningHandle,
src/main/java/org/apache/paimon/trino/FixedBucketTableShuffleFunction.java:48
MethodOptionInfo
( String trinoOptionKey, String paimonOptionKey, Class<T> claz
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:172
MethodOptionWithMetaInfo
(ConfigOption<?> option, Field field)
src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:159
MethodPositionOutputStreamWrapper
(OutputStream outputStream)
src/main/java/org/apache/paimon/trino/fileio/PositionOutputStreamWrapper.java:33
MethodSimpleTableTestHelper
(Path path, RowType rowType)
src/test/java/org/apache/paimon/trino/SimpleTableTestHelper.java:41
MethodTableChangesFunction
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:82
MethodTableChangesFunctionProcessor
( ConnectorSession session, TrinoTableHandle handle, TrinoSplit split,
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunctionProcessor.java:42
MethodTableChangesFunctionProcessorProvider
( TrinoPageSourceProvider icebergPageSourceProvider)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunctionProcessorProvider.java:38
MethodTableChangesFunctionProvider
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunctionProvider.java:34
MethodTrinoCatalog
( Options options, Configuration configuration, TrinoFileSystemFactory tri
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:68
MethodTrinoColumnHandle
( @JsonProperty("columnName") String columnName, @JsonProperty("typeString") String ty
src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:41
MethodTrinoConnector
( ConnectorMetadata trinoMetadata, ConnectorSplitManager trinoSplitManager,
src/main/java/org/apache/paimon/trino/TrinoConnector.java:56
MethodTrinoDirectoryFileStatus
(Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoDirectoryFileStatus.java:29
MethodTrinoFileIO
(TrinoFileSystem trinoFileSystem, @Nullable Path path)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:48
MethodTrinoFileIOLoader
(TrinoFileSystem trinoFileSystem)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileIOLoader.java:32
MethodTrinoFileStatus
(long len, Path path, long modificationTmie)
src/main/java/org/apache/paimon/trino/fileio/TrinoFileStatus.java:31
MethodTrinoFilter
( TupleDomain<TrinoColumnHandle> filter, TupleDomain<ColumnHandle> remainFilter)
src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:228
MethodTrinoFilterConverter
(RowType rowType)
src/main/java/org/apache/paimon/trino/TrinoFilterConverter.java:79
MethodTrinoFunctionProvider
( TableChangesFunctionProcessorProvider tableChangesFunctionProcessorProvider)
src/main/java/org/apache/paimon/trino/functions/TrinoFunctionProvider.java:35
MethodTrinoInputStreamWrapper
(TrinoInputStream trinoInputStream)
src/main/java/org/apache/paimon/trino/fileio/TrinoInputStreamWrapper.java:35
MethodTrinoMergePageSourceWrapper
( ConnectorPageSource pageSource, HashMap<String, Integer> fieldToIndex)
src/main/java/org/apache/paimon/trino/TrinoMergePageSourceWrapper.java:36
MethodTrinoMergeSink
(ConnectorPageSink pageSink, int dataColumnCount)
src/main/java/org/apache/paimon/trino/TrinoMergeSink.java:41
MethodTrinoMergeTableHandle
(@JsonProperty("tableHandle") TrinoTableHandle tableHandle)
src/main/java/org/apache/paimon/trino/TrinoMergeTableHandle.java:31
MethodTrinoMetadata
(TrinoCatalog catalog)
src/main/java/org/apache/paimon/trino/TrinoMetadata.java:106
MethodTrinoMetadataFactory
(Options options, TrinoFileSystemFactory fileSystemFactory)
src/main/java/org/apache/paimon/trino/TrinoMetadataFactory.java:36
MethodTrinoModule
(Map<String, String> config)
src/main/java/org/apache/paimon/trino/TrinoModule.java:41
MethodTrinoNodePartitioningProvider
()
src/main/java/org/apache/paimon/trino/TrinoNodePartitioningProvider.java:34
MethodTrinoOrcDataSource
(TrinoInputFile file, OrcReaderOptions options)
src/main/java/org/apache/paimon/trino/TrinoOrcDataSource.java:36
MethodTrinoPageSink
(BatchTableWrite writer)
src/main/java/org/apache/paimon/trino/TrinoPageSink.java:43
MethodTrinoPageSinkProvider
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/TrinoPageSinkProvider.java:48
MethodTrinoPageSource
( RecordReader<InternalRow> reader, List<ColumnHandle> projectedColumns, O
src/main/java/org/apache/paimon/trino/TrinoPageSource.java:103
MethodTrinoPageSourceProvider
( TrinoFileSystemFactory fileSystemFactory, TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:88
MethodTrinoPageSourceWrapper
( ConnectorPageSource source, Optional<DeletionVector> deletionVector)
src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:41
MethodTrinoPartitioningHandle
(@JsonProperty("schema") byte[] schema)
src/main/java/org/apache/paimon/trino/TrinoPartitioningHandle.java:36
MethodTrinoQueryRunner
()
src/test/java/org/apache/paimon/trino/TrinoQueryRunner.java:41
MethodTrinoRow
(Page singlePage, RowKind rowKind)
src/main/java/org/apache/paimon/trino/TrinoRow.java:60
MethodTrinoSessionProperties
()
src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:45
MethodTrinoSplit
( @JsonProperty("splitSerialized") String splitSerialized, @JsonProperty("weight") Dou
src/main/java/org/apache/paimon/trino/TrinoSplit.java:40
MethodTrinoSplitManager
(TrinoMetadataFactory trinoMetadataFactory)
src/main/java/org/apache/paimon/trino/TrinoSplitManager.java:46
MethodTrinoSplitSource
(List<TrinoSplit> splits, OptionalLong limit)
src/main/java/org/apache/paimon/trino/TrinoSplitSource.java:38
MethodTrinoTableHandle
( String schemaName, String tableName, Map<String, String> dynamicOptions)
src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:65
MethodTrinoTableOptions
()
src/main/java/org/apache/paimon/trino/TrinoTableOptions.java:41
Methodabort
()
src/main/java/org/apache/paimon/trino/TrinoPageSink.java:88
MethodalterDatabase
(String s, List<PropertyChange> list, boolean b)
src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:140
← previousnext →101–200 of 631, ranked by callers