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
↓ 132 callers
Method
build
()
fe/src/main/java/org/apache/impala/catalog/HdfsPartition.java:940
↓ 132 callers
Method
writeLock
()
fe/src/main/java/org/apache/impala/catalog/Table.java:310
↓ 131 callers
Method
execute_async
Issues a query and returns the handle to the caller for processing. Only one async operation per connection at a time is supported, due to limitat
tests/common/impala_connection.py:277
↓ 130 callers
Method
assert_impalad_log_contains
Convenience wrapper around assert_log_contains for impalad logs.
tests/common/impala_test_suite.py:1698
↓ 129 callers
Method
count
be/src/kudu/util/countdown_latch.h:112
↓ 129 callers
Method
getCounter
Returns a counter named 'name'. If the counter does not exist, it is registered in the metrics registry.
fe/src/main/java/org/apache/impala/common/Metrics.java:59
↓ 129 callers
Method
getSlots
()
fe/src/main/java/org/apache/impala/analysis/TupleDescriptor.java:155
↓ 129 callers
Method
update
Updates the stats with the given ColumnStatisticsData. If the ColumnStatisticsData is not compatible with the given colType, all stats are initialized
fe/src/main/java/org/apache/impala/catalog/ColumnStats.java:571
↓ 128 callers
Method
Load
be/src/kudu/util/atomic.h:175
↓ 125 callers
Function
RuntimeError
be/src/kudu/util/status.h:266
↓ 125 callers
Method
accessError
(String object)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:732
↓ 125 callers
Method
addBuiltin
Adds a builtin to this database. The function must not already exist.
fe/src/main/java/org/apache/impala/catalog/Db.java:458
↓ 125 callers
Method
begin
be/src/service/query-state-record.cc:498
↓ 122 callers
Method
selectError
(String object)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:708
↓ 121 callers
Method
PushBack
be/src/kudu/util/easy_json.cc:153
↓ 120 callers
Method
end
Forward iterator that points to the end of the values in the bitset.
be/src/kudu/util/bitset.h:128
↓ 120 callers
Method
verifySelectExpr
(String db, String table, String exprSql, long expectedNdv, double expectedSel)
fe/src/test/java/org/apache/impala/analysis/ExprCardinalityTest.java:219
↓ 119 callers
Method
Size
be/src/util/thread.cc:409
↓ 117 callers
Method
close_query
(self, query_handle)
tests/custom_cluster/test_hs2_fault_injection.py:146
↓ 117 callers
Method
create
The local path contains a directory on the local file system to which the jar file on hdfs can be copied.
fe/src/main/java/org/apache/impala/hive/executor/HiveJavaFunctionFactory.java:33
↓ 116 callers
Method
SetError
be/src/exec/hdfs-scan-node.cc:555
↓ 114 callers
Method
AddInfoString
be/src/util/runtime-profile.cc:1077
↓ 114 callers
Method
getColumn
Case-insensitive lookup. @return null if the column with 'name' is not found.
fe/src/main/java/org/apache/impala/catalog/FeTable.java:192
↓ 114 callers
Method
tuple_offset
be/src/runtime/descriptors.h:143
↓ 113 callers
Method
getColumns
@return the columns in this table
fe/src/main/java/org/apache/impala/catalog/FeTable.java:113
↓ 112 callers
Method
String
be/src/kudu/util/jsonwriter.cc:147
↓ 112 callers
Method
assertEventEquals
(String resourceType, String accessType, String resourcePath, int accessResult, AuthzAuditEvent event)
fe/src/test/java/org/apache/impala/authorization/ranger/RangerAuditLogTest.java:1057
↓ 111 callers
Method
GetReservation
be/src/runtime/bufferpool/buffer-pool.cc:328
↓ 111 callers
Method
compare
(FeDb db1, FeDb db2)
fe/src/main/java/org/apache/impala/catalog/FeDb.java:39
↓ 111 callers
Method
get_workload
(cls)
tests/query_test/test_tpcds_queries.py:342
↓ 111 callers
Method
keySet
Returns the set of all known object names. The returned set is backed by the cache, so updates to the cache will be visible in the returned set and vi
fe/src/main/java/org/apache/impala/catalog/CatalogObjectCache.java:152
↓ 111 callers
Method
set_configuration_option
Sets a configuration option name to the given value. Return True if option is changing. Otherwise, return False (option already has the same v
tests/common/impala_connection.py:162
↓ 111 callers
Method
toString
()
fe/src/main/java/org/apache/impala/common/Id.java:42
↓ 110 callers
Method
GetRow
be/src/exec/hash-table.inline.h:263
↓ 109 callers
Function
JoinPathSegments
be/src/kudu/util/path_util.cc:73
↓ 109 callers
Method
getOrLoadTable
Returns the Table for the given name, loading the table's metadata if necessary. Returns null if the database or table does not exist.
fe/src/test/java/org/apache/impala/testutil/ImpaladTestCatalog.java:124
↓ 109 callers
Method
getPath
()
fe/src/main/java/org/apache/impala/analysis/HdfsUri.java:46
↓ 108 callers
Method
Get
be/src/util/metrics.cc:124
↓ 108 callers
Function
InvalidArgument
be/src/kudu/util/status.h:254
↓ 108 callers
Method
create_hs2_client
Creates a new HS2 client connection to the impalad
tests/common/impala_service.py:525
↓ 107 callers
Method
front
be/src/gutil/ref_counted_memory.cc:24
↓ 107 callers
Method
getName
()
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:153
↓ 107 callers
Method
set_configuration
Replaces existing configuration with the given dictionary. If config_option_dict is an empty dictionary, simply clear current client configura
tests/common/impala_connection.py:169
↓ 105 callers
Method
GetI32Constant
be/src/codegen/llvm-codegen.h:592
↓ 105 callers
Method
size
()
fe/src/main/java/org/apache/impala/service/HistoricalStatsValue.java:61
↓ 104 callers
Function
StrCat
Support 9 or more arguments
be/src/gutil/strings/strcat.h:128
↓ 104 callers
Method
getTbl
()
fe/src/main/java/org/apache/impala/analysis/TableDef.java:360
↓ 103 callers
Function
IOError
be/src/kudu/util/env_posix.cc:398
↓ 103 callers
Function
PrintBytes
Convenience method.
be/src/scheduling/admission-controller.cc:107
↓ 103 callers
Method
asInt
()
fe/src/main/java/org/apache/impala/common/Id.java:37
↓ 102 callers
Method
AddArgument
Add argument
be/src/codegen/llvm-codegen.h:228
↓ 101 callers
Method
getLocation
()
fe/src/main/java/org/apache/impala/catalog/FeFsTable.java:333
↓ 101 callers
Method
insert
be/src/scheduling/admission-controller.cc:983
↓ 101 callers
Method
onColumn
(String db, String table, String column, TPrivilegeLevel... levels)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:452
↓ 100 callers
Method
filename
be/src/exec/orc/hdfs-orc-scanner.h:320
↓ 99 callers
Method
equals
Subclasses must provide consistent equals and hashCode implementations such that a.equals(b) implies a.hashCode() == b.hashCode().
fe/src/main/java/org/apache/impala/catalog/Type.java:326
↓ 98 callers
Method
getName
()
fe/src/main/java/org/apache/impala/catalog/local/MetaProvider.java:209
↓ 97 callers
Method
getType
()
fe/src/main/java/org/apache/impala/analysis/Expr.java:489
↓ 97 callers
Method
query_id
be/src/service/impala-server.h:1383
↓ 97 callers
Method
year
(String sourceName, int sourceId)
fe/src/main/java/org/apache/impala/util/IcebergUtil.java:579
↓ 96 callers
Function
$
(t)
www/d3.v5.min.js:2
↓ 96 callers
Method
_write
Return a sql string representation of the given object.
tests/comparison/model_translator.py:470
↓ 96 callers
Method
contains
be/src/gutil/charmap.h:53
↓ 96 callers
Method
getStatus
Gets the current event processor status
fe/src/main/java/org/apache/impala/catalog/events/MetastoreEventsProcessor.java:876
↓ 95 callers
Method
execute_query_using_vector
Run 'query' with given test 'vector'. 'vector' must have 'protocol' and 'exec_option' dimension. Default ImpalaTestSuite client will be used d
tests/common/impala_test_suite.py:1313
↓ 95 callers
Function
get_fs_path
(path)
tests/util/filesystem_utils.py:79
↓ 95 callers
Method
is
(String s)
fe/src/main/java/org/apache/impala/analysis/PlanHint.java:49
↓ 94 callers
Method
AddGauge
Create a gauge metric object with given key and initial value (owned by this object)
be/src/util/metrics.h:400
↓ 94 callers
Method
Close
be/src/runtime/sorter.cc:98
↓ 94 callers
Method
getCounter
(String s)
fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java:3034
↓ 94 callers
Method
getEventType
()
fe/src/main/java/org/apache/impala/catalog/events/MetastoreEvents.java:717
↓ 93 callers
Method
get_workload
(cls)
tests/query_test/test_tpcds_queries.py:37
↓ 92 callers
Function
a
(e)
tests/comparison/leopard/static/js/highlight.pack.js:1
↓ 92 callers
Method
getFunction
@see Catalog#getFunction(Function, Function.CompareMode)
fe/src/main/java/org/apache/impala/catalog/FeDb.java:96
↓ 91 callers
Method
AtCapacity
be/src/runtime/row-batch.h:153
↓ 91 callers
Method
SetValue
be/src/statestore/statestore.cc:403
↓ 91 callers
Method
getParent
()
fe/src/main/java/org/apache/impala/analysis/SlotDescriptor.java:121
↓ 91 callers
Method
isScalarType
()
fe/src/main/java/org/apache/impala/catalog/Type.java:206
↓ 91 callers
Method
kill
Kills the given processes.
tests/common/impala_cluster.py:511
↓ 91 callers
Method
obj_pool
be/src/exec/hdfs-scan-node-base.h:169
↓ 90 callers
Method
code
be/src/common/status.h:270
↓ 90 callers
Method
getRootAnalyzer
()
fe/src/main/java/org/apache/impala/planner/PlannerContext.java:112
↓ 90 callers
Method
tuple_data_pool
be/src/runtime/row-batch.h:248
↓ 89 callers
Method
ToString
be/src/runtime/date-value.cc:431
↓ 89 callers
Method
merge
(FileMetadataStats other)
fe/src/main/java/org/apache/impala/catalog/FeFsTable.java:178
↓ 88 callers
Function
StringToInt128
Utility function to construct int128 types.
be/src/exprs/expr-test.cc:1830
↓ 88 callers
Function
TestAllFloatVariants
Tests conversion of s to double and float with +/- prefixing (and no prefix) and with and without leading/trailing whitespace
be/src/util/string-parser-test.cc:122
↓ 88 callers
Method
data
be/src/gutil/strings/strcat.h:70
↓ 88 callers
Method
len
be/src/runtime/bufferpool/buffer-pool.cc:92
↓ 87 callers
Function
DebugString
be/src/udf/udf-debug.h:33
↓ 87 callers
Method
name
be/src/common/daemon-env.h:49
↓ 86 callers
Method
CreateCall
be/src/codegen/codegen-anyval.cc:174
↓ 86 callers
Method
Submit
be/src/kudu/util/threadpool.cc:196
↓ 86 callers
Method
getCatalogVersion
@return the catalog version of this table assigned in catalogd.
fe/src/main/java/org/apache/impala/catalog/FeTable.java:238
↓ 86 callers
Method
getDbName
()
fe/src/main/java/org/apache/impala/catalog/TableWriteId.java:41
↓ 85 callers
Method
begin
Forward iterator that points to the start of the values in the bitset. Points at the first set bit, or at end() if no bits are set.
be/src/kudu/util/bitset.h:121
↓ 85 callers
Method
error
be/src/util/error-util.h:110
↓ 85 callers
Method
exec
(String[] args)
java/TableFlattener/src/main/java/org/apache/impala/infra/tableflattener/Main.java:149
↓ 85 callers
Method
getLastSyncedEventId
Get the latest event id that has been processed.
fe/src/main/java/org/apache/impala/catalog/events/ExternalEventsProcessor.java:43
↓ 85 callers
Method
getPrimitiveType
()
fe/src/main/java/org/apache/impala/catalog/Type.java:298
← previous
next →
201–300 of 43,496, ranked by callers