Functions — github.com/apache/paimon-trino

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

Functions631 in github.com/apache/paimon-trino

⨍ Functions 631◇ Types & classes 71

↓ 106 callersMethodof

(String columnName, DataType columnType)

src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:52

↓ 77 callersMethodget

()

src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunctionProvider.java:40

↓ 68 callersMethodsql

(String sql)

src/test/java/org/apache/paimon/trino/TrinoITCase.java:982

↓ 53 callersMethodcreate

()

src/main/java/org/apache/paimon/trino/TrinoMetadataFactory.java:42

↓ 35 callersMethodtoString

()

src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:105

↓ 33 callersMethodequals

(Object o)

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:200

↓ 25 callersMethodfromPaimonType

(DataType type)

src/main/java/org/apache/paimon/trino/TrinoTypeUtils.java:65

↓ 25 callersMethodwrite

(InternalRow row)

src/test/java/org/apache/paimon/trino/SimpleTableTestHelper.java:57

↓ 24 callersMethodtoPaimonType

(Type trinoType)

src/main/java/org/apache/paimon/trino/TrinoTypeUtils.java:69

↓ 21 callersMethodgetTableName

()

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:97

↓ 19 callersMethodinitSession

(ConnectorSession connectorSession)

src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:77

↓ 18 callersMethodconvert

(TupleDomain<TrinoColumnHandle> tupleDomain)

src/main/java/org/apache/paimon/trino/TrinoFilterConverter.java:84

↓ 15 callersMethodcommit

()

src/test/java/org/apache/paimon/trino/SimpleTableTestHelper.java:61

↓ 14 callersMethodgetSchemaName

()

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:92

↓ 13 callersMethodcreateTable

( ConnectorSession session, ConnectorTableMetadata tableMetadata, SaveMode saveMode)

src/main/java/org/apache/paimon/trino/TrinoMetadata.java:500

↓ 11 callersMethodgetColumnName

()

src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:59

↓ 9 callersMethodtable

(TrinoCatalog catalog)

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:139

↓ 8 callersMethodgetFilter

()

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:107

↓ 8 callersMethodgetName

()

src/main/java/org/apache/paimon/trino/TrinoConnectorFactory.java:68

↓ 8 callersMethodgetTable

(Identifier identifier)

src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:146

↓ 8 callersMethodgetTrinoType

()

src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:69

↓ 6 callersMethodgetLimit

()

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:117

↓ 5 callersMethodappendTo

(Type type, DataType logicalType, Object value, BlockBuilder output)

src/main/java/org/apache/paimon/trino/TrinoPageSource.java:202

↓ 5 callersMethodcopy

(TupleDomain<TrinoColumnHandle> filter)

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:185

↓ 5 callersMethodgetLiteralValue

(Type type, Object trinoNativeValue)

src/main/java/org/apache/paimon/trino/TrinoFilterConverter.java:250

↓ 5 callersMethodgetProjectedColumns

()

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:112

↓ 5 callersMethodtableWithDynamicOptions

(TrinoCatalog catalog, ConnectorSession session)

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:121

↓ 4 callersMethodalterTable

(Identifier identifier, List<SchemaChange> list, boolean ignoreIfExists)

src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:196

↓ 4 callersMethodcatalog

()

src/main/java/org/apache/paimon/trino/TrinoMetadata.java:110

↓ 4 callersMethodconvertOptionKey

(String key)

src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:127

↓ 4 callersMethodgetSchema

()

src/main/java/org/apache/paimon/trino/TrinoPartitioningHandle.java:41

↓ 4 callersMethodgetTableHandle

( ConnectorSession session, SchemaTableName tableName, Optional<ConnectorT

src/main/java/org/apache/paimon/trino/TrinoMetadata.java:338

↓ 4 callersMethodhandleExpressionEqualOrIn

( Map<String, ColumnHandle> assignments, Call expression, boolean inClause)

src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:146

↓ 4 callersMethodrunWithContextClassLoader

(Supplier<T> supplier, ClassLoader classLoader)

src/main/java/org/apache/paimon/trino/ClassLoaderUtils.java:26

↓ 3 callersMethodcolumnMetadatas

(TrinoCatalog catalog)

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:159

↓ 3 callersMethodcommit

( ConnectorSession session, TrinoTableHandle insertHandle, Collection<Slice> fragments)

src/main/java/org/apache/paimon/trino/TrinoMetadata.java:188

↓ 3 callersMethodgetDecimal

(int i, int decimalPrecision, int decimalScale)

src/main/java/org/apache/paimon/trino/TrinoRow.java:144

↓ 3 callersMethodoptions

()

src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:337

↓ 3 callersMethodreturnPage

(int count)

src/main/java/org/apache/paimon/trino/TrinoPageSource.java:183

↓ 3 callersMethodwriteObject

(BlockBuilder output, Type type, Object value)

src/main/java/org/apache/paimon/trino/TrinoPageSource.java:289

↓ 3 callersMethodwritePage

(Page page, RowKind rowKind)

src/main/java/org/apache/paimon/trino/TrinoPageSink.java:57

↓ 2 callersMethodaddColumn

( ConnectorSession session, ConnectorTableHandle tableHandle, ColumnMetada

src/main/java/org/apache/paimon/trino/TrinoMetadata.java:609

↓ 2 callersMethodargumentExists

(Map<String, Argument> arguments, String key)

src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:216

↓ 2 callersMethodcheckNonNull

(Object argumentValue)

src/main/java/org/apache/paimon/trino/functions/tablechanges/TableChangesFunction.java:224

↓ 2 callersMethodclose

()

src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:93

↓ 2 callersMethodclose

()

src/main/java/org/apache/paimon/trino/TrinoPageSource.java:193

↓ 2 callersMethodcreateLegacyPageSource

( Table table, Optional<Predicate> paimonFilter, List<String> fieldNames,

src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:281

↓ 2 callersMethodcreatePrestoQueryRunner

( Map<String, String> extraProperties)

src/test/java/org/apache/paimon/trino/TrinoQueryRunner.java:43

↓ 2 callersMethodcreateTag

(String name)

src/test/java/org/apache/paimon/trino/SimpleTableTestHelper.java:65

↓ 2 callersMethodcreateTestHelper

(Path tablePath)

src/test/java/org/apache/paimon/trino/TrinoITCase.java:597

↓ 2 callersMethoddecodeSplit

()

src/main/java/org/apache/paimon/trino/TrinoSplit.java:52

↓ 2 callersMethodenableInsertOverwrite

(ConnectorSession session)

src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:94

↓ 2 callersMethodexistFile

(Location location)

src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:137

↓ 2 callersMethodexists

(Path path)

src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:131

↓ 2 callersMethodfieldNames

(RowType rowType)

src/main/java/org/apache/paimon/trino/FieldNameUtils.java:30

↓ 2 callersMethodfillBuffer

Refills the internal buffer from the underlying stream. <p>The underlying stream is always positioned at {@code bufferStart + bufferLen} after any op

src/main/java/org/apache/paimon/trino/fileio/BufferedSeekableInputStream.java:138

↓ 2 callersMethodgetBinary

(int i)

src/main/java/org/apache/paimon/trino/TrinoRow.java:169

↓ 2 callersMethodgetByte

(int i)

src/main/java/org/apache/paimon/trino/TrinoRow.java:91

↓ 2 callersMethodgetLong

(int i)

src/main/java/org/apache/paimon/trino/TrinoRow.java:123

↓ 2 callersMethodgetOptionInfos

()

src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:51

↓ 2 callersMethodgetSplitSerialized

()

src/main/java/org/apache/paimon/trino/TrinoSplit.java:56

↓ 2 callersMethodgetTypeString

()

src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:64

↓ 2 callersMethodisRowId

()

src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:74

↓ 2 callersMethodtimestampLiteral

(long epochMilliSeconds, int precision)

src/test/java/org/apache/paimon/trino/TrinoITCase.java:987

↓ 1 callersMethodadvance

()

src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:77

↓ 1 callersMethodbuildClass

(String className)

src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:108

↓ 1 callersMethodbuildOptions

(Schema.Builder builder, Map<String, Object> properties)

src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:38

↓ 1 callersMethodcanUseTrinoPageSource

(List<RawFile> rawFiles)

src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:326

↓ 1 callersMethodcheckObjectStore

(String scheme)

src/main/java/org/apache/paimon/trino/fileio/TrinoFileIO.java:182

↓ 1 callersMethodcheckRawFile

(Optional<List<RawFile>> optionalRawFiles)

src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:320

↓ 1 callersMethodcolumnHandle

(TrinoCatalog catalog, String field)

src/main/java/org/apache/paimon/trino/TrinoTableHandle.java:172

↓ 1 callersMethodcontainSameElements

( List<? extends ColumnHandle> first, List<? extends ColumnHandle> second)

src/main/java/org/apache/paimon/trino/TrinoMetadata.java:721

↓ 1 callersMethodconvertToRetained

( Page page, DeletionVector deletionVector, int startPosition, int pageCount)

src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:85

↓ 1 callersMethodcreate

( String catalogName, Map<String, String> config, ConnectorContext context)

src/main/java/org/apache/paimon/trino/TrinoConnectorFactory.java:73

↓ 1 callersMethodcreateDataPageSource

( String format, TrinoInputFile inputFile, // TODO construct read option b

src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:353

↓ 1 callersMethodcreateDatabase

(String s, boolean b, Map<String, String> map)

src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:124

↓ 1 callersMethodcreateHadoopConfiguration

(Options options)

src/main/java/org/apache/paimon/trino/TrinoMetadataFactory.java:47

↓ 1 callersMethodcreateOrcDataPageSource

( TrinoInputFile inputFile, OrcReaderOptions options, List<String> columns

src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:394

↓ 1 callersMethodcreatePageSink

( ConnectorTransactionHandle transactionHandle, ConnectorSession session,

src/main/java/org/apache/paimon/trino/TrinoPageSinkProvider.java:56

↓ 1 callersMethodcreatePageSource

( ConnectorTransactionHandle transaction, ConnectorSession session, Connec

src/main/java/org/apache/paimon/trino/TrinoPageSourceProvider.java:98

↓ 1 callersMethodcreateTestHelper

(Path tablePath)

src/test/java/org/apache/paimon/trino/TrinoTestUtils.java:67

↓ 1 callersMethoddecodeStringToObject

(String encodedStr)

src/main/java/org/apache/paimon/trino/EncodingUtils.java:43

↓ 1 callersMethoddropColumn

( ConnectorSession session, ConnectorTableHandle tableHandle, ColumnHandle column)

src/main/java/org/apache/paimon/trino/TrinoMetadata.java:652

↓ 1 callersMethoddropDatabase

(String s, boolean b, boolean b1)

src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:134

↓ 1 callersMethodencodeObjectToString

(T t)

src/main/java/org/apache/paimon/trino/EncodingUtils.java:34

↓ 1 callersMethodequals

(Object obj)

src/main/java/org/apache/paimon/trino/TrinoColumnHandle.java:92

↓ 1 callersMethodextract

Extract filter from trino , include ExpressionFilter.

src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:58

↓ 1 callersMethodextractConfigOptions

(Class<?> clazz)

src/main/java/org/apache/paimon/trino/TrinoTableOptionUtils.java:134

↓ 1 callersMethodextractTrinoColumnHandleForExpressionFilter

Extract Expression filter from trino Constraint. Extract Trino Expression filter ( e.g. element_at(jsonmap, 'a') = '1' ) to TrinoColumnHandle.

src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:104

↓ 1 callersMethodfromSplit

(Split split, Double weight)

src/main/java/org/apache/paimon/trino/TrinoSplit.java:48

↓ 1 callersMethodgetBoolean

(int i)

src/main/java/org/apache/paimon/trino/TrinoRow.java:86

↓ 1 callersMethodgetCompletedBytes

()

src/main/java/org/apache/paimon/trino/DirectTrinoPageSource.java:43

↓ 1 callersMethodgetCompletedPositions

()

src/main/java/org/apache/paimon/trino/TrinoPageSourceWrapper.java:52

↓ 1 callersMethodgetConnectorFactories

()

src/main/java/org/apache/paimon/trino/TrinoPlugin.java:28

↓ 1 callersMethodgetDatabase

(String name)

src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java:129

↓ 1 callersMethodgetDouble

(int i)

src/main/java/org/apache/paimon/trino/TrinoRow.java:134

↓ 1 callersMethodgetFilter

()

src/main/java/org/apache/paimon/trino/TrinoFilterExtractor.java:234

↓ 1 callersMethodgetFloat

(int i)

src/main/java/org/apache/paimon/trino/TrinoRow.java:128

↓ 1 callersMethodgetInt

(int i)

src/main/java/org/apache/paimon/trino/TrinoRow.java:105

↓ 1 callersMethodgetMinimumSplitWeight

(ConnectorSession session)

src/main/java/org/apache/paimon/trino/TrinoSessionProperties.java:90

next →1–100 of 631, ranked by callers