MCPcopy Create free account

hub / github.com/apache/impala / functions

Functions43,496 in github.com/apache/impala

⨍ Functions 43,496◇ Types & classes 6,611↳ Endpoints 56
↓ 20 callersMethodEndObject
be/src/kudu/util/jsonwriter.cc:151
↓ 20 callersFunctionEscapeSql
be/src/util/sql-util.cc:38
↓ 20 callersMethodExtractString
be/src/kudu/util/jsonreader.cc:173
↓ 20 callersMethodGetInt64
be/src/util/process-state-info.cc:51
↓ 20 callersMethodGetPerExecutorMemLimitForAdmission
Return effective memory limit for admission for executors in this group.
be/src/scheduling/executor-group.h:122
↓ 20 callersMethodInsert
be/src/kudu/util/cache.cc:422
↓ 20 callersMethodInsert
be/src/exec/filter-context.cc:91
↓ 20 callersFunctionMakeJsonString
be/src/service/query-profile-parsing-tools.cc:124
↓ 20 callersMethodMaxOutputLen
be/src/util/compress.cc:80
↓ 20 callersMethodNext
Next pseudo-random 32-bit unsigned integer. FIXME: This currently only generates 31 bits of randomness. The MSB will always be zero.
be/src/kudu/util/random.h:52
↓ 20 callersFunctionOr
(n)
www/d3.v3.min.js:2
↓ 20 callersFunctionParseValidateDate
be/src/runtime/date-test.cc:47
↓ 20 callersMethodReadBytes
be/src/exec/scanner-context.inline.h:58
↓ 20 callersFunctionRunTest
be/src/kudu/util/os-util-test.cc:33
↓ 20 callersMethodStartObject
be/src/kudu/util/jsonwriter.cc:150
↓ 20 callersFunctionStatusFromThrift
be/src/common/status-serialization.cc:31
↓ 20 callersMethodTake
be/src/exec/json/json-parser.h:311
↓ 20 callersMethodTblsAnalysisError
Same as TblsAnalyzeOk(), except that analysis of all variants is expected to fail with the given error message.
fe/src/test/java/org/apache/impala/analysis/AnalyzerTest.java:107
↓ 20 callersMethodToJson
be/src/util/metrics.cc:62
↓ 20 callersMethodValueAtPercentile
be/src/kudu/util/hdr_histogram.cc:303
↓ 20 callersMethodVerify
JWTPublicKey member functions. Verify JWT's signature for the given decoded token with jwt-cpp API.
be/src/kudu/util/jwt-util.cc:309
↓ 20 callersMethod_shell_smoke
(self, host, vector, expected_errors=[])
tests/custom_cluster/test_ipv6.py:124
↓ 20 callersMethod_smoke
(self, host, vector, expected_errors=[])
tests/custom_cluster/test_ipv6.py:86
↓ 20 callersMethod_verify_total_admitted_queries
Verify the total number of queries that have been admitted to the given resource pool on the Web admission site.
tests/custom_cluster/test_executor_groups.py:234
↓ 20 callersMethod_webui_smoke
Tests to check glibc version and locale is available
tests/custom_cluster/test_ipv6.py:102
↓ 20 callersMethodaddRemovedObject
Adds a new item to the map of removed catalog objects.
fe/src/main/java/org/apache/impala/catalog/CatalogDeltaLog.java:82
↓ 20 callersFunctionassert_query
Helper function to assert that the values in the completed query log table match the values from the query profile.
tests/util/workload_management.py:62
↓ 20 callersMethodbuild
()
fe/src/main/java/org/apache/impala/planner/ResourceProfileBuilder.java:94
↓ 20 callersMethodbuildCommand
( String query, String protocol, String user, String password, String httpPath)
fe/src/test/java/org/apache/impala/customcluster/LdapImpalaShellTest.java:152
↓ 20 callersMethodcheckCorrectType
If correctType is true, returns. Otherwise throws a formatted error message indicating problems with the type of the literal of the range literal.
fe/src/main/java/org/apache/impala/util/KuduUtil.java:390
↓ 20 callersMethodcheckResponse
(boolean condition, TGetPartialCatalogObjectRequest req, String msg, Object... args)
fe/src/main/java/org/apache/impala/catalog/local/CatalogdMetaProvider.java:1425
↓ 20 callersMethodcreateDatabase
(String dbName)
fe/src/test/java/org/apache/impala/catalog/events/EventExecutorServiceTest.java:132
↓ 20 callersMethodcreateImpalaType
Create a new impala type given a relDataType
java/calcite-planner/src/main/java/org/apache/impala/calcite/type/ImpalaTypeConverter.java:200
↓ 20 callersMethoddeserialize
(ByteBuffer b)
fe/src/main/java/org/apache/impala/catalog/paimon/PaimonUtil.java:173
↓ 20 callersMethodeof
If true, the stream has reached the end of the file. After this is true, any Read*()/Get*()/Skip*() methods will not succeed.
be/src/exec/scanner-context.h:153
↓ 20 callersMethodequals
(Object o)
fe/src/main/java/org/apache/impala/authorization/Authorizable.java:73
↓ 20 callersFunctionerror_msg_startswith
As defined in `ImpalaServer::QUERY_ERROR_FORMAT`, an error message is expected to has the following form: Query <query_id> failed:\n<error_d
tests/common/test_result_verifier.py:805
↓ 20 callersMethodexecute_query_async
(self, query, query_options=None)
tests/common/impala_test_suite.py:1327
↓ 20 callersMethodexecute_query_async_using_client
(self, client, query, vector)
tests/common/impala_test_suite.py:1303
↓ 20 callersMethodfile_format
be/src/exec/orc/hdfs-orc-scanner.h:184
↓ 20 callersMethodfile_string
be/src/runtime/io/request-ranges.h:145
↓ 20 callersMethodfromImpalaType
Convert impala data type {@link Type} to paimon data type {@link DataType}. @param Type hive type info @return paimon data type
fe/src/main/java/org/apache/impala/catalog/paimon/PaimonImpalaTypeUtils.java:73
↓ 20 callersMethodget
()
fe/src/main/java/org/apache/impala/util/TResultRowBuilder.java:77
↓ 20 callersMethodgetCost
()
fe/src/main/java/org/apache/impala/analysis/Expr.java:492
↓ 20 callersMethodgetCreateEventId
()
fe/src/main/java/org/apache/impala/catalog/Db.java:141
↓ 20 callersMethodgetEventsFactory
Gets the {@link MetastoreEventFactory} to be used for creating {@link MetastoreEvents.MetastoreEvent}.
fe/src/main/java/org/apache/impala/catalog/events/ExternalEventsProcessor.java:96
↓ 20 callersMethodgetMetaStoreDb
()
fe/src/main/java/org/apache/impala/catalog/Db.java:294
↓ 20 callersMethodgetNumInstances
()
fe/src/main/java/org/apache/impala/planner/PlanNode.java:273
↓ 20 callersFunctionget_import
(name)
tests/comparison/common.py:32
↓ 20 callersMethodget_table_req
This method gets the table from the HMS directly. Additionally, if the request has {@code getFileMetadata} set it computes the filemetadata and return
fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java:892
↓ 20 callersMethodi32_type
be/src/codegen/llvm-codegen.h:569
↓ 20 callersMethodincrementOperation
(TDdlType tDdlType, Optional<TTableName> tTableName)
fe/src/main/java/org/apache/impala/catalog/monitor/CatalogDdlCounter.java:40
↓ 20 callersMethodinputFormat
()
fe/src/main/java/org/apache/impala/catalog/HdfsFileFormat.java:121
↓ 20 callersMethodinstance_id
be/src/runtime/io/request-context.h:232
↓ 20 callersMethodisArrayType
()
fe/src/main/java/org/apache/impala/catalog/Type.java:242
↓ 20 callersMethodisDbBlacklisted
Check if a database is blacklisted. Note: The system database ({@link Db#SYS}) is exempt from blacklisting when workload management is enabled in {@li
fe/src/main/java/org/apache/impala/util/CatalogBlacklistUtils.java:180
↓ 20 callersMethodis_catalog_v2_cluster
Checks whether we use local catalog.
tests/common/environ.py:408
↓ 20 callersMethodlocal_time
be/src/util/runtime-profile.h:212
↓ 20 callersFunctionr
(t)
www/c3/c3.v7.min.js:2
↓ 20 callersMethodserialize
be/src/runtime/io/data-cache.cc:471
↓ 20 callersMethodset_perf_improvement
be/src/kudu/util/maintenance_manager-test.cc:187
↓ 20 callersMethodsnapshotId
Returns the current snapshot id of the Iceberg API table if it exists, otherwise returns -1.
fe/src/main/java/org/apache/impala/catalog/FeIcebergTable.java:438
↓ 20 callersMethodtrue_value
Returns true/false constants (bool type)
be/src/codegen/llvm-codegen.h:561
↓ 20 callersMethodverify_function_count
(self, query, count)
tests/custom_cluster/test_permanent_udfs.py:96
↓ 19 callersMethodAnyLimitExceeded
Returns true if a valid limit of this tracker or one of its ancestors is exceeded.
be/src/runtime/mem-tracker.h:255
↓ 19 callersFunctionCheckVersionParse
be/src/exec/parquet/parquet-version-test.cc:29
↓ 19 callersFunctionCommaSeparatedContains
be/src/util/string-util.cc:61
↓ 19 callersMethodCopyRow
be/src/runtime/row-batch.h:313
↓ 19 callersMethodDebugString
be/src/exec/hbase/hbase-scan-node.cc:298
↓ 19 callersFunctionDecimalToString
Workaround for an ASAN build issue documented here: https://bugs.llvm.org/show_bug.cgi?id=16404
be/src/kudu/util/decimal_util.cc:49
↓ 19 callersMethodEmplaceAndGet
be/src/util/lru-multi-cache.inline.h:153
↓ 19 callersFunctionEvalTruncation
be/src/util/string-util-test.cc:34
↓ 19 callersFunctionFindUnusedEphemeralPort
Pick a random port in the range of ephemeral ports https://tools.ietf.org/html/rfc6335
be/src/util/network-util.cc:305
↓ 19 callersMethodGetInfoString
be/src/util/runtime-profile.cc:1115
↓ 19 callersMethodGetNext
be/src/runtime/sorter.cc:505
↓ 19 callersMethodIsAvailableForRead
be/src/runtime/tuple-cache-mgr.cc:404
↓ 19 callersMethodIsWriteIdRangeValid
be/src/exec/acid-metadata-utils.cc:149
↓ 19 callersFunctionMaskShowFirstNImpl
Mask the given string except the first 'un_mask_char_count' chars. Ported from org.apache.hadoop.hive.ql.udf.generic.GenericUDFMaskShowFirstN.
be/src/exprs/mask-functions-ir.cc:215
↓ 19 callersMethodMerge
Merge utilization from 'other' into this.
be/src/runtime/coordinator.h:250
↓ 19 callersMethodReachedLimitShared
Returns true if a valid limit is set and number of rows returned by this node has exceeded the limit. Thread safe version of ReachedLimit().
be/src/exec/exec-node.h:341
↓ 19 callersMethodRegisterSubscriber
be/src/rpc/thrift-server-test.cc:77
↓ 19 callersMethodSerializeToBuffer
be/src/rpc/thrift-util.h:105
↓ 19 callersMethodSetAttribute
be/src/observe/buffered-span.cc:115
↓ 19 callersMethodSetData
be/src/runtime/io/disk-io-mgr.cc:251
↓ 19 callersMethodSetVal
be/src/codegen/codegen-anyval.cc:407
↓ 19 callersMethodStart
be/src/kudu/util/mini_oidc.cc:99
↓ 19 callersMethodSyncRequest
be/src/kudu/rpc/proxy.cc:252
↓ 19 callersFunctionTestStringToFloatPreprocess
be/src/util/string-parser-test.cc:158
↓ 19 callersFunctionTimedOut
be/src/kudu/util/status.h:294
↓ 19 callersFunctionUint128High64
be/src/gutil/int128.h:87
↓ 19 callersMethodUnlock
be/src/kudu/util/mutex.h:118
↓ 19 callersFunctionValidatePages
be/src/exec/parquet/parquet-common-test.cc:68
↓ 19 callersFunctiona
(t)
www/c3/c3.v7.min.js:2
↓ 19 callersMethodaddPlanRoot
Adds a node as the new root to the plan tree. Connects the existing root as the child of newRoot.
fe/src/main/java/org/apache/impala/planner/PlanFragment.java:889
↓ 19 callersFunctionassertCounter
(profile, key, val, num_matches)
tests/custom_cluster/test_tuple_cache.py:67
↓ 19 callersMethodbool_type
Simple wrappers to reduce code verbosity
be/src/codegen/llvm-codegen.h:566
↓ 19 callersFunctionc
(n)
www/d3.v3.min.js:1
↓ 19 callersMethodcapCardinalityAtLimit
(long cardinality)
fe/src/main/java/org/apache/impala/planner/PlanNode.java:774
↓ 19 callersMethodclose_impala_clients
Closes Impala clients created by create_impala_clients().
tests/common/impala_test_suite.py:530
↓ 19 callersMethodcol_pos
Returns the column index of this slot, including partition keys. (e.g., col_pos - num_partition_keys = the table column this slot corresponds to) TODO
be/src/runtime/descriptors.h:135
← previousnext →1,401–1,500 of 43,496, ranked by callers