Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/impala
/ functions
Functions
43,496 in github.com/apache/impala
⨍
Functions
43,496
◇
Types & classes
6,611
↳
Endpoints
56
↓ 28 callers
Method
getRef
()
fe/src/main/java/org/apache/impala/common/Reference.java:40
↓ 28 callers
Method
getViewStmt
()
fe/src/main/java/org/apache/impala/analysis/InlineViewRef.java:565
↓ 28 callers
Method
get_tmp_dir
Get the path of temporary directory that was registered with given 'name'.
tests/common/custom_cluster_test_suite.py:264
↓ 28 callers
Function
i
(n,t)
www/d3.v3.min.js:1
↓ 28 callers
Method
iface
Returns the object used to actually make RPCs against the remote server
be/src/rpc/thrift-client.h:125
↓ 28 callers
Method
matches
(SlotRef a, SlotRef b)
fe/src/main/java/org/apache/impala/analysis/SlotRef.java:382
↓ 28 callers
Method
pause
Pauses the event processing. Use <code>start(fromEventId)</code> method below to restart the event processing
fe/src/main/java/org/apache/impala/catalog/events/ExternalEventsProcessor.java:49
↓ 28 callers
Method
peak_consumption
Note that if consumption_ is based on consumption_metric_, this will the max value we've recorded in consumption(), not necessarily the highest value
be/src/runtime/mem-tracker.h:307
↓ 28 callers
Method
size
be/src/kudu/util/debug/trace_event_impl.h:195
↓ 28 callers
Function
testOutputCorrectness
We could use operator== instead of this, but using this function gives better readability, and makes debugging easier.
be/src/benchmarks/parquet-byte-stream-split-decoder-benchmark.cc:176
↓ 27 callers
Method
Accept
be/src/kudu/util/net/socket.cc:335
↓ 27 callers
Method
AddTableScan
be/src/scheduling/scheduler-test-util.cc:301
↓ 27 callers
Method
CheckNeedKey
be/src/kudu/security/token_signer.cc:202
↓ 27 callers
Method
Close
be/src/udf/udf.cc:259
↓ 27 callers
Method
Close
be/src/runtime/io/hdfs-file-reader.cc:362
↓ 27 callers
Method
DestroyPage
be/src/runtime/bufferpool/buffer-pool.cc:157
↓ 27 callers
Function
Et
(n)
www/d3.v3.min.js:1
↓ 27 callers
Method
GetBigIntSlot
be/src/runtime/tuple.h:320
↓ 27 callers
Function
InsertOrDie
be/src/gutil/map-util.h:394
↓ 27 callers
Method
IsAvailableForWrite
be/src/runtime/tuple-cache-mgr.cc:411
↓ 27 callers
Method
IsVarLenStringType
be/src/runtime/types.h:219
↓ 27 callers
Function
Iv
(t)
www/d3.v5.min.js:2
↓ 27 callers
Method
Load
be/src/exec/blob-reader.h:92
↓ 27 callers
Method
LogError
be/src/udf/udf.cc:112
↓ 27 callers
Function
MakeNetworkAddressPB
be/src/util/network-util.cc:180
↓ 27 callers
Method
MergeFrom
be/src/kudu/util/metrics.cc:899
↓ 27 callers
Method
NewRWFile
be/src/kudu/util/env_posix.cc:1646
↓ 27 callers
Method
NewToken
be/src/kudu/util/threadpool.cc:491
↓ 27 callers
Method
Pin
be/src/runtime/bufferpool/buffer-pool.cc:178
↓ 27 callers
Method
Read
be/src/kudu/util/env_posix.cc:1245
↓ 27 callers
Function
RedactedDebugString
be/src/util/thrift-debug-util.h:132
↓ 27 callers
Method
Shutdown
be/src/kudu/rpc/reactor.cc:233
↓ 27 callers
Function
StripWhiteSpace
be/src/gutil/strings/strip.h:102
↓ 27 callers
Method
TblsAnalyzeOk
Generates and analyzes two variants of the given query by replacing all occurrences of "$TBL" in the query string with the unqualified and fully-quali
fe/src/test/java/org/apache/impala/analysis/AnalyzerTest.java:94
↓ 27 callers
Method
TypeDefsParseOk
Wraps the given typeDefs in a CREATE TABLE and CAST and runs ParsesOk(). Also tests that the type is parsed correctly in ARRAY, MAP, and STRUCT types.
fe/src/test/java/org/apache/impala/analysis/ParserTest.java:3602
↓ 27 callers
Function
UnixMicros
Returns the number of microseconds that have passed since the Unix epoch. This is affected by manual changes to the system clock but is more suitable
be/src/util/time.h:78
↓ 27 callers
Method
add_test_dimensions
(cls)
tests/query_test/test_scanners.py:1617
↓ 27 callers
Function
char2unsigned
be/src/gutil/hash/jenkins.cc:26
↓ 27 callers
Method
counter
be/src/runtime/thread-resource-mgr-test.cc:40
↓ 27 callers
Method
equals
(Object that)
fe/src/compat-apache-hive-2/java/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java:500
↓ 27 callers
Method
executeHiveSql
(String query)
fe/src/test/java/org/apache/impala/catalog/PartialCatalogInfoWriteIdTest.java:755
↓ 27 callers
Method
getContentFileStore
Return content file store.
fe/src/main/java/org/apache/impala/catalog/FeIcebergTable.java:115
↓ 27 callers
Method
getMetaStoreDb
@return the metastore.api.Database object this Database was created from, or null if it is not related to a hive database such as builtins_db.
fe/src/main/java/org/apache/impala/catalog/FeDb.java:55
↓ 27 callers
Method
getNumInstancesExpected
()
fe/src/main/java/org/apache/impala/planner/ProcessingCost.java:212
↓ 27 callers
Method
getSchema
()
fe/src/main/java/org/apache/impala/authorization/ranger/RangerImpaladAuthorizationManager.java:557
↓ 27 callers
Method
getSlotId
()
fe/src/main/java/org/apache/impala/analysis/SlotRef.java:302
↓ 27 callers
Method
invalidateNonTransactionalTableIfExists
For non transactional tables, invalidate the table from cache if hms ddl apis are accessed from catalogd's metastore server. Any subsequent get table
fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java:3112
↓ 27 callers
Function
isFinite
(value)
www/dagre-d3.min.js:48
↓ 27 callers
Method
isIntegerType
()
fe/src/main/java/org/apache/impala/catalog/Type.java:221
↓ 27 callers
Method
is_registered
be/src/runtime/bufferpool/buffer-pool.h:401
↓ 27 callers
Method
low_memory_limit_test
(self, vector, tpch_query, limit)
tests/query_test/test_mem_usage_scaling.py:110
↓ 27 callers
Method
shift
be/src/transport/THttpTransport.cpp:198
↓ 27 callers
Method
socket
be/src/kudu/rpc/connection.h:217
↓ 27 callers
Method
sum
(List<CoreCount> cores)
fe/src/main/java/org/apache/impala/planner/CoreCount.java:116
↓ 27 callers
Method
toRule
()
java/calcite-planner/src/main/java/org/apache/impala/calcite/rules/ImpalaMinusToDistinctRule.java:208
↓ 27 callers
Method
treesToThrift
(List<? extends Expr> exprs, ThriftSerializationCtx serialCtx)
fe/src/main/java/org/apache/impala/analysis/Expr.java:958
↓ 26 callers
Method
AddDetail
be/src/common/status.cc:207
↓ 26 callers
Method
CompareAndSwap
be/src/kudu/util/atomic.h:222
↓ 26 callers
Function
GetMonoTimeMicros
be/src/gutil/walltime.h:103
↓ 26 callers
Function
HostnameToIpAddr
be/src/util/network-util.cc:71
↓ 26 callers
Method
IsFileRangeValid
be/src/exec/acid-metadata-utils.cc:167
↓ 26 callers
Function
IsInternalTlsConfigured
be/src/util/openssl-util.cc:114
↓ 26 callers
Function
LogSketchDeserializationError
be/src/exprs/datasketches-common.cc:38
↓ 26 callers
Function
NoBarrier_Store
be/src/gutil/atomicops-internals-portable.h:121
↓ 26 callers
Method
Open
be/src/rpc/thrift-client.cc:64
↓ 26 callers
Function
SecureDebugString
be/src/kudu/util/pb_util.cc:645
↓ 26 callers
Method
ToPrometheus
be/src/util/metrics.cc:86
↓ 26 callers
Method
Value
be/src/kudu/util/striped64.cc:186
↓ 26 callers
Function
a
(n)
www/d3.v3.min.js:1
↓ 26 callers
Method
assertToSql
(AnalysisContext ctx, String query, String expectedToSql, String expectedToRewrittenSql)
fe/src/test/java/org/apache/impala/analysis/ExprRewriterTest.java:513
↓ 26 callers
Method
bytesBasedNumWriters
Estimate such that each writer will work on at least MIN_WRITE_BYTES of rows. However, if this is a partitioned insert, the output volume will be divi
fe/src/main/java/org/apache/impala/planner/HdfsTableSink.java:437
↓ 26 callers
Method
cbegin
be/src/kudu/util/array_view.h:114
↓ 26 callers
Method
contains
(String apiName)
fe/src/main/java/org/apache/impala/catalog/metastore/HmsApiNameEnum.java:80
↓ 26 callers
Method
create
(TBackendGflags cfg)
fe/src/main/java/org/apache/impala/service/BackendConfig.java:52
↓ 26 callers
Method
debugString
Helper method to get debug string with helpful event information prepended to the message. This can be used to generate helpful exception messages @p
fe/src/compat-apache-hive-2/java/org/apache/impala/catalog/events/MetastoreEvents.java:889
↓ 26 callers
Method
describeOutput
(TDescribeOutputStyle style)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:294
↓ 26 callers
Method
fetch
Wrapper around ImpalaHiveServer2Service.FetchResults(fetch_results_req) that issues the given fetch request until the TCLIService.TStatusCode tran
tests/hs2/hs2_test_suite.py:203
↓ 26 callers
Function
filter
(collection,callback,thisArg)
www/dagre-d3.min.js:48
↓ 26 callers
Function
find
(collection,callback,thisArg)
www/dagre-d3.min.js:48
↓ 26 callers
Method
getCause
Return the cause of the failure to load
fe/src/main/java/org/apache/impala/catalog/FeIncompleteTable.java:26
↓ 26 callers
Method
getDistinctRowCount
(TableScan scan, RelMetadataQuery mq, ImmutableBitSet groupKey, RexNode predicate)
java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaRelMdDistinctRowCount.java:51
↓ 26 callers
Method
getEventType
()
fe/src/compat-apache-hive-2/java/org/apache/impala/catalog/events/MetastoreEvents.java:706
↓ 26 callers
Method
getLongValue
()
fe/src/main/java/org/apache/impala/analysis/NumericLiteral.java:268
↓ 26 callers
Method
getMessageDeserializer
()
fe/src/main/java/org/apache/impala/catalog/events/MetastoreEventsProcessor.java:1815
↓ 26 callers
Method
getSortExprs
Returns sort expressions originated from SORT BY property of the target table. @return list of sort expressions
fe/src/main/java/org/apache/impala/analysis/MergeImpl.java:81
↓ 26 callers
Method
getTable
Returns the Table with the given name if present in the table cache or null if the table does not exist in the cache.
fe/src/main/java/org/apache/impala/catalog/Db.java:259
↓ 26 callers
Method
getTableAndAcquireWriteLock
( String dbNameWithCatalog, String tblName, String apiName)
fe/src/main/java/org/apache/impala/catalog/metastore/CatalogMetastoreServiceHandler.java:1214
↓ 26 callers
Method
getTopLevelNode
()
fe/src/main/java/org/apache/impala/analysis/ParsedStatement.java:37
↓ 26 callers
Method
getUser
()
fe/src/main/java/org/apache/impala/analysis/Analyzer.java:3710
↓ 26 callers
Method
get_impala_partition_info
Find information about partitions of a table, as returned by a SHOW PARTITION statement. Return a list that contains one tuple for each parti
tests/common/impala_test_suite.py:631
↓ 26 callers
Method
iterator
()
fe/src/main/java/org/apache/impala/analysis/FromClause.java:261
↓ 26 callers
Method
length
be/src/gutil/strings/stringpiece.h:175
↓ 26 callers
Method
noReservation
(long memEstimateBytes)
fe/src/main/java/org/apache/impala/planner/ResourceProfile.java:108
↓ 26 callers
Method
offset
be/src/runtime/io/request-ranges.h:146
↓ 26 callers
Method
okDescribe
This method runs with the specified privileges.
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:358
↓ 26 callers
Method
query_state
be/src/runtime/runtime-state.h:97
↓ 26 callers
Method
testShellKerberosAuthWithUserWithHttpPath
Tests Kerberos authentication using impala-shell over HTTP protocol, using the HTTP path to specify the 'doAs' parameter.
fe/src/test/java/org/apache/impala/customcluster/LdapKerberosImpalaShellTestBase.java:100
↓ 26 callers
Method
total_allocated_bytes
be/src/exec/scratch-tuple-batch.h:229
↓ 26 callers
Method
union
Merges the two item sets belonging to the members a and b. The merged set contains at least a and b even if a or b did not have an associated item set
fe/src/main/java/org/apache/impala/util/DisjointSet.java:82
↓ 26 callers
Method
unit
be/src/util/metrics.h:171
← previous
next →
1,001–1,100 of 43,496, ranked by callers