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
↓ 53 callers
Function
DebugString
be/src/exprs/conditional-functions.h:80
↓ 53 callers
Method
MemLimitExceeded
be/src/common/status.cc:40
↓ 53 callers
Function
NetworkAddressPBToString
be/src/util/network-util.cc:251
↓ 53 callers
Method
consumption
Returns the memory consumed in bytes.
be/src/kudu/util/mem_tracker.h:147
↓ 53 callers
Method
createTColumnValue
(String val)
fe/src/main/java/org/apache/impala/service/MetadataOp.java:943
↓ 53 callers
Function
create_table_from_parquet
Utility function to create a database table from a Parquet file. A Parquet file must exist in $IMPALA_HOME/testdata/data with the name 'table_name'.
tests/common/file_utils.py:81
↓ 53 callers
Method
equals
(Object other)
fe/src/main/java/org/apache/impala/catalog/paimon/PaimonStructField.java:68
↓ 53 callers
Method
length
be/src/statestore/statestore.h:330
↓ 53 callers
Method
month
(String sourceName, int sourceId)
fe/src/main/java/org/apache/impala/util/IcebergUtil.java:586
↓ 53 callers
Method
owns_lock
be/src/kudu/util/locks.h:273
↓ 53 callers
Method
toString
()
java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaCost.java:36
↓ 52 callers
Method
AddRow
be/src/exec/analytic-eval-node.cc:348
↓ 52 callers
Method
Close
be/src/runtime/bufferpool/buffer-pool.cc:410
↓ 52 callers
Method
Init
be/src/util/os-info.cc:57
↓ 52 callers
Function
column_val
(index)
tests/util/workload_management.py:113
↓ 52 callers
Method
find
Forward iterator that points at the element 'val' if it exists, or at end() if it doesn't exist.
be/src/kudu/util/bitset.h:134
↓ 52 callers
Method
getDescTbl
()
fe/src/main/java/org/apache/impala/analysis/Analyzer.java:2357
↓ 52 callers
Function
join
Returns result from queue returned by 'start', and waits for proc to complete.
tests/util/web_pages_util.py:114
↓ 52 callers
Method
sign
(String input)
fe/src/main/java/org/apache/impala/authentication/saml/HiveSamlAuthTokenGenerator.java:100
↓ 52 callers
Method
status
be/src/kudu/rpc/outbound_call.cc:195
↓ 52 callers
Method
transform
(String input)
fe/src/test/java/org/apache/impala/testutil/TestUtils.java:87
↓ 51 callers
Method
Build
Constructs a new ThriftServer and puts it in 'server', if construction was successful, returns an error otherwise. In the error case, 'server' will no
be/src/rpc/thrift-server.h:565
↓ 51 callers
Method
NotifyAll
Notify all waiters on this condition variable.
be/src/util/condition-variable.h:74
↓ 51 callers
Method
_start_impala_cluster
(cls, options, impala_log_dir=None,
tests/common/custom_cluster_test_suite.py:605
↓ 51 callers
Method
getMetastoreDdlLock
()
fe/src/main/java/org/apache/impala/service/CatalogOpExecutor.java:5688
↓ 51 callers
Method
getOp
()
fe/src/main/java/org/apache/impala/analysis/BinaryPredicate.java:146
↓ 51 callers
Method
getStats
()
fe/src/main/java/org/apache/impala/catalog/Column.java:71
↓ 51 callers
Method
printBytes
Prints the given number of bytes in PB, TB, GB, MB, KB with 2 decimal points. For example 5000 will be returned as 4.88KB.
fe/src/main/java/org/apache/impala/common/PrintUtils.java:44
↓ 51 callers
Method
verifyMetrics
(long expectedBasicAuthSuccess, long expectedBasicAuthFailure)
fe/src/test/java/org/apache/impala/customcluster/LdapHS2Test.java:140
↓ 50 callers
Method
SetFunctionState
be/src/udf/udf.cc:489
↓ 50 callers
Method
ToString
be/src/kudu/security/cert.cc:97
↓ 50 callers
Method
deepCopy
Create a deep copy of 'ls'. The elements of the returned list are of the same type as the input list.
fe/src/main/java/org/apache/impala/analysis/Expr.java:1293
↓ 50 callers
Method
getShortName
()
fe/src/main/java/org/apache/impala/authorization/User.java:49
↓ 50 callers
Method
runtime_profile
be/src/exec/exec-node.h:350
↓ 50 callers
Method
toSql
()
fe/src/main/java/org/apache/impala/analysis/Expr.java:859
↓ 49 callers
Method
AcquireData
be/src/runtime/mem-pool.cc:162
↓ 49 callers
Method
RegisterClient
be/src/runtime/bufferpool/buffer-pool.cc:124
↓ 49 callers
Method
SetTuple
be/src/exec/hash-table.inline.h:318
↓ 49 callers
Method
TryAllocate
Same as Allocate() except the mem limit is checked before the allocation and this call will fail (returns NULL) if it does. The caller must handle the
be/src/runtime/mem-pool.h:133
↓ 49 callers
Method
_expect_with_cmd
Executes a command on the expect process instance and verifies a set of assertions defined by the expectations.
tests/shell/test_shell_interactive.py:195
↓ 49 callers
Method
builder
be/src/codegen/codegen-anyval.h:260
↓ 49 callers
Method
execute_statement
Executes statement and checks if the response meets the expectations. If so, it returns the response.
tests/hs2/hs2_test_suite.py:364
↓ 49 callers
Method
get_metric
Get metric from impalad by name. Raise exception if there is no such metric.
tests/comparison/cluster.py:684
↓ 49 callers
Method
host
be/src/kudu/util/net/sockaddr.cc:232
↓ 49 callers
Method
inferType
Infer the natural (smallest) type required to hold the given numeric value. @throws SqlCastException if the value is not valid for any type
fe/src/main/java/org/apache/impala/analysis/NumericLiteral.java:356
↓ 49 callers
Method
init
(TPrivilege[]... privileges)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:151
↓ 49 callers
Method
parent
be/src/runtime/mem-tracker.h:309
↓ 48 callers
Method
ReplaceCallSites
be/src/codegen/llvm-codegen.cc:991
↓ 48 callers
Method
cloneList
Create a deep copy of 'l'. The elements of the returned list are of the same type as the input list.
fe/src/main/java/org/apache/impala/analysis/Expr.java:1280
↓ 48 callers
Method
createError
(String object)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:716
↓ 48 callers
Method
data
be/src/kudu/rpc/transfer.h:87
↓ 48 callers
Method
enableCatalogdHMSCache
()
fe/src/main/java/org/apache/impala/service/BackendConfig.java:336
↓ 48 callers
Method
getTupleIds
()
fe/src/main/java/org/apache/impala/planner/PlanNode.java:303
↓ 48 callers
Method
get_data
(self)
tests/beeswax/impala_beeswax.py:91
↓ 48 callers
Method
get_event_processor_status
Returns the current status of the EventsProcessor
tests/util/event_processor_utils.py:171
↓ 48 callers
Method
infoLog
Logs at info level the given log formatted string and its args. The log formatted string should have {} pair at the appropriate location in the string
fe/src/compat-apache-hive-2/java/org/apache/impala/catalog/events/MetastoreEvents.java:924
↓ 48 callers
Method
isStructType
()
fe/src/main/java/org/apache/impala/catalog/Type.java:243
↓ 48 callers
Method
len
be/src/runtime/io/request-ranges.h:147
↓ 48 callers
Method
row_desc
Returns the row descriptor for rows produced by this node. The RowDescriptor is constant for the lifetime of the fragment instance, and so is shared b
be/src/exec/exec-node.h:298
↓ 48 callers
Function
t
()
www/datatables/DataTables-1.13.2/js/jquery.dataTables.min.js:4
↓ 47 callers
Method
Clear
be/src/runtime/mem-pool.cc:65
↓ 47 callers
Function
ContainsKey
be/src/gutil/map-util.h:296
↓ 47 callers
Method
Put
be/src/kudu/util/jsonwriter.cc:302
↓ 47 callers
Function
Validate
be/src/exec/delimited-text-parser-test.cc:27
↓ 47 callers
Function
create_uncompressed_text_dimension
(workload)
tests/common/test_dimensions.py:141
↓ 47 callers
Method
day
(String sourceName, int sourceId)
fe/src/main/java/org/apache/impala/util/IcebergUtil.java:593
↓ 47 callers
Method
duration
be/src/kudu/util/debug/trace_event_impl.h:138
↓ 47 callers
Method
equals
(Object obj)
fe/src/main/java/org/apache/impala/planner/DataPartition.java:99
↓ 47 callers
Method
error
(self)
tests/comparison/discrepancy_searcher.py:510
↓ 47 callers
Method
getIdentSql
Given an unquoted identifier string, returns an identifier lexable by Impala and Hive, possibly by enclosing the original identifier in "`" quotes. Fo
fe/src/main/java/org/apache/impala/analysis/ToSqlUtils.java:338
↓ 47 callers
Method
getNumRows
@return the estimated number of rows in this table (or -1 if unknown)
fe/src/main/java/org/apache/impala/catalog/FeTable.java:207
↓ 47 callers
Method
getPrecision
JDBC data type description For numeric types, returns the maximum precision for this type. For non-numeric types, returns null.
fe/src/main/java/org/apache/impala/catalog/Type.java:588
↓ 47 callers
Method
metrics
be/src/scheduling/admission-controller.h:850
↓ 46 callers
Method
AlwaysTrue
be/src/util/min-max-filter.cc:1225
↓ 46 callers
Method
CommitLastRow
be/src/runtime/row-batch.h:140
↓ 46 callers
Function
GetThreadDebugInfo
be/src/common/thread-debug-info.cc:37
↓ 46 callers
Method
InitRootTracker
be/src/runtime/bufferpool/reservation-tracker.cc:43
↓ 46 callers
Method
LimitExceeded
If this tracker has a limit, checks the limit and attempts to free up some memory if the hard limit is exceeded by calling any added GC functions. Ret
be/src/runtime/mem-tracker.h:266
↓ 46 callers
Function
ParseVersion
be/src/kudu/util/version_util.cc:59
↓ 46 callers
Method
Start
be/src/rpc/thrift-server.cc:408
↓ 46 callers
Function
Validate
be/src/exprs/cast-functions-ir.cc:141
↓ 46 callers
Method
apiName
()
fe/src/main/java/org/apache/impala/catalog/metastore/HmsApiNameEnum.java:76
↓ 46 callers
Function
deserialize
(value)
tests/comparison/data_generator_mapred_common.py:40
↓ 46 callers
Method
getFragment
()
fe/src/main/java/org/apache/impala/planner/DataSink.java:132
↓ 46 callers
Method
getQueryStmt
Creates the query statement that produces the result set that will be evaluated by the merge cases, and later gets persisted by a data sink. @return q
fe/src/main/java/org/apache/impala/analysis/MergeImpl.java:94
↓ 46 callers
Method
getRexBuilder
()
java/calcite-planner/src/main/java/org/apache/impala/calcite/rel/util/CreateExprVisitor.java:69
↓ 45 callers
Method
GetMethodID
be/src/util/jni-util.cc:135
↓ 45 callers
Method
Init
be/src/rpc/rpc-mgr.cc:136
↓ 45 callers
Function
IsAddrOneOf
be/src/kudu/util/net/net_util.cc:529
↓ 45 callers
Method
createDatabase
(String catName, String dbName, Map<String, String> params)
fe/src/test/java/org/apache/impala/catalog/events/MetastoreEventsProcessorTest.java:4416
↓ 45 callers
Method
handle_id
Return a string id for given operation_handle. Most implementations will return an Impala query id for given handle. Otherwise, return str(ope
tests/common/impala_connection.py:301
↓ 45 callers
Method
hostname
be/src/util/webserver.h:129
↓ 45 callers
Method
isOverflow
Check overflow.
fe/src/main/java/org/apache/impala/analysis/NumericLiteral.java:544
↓ 45 callers
Method
is_open
be/src/runtime/bufferpool/buffer-pool.h:533
↓ 45 callers
Function
map
(collection,callback,thisArg)
www/dagre-d3.min.js:48
↓ 45 callers
Function
o
(c)
www/d3.v5.min.js:2
↓ 45 callers
Method
proxy
be/src/kudu/rpc/protoc-gen-krpc.cc:127
↓ 45 callers
Method
pytest_config
Return a pytest config object.
tests/common/base_test_suite.py:47
↓ 45 callers
Method
registerPrivReq
Registers a new PrivilegeRequest in the analyzer.
fe/src/main/java/org/apache/impala/analysis/Analyzer.java:4242
↓ 45 callers
Method
row
be/src/runtime/sorter-internal.h:470
← previous
next →
501–600 of 43,496, ranked by callers