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
↓ 283 callers
Method
max
be/src/kudu/util/random.h:220
↓ 282 callers
Method
search
Returns an instance of SearchResults, which is a summary report. This method oversees the generation, execution, and comparison of queries.
tests/comparison/discrepancy_searcher.py:675
↓ 279 callers
Method
createDecimalType
()
fe/src/main/java/org/apache/impala/catalog/ScalarType.java:110
↓ 269 callers
Method
Increment
be/src/kudu/util/atomic.h:246
↓ 268 callers
Method
toString
()
fe/src/main/java/org/apache/impala/analysis/Expr.java:1693
↓ 265 callers
Method
allExcept
(TPrivilegeLevel... excludedPrivLevels)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:820
↓ 263 callers
Method
analyze
Analyzes the implementation specific parts of the MERGE statement. @param analyzer analyzer of the MERGE statement @throws AnalysisException if analys
fe/src/main/java/org/apache/impala/analysis/MergeImpl.java:39
↓ 260 callers
Method
getThriftClient
(IMetaStoreClient msClient)
fe/src/compat-apache-hive-2/java/org/apache/impala/compat/MetastoreShim.java:395
↓ 257 callers
Method
add_constraint
(self, constraint_func)
tests/common/test_vector.py:299
↓ 255 callers
Method
stream
be/src/exec/parquet/parquet-page-reader.h:31
↓ 253 callers
Method
toString
()
fe/src/test/java/org/apache/impala/util/IcebergUtilTest.java:401
↓ 252 callers
Method
execute_query_expect_failure
Executes a query and asserts that the query failed. Remember to pass vector.get_value('exec_option') as 'query_options' argument if the test h
tests/common/impala_test_suite.py:1257
↓ 250 callers
Method
Load
be/src/runtime/io/data-cache.cc:1078
↓ 244 callers
Method
getTableName
@return the table name in structured form
fe/src/main/java/org/apache/impala/catalog/FeTable.java:98
↓ 242 callers
Method
slice
Return a slice view into this Bloom Filter, suitable for writing out to a file.
be/src/kudu/util/bloom_filter.h:160
↓ 239 callers
Method
join
(TPrivilegeLevel[] level1, TPrivilegeLevel... level2)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:803
↓ 238 callers
Method
write
be/src/transport/THttpTransport.cpp:283
↓ 237 callers
Function
TestDateValue
be/src/util/string-parser-test.cc:82
↓ 232 callers
Method
ToString
be/src/kudu/rpc/proxy.cc:275
↓ 228 callers
Method
empty
be/src/util/internal-queue.h:230
↓ 227 callers
Method
find
Forward interface for boost::unordered_map
be/src/scheduling/scheduler.h:144
↓ 226 callers
Method
children
be/src/exec/parquet/parquet-complex-column-reader.h:30
↓ 224 callers
Method
path
Helper function that returns a list of integers used to improve readability in the path-related tests below.
fe/src/test/java/org/apache/impala/analysis/AnalyzeStmtsTest.java:530
↓ 222 callers
Method
size
be/src/gutil/strings/strcat.h:69
↓ 220 callers
Method
getValue
()
fe/src/main/java/org/apache/impala/catalog/HdfsTable.java:2943
↓ 218 callers
Method
insert
Inserts 'val' into the set.
be/src/kudu/util/bitset.h:69
↓ 217 callers
Method
reserve
Reserve space for the given total amount of data. If the current capacity is already larger than the newly requested capacity, this is a no-op (i.e. i
be/src/kudu/util/faststring.h:141
↓ 217 callers
Method
warn
be/src/gutil/threading/thread_collision_warner.cc:13
↓ 215 callers
Method
iterator
be/src/kudu/util/bitset.h:180
↓ 214 callers
Method
get_metric_value
Returns the value of the the given metric name from the Impala debug webpage
tests/common/impala_service.py:100
↓ 212 callers
Method
RewritesOk
(String exprStr, ExprRewriteRule rule, String expectedExprStr)
fe/src/test/java/org/apache/impala/analysis/ExprRewriteRulesTest.java:172
↓ 206 callers
Method
processEvents
Implements the core logic of processing external events
fe/src/main/java/org/apache/impala/catalog/events/ExternalEventsProcessor.java:77
↓ 206 callers
Method
start
Start the event processing. This could also be used to initialize the configuration like polling interval of the event processor
fe/src/main/java/org/apache/impala/catalog/events/ExternalEventsProcessor.java:32
↓ 205 callers
Method
collect
Add all nodes in the tree that satisfy 'predicate' to the list 'matches' This node is checked first, followed by its children in order. If the node it
fe/src/main/java/org/apache/impala/common/TreeNode.java:117
↓ 204 callers
Method
erase
Removes 'val' from the set if it exists.
be/src/kudu/util/bitset.h:79
↓ 197 callers
Method
Add
be/src/exprs/agg-fn-evaluator.h:255
↓ 196 callers
Method
max
(CoreCount core1, CoreCount core2)
fe/src/main/java/org/apache/impala/planner/CoreCount.java:136
↓ 195 callers
Method
root
be/src/kudu/util/jsonreader.h:93
↓ 194 callers
Method
append
(LoggingEvent loggingEvent)
fe/src/test/java/org/apache/impala/util/TestRequestPoolService.java:272
↓ 193 callers
Method
find
be/src/util/in-list-filter.h:164
↓ 193 callers
Method
getKey
Util method to generate a database deletion entry value from a {@link Database} object.
fe/src/main/java/org/apache/impala/catalog/events/DeleteEventLog.java:142
↓ 192 callers
Method
skip
be/src/exec/parquet/parquet-byte-stream-split-test.cc:248
↓ 191 callers
Function
run_impala_shell_cmd
Runs the Impala shell on the commandline. 'shell_args' is a string which represents the commandline options. Returns a ImpalaShellResult.
tests/shell/util.py:124
↓ 189 callers
Method
createAnalysisCtx
(String defaultDb)
fe/src/test/java/org/apache/impala/analysis/AnalyzeAuthStmtsTest.java:69
↓ 188 callers
Method
wait_for_metric_value
(self, metric_name, expected_value, timeout=10, interval=1, allow_greater=False)
tests/common/impala_service.py:143
↓ 186 callers
Method
GetValue
be/src/kudu/util/semaphore.cc:93
↓ 183 callers
Function
$
(t)
www/datatables/DataTables-1.13.2/js/jquery.dataTables.min.js:4
↓ 182 callers
Method
Instantiate
be/src/kudu/util/metrics.cc:206
↓ 180 callers
Method
AddBenchmark
be/src/util/benchmark.cc:126
↓ 180 callers
Function
t
(n)
www/d3.v3.min.js:1
↓ 179 callers
Method
markEvent
Saves an event at the current time with the given label. It returns the duration in nano seconds between the last and the current event.
fe/src/main/java/org/apache/impala/util/EventSequence.java:57
↓ 179 callers
Method
match
(String actual, String expected)
fe/src/test/java/org/apache/impala/authorization/AuthorizationTestBase.java:589
↓ 178 callers
Method
ToString
Return a string that contains the copy of the referenced data.
be/src/kudu/util/slice.cc:38
↓ 177 callers
Method
impl
Returns the underlying opaque implementation object. The UDF/UDA should not use this. This is used internally.
be/src/udf/udf.h:271
↓ 174 callers
Method
AddCounter
be/src/util/metrics.h:423
↓ 174 callers
Method
GetString
be/src/util/process-state-info.cc:62
↓ 173 callers
Method
empty
Returns whether the set is empty.
be/src/kudu/util/bitset.h:96
↓ 173 callers
Method
node
be/src/kudu/util/yamlreader.h:70
↓ 172 callers
Method
getMetaStoreTable
@return the metastore.api.Table object this Table was created from. Returns null if the derived Table object was not created from a metastore Table (e
fe/src/main/java/org/apache/impala/catalog/FeTable.java:72
↓ 171 callers
Method
byte_size
be/src/runtime/descriptors.h:633
↓ 170 callers
Method
set
be/src/kudu/util/mt-threadlocal-test.cc:257
↓ 166 callers
Method
unlock
(UnlockRequest unlockRequest)
fe/src/main/java/org/apache/impala/catalog/metastore/MetastoreServiceHandler.java:2320
↓ 165 callers
Method
equals
Returns true if two expressions are equal. The equality comparison works on analyzed as well as unanalyzed exprs by ignoring implicit casts. If overri
fe/src/main/java/org/apache/impala/analysis/Expr.java:1043
↓ 165 callers
Method
getEventId
()
fe/src/main/java/org/apache/impala/catalog/events/MetastoreEvents.java:713
↓ 164 callers
Function
SleepFor
be/src/kudu/util/monotime.cc:272
↓ 162 callers
Method
Add
be/src/util/hdfs-bulk-ops.cc:165
↓ 162 callers
Function
isNaN
(value)
www/dagre-d3.min.js:48
↓ 162 callers
Method
name
Returns the name of the function. Multiple functions may have the same name. For example, COUNT will have a separate Func class for the analyti
tests/comparison/funcs.py:130
↓ 160 callers
Method
test
()
fe/src/test/java/org/apache/impala/catalog/CatalogTableWriteIdTest.java:44
↓ 160 callers
Function
time
(name,fn)
www/dagre-d3.min.js:46
↓ 157 callers
Method
equals
(RelOptCost other)
java/calcite-planner/src/main/java/org/apache/impala/calcite/schema/ImpalaCost.java:109
↓ 156 callers
Method
check_response
(response, expected_status_code = TCLIService.TStatusCode.SUCCESS_STATUS,
tests/hs2/hs2_test_suite.py:142
↓ 156 callers
Method
select
(Select select)
fe/src/main/java/org/apache/impala/analysis/QueryStringBuilder.java:133
↓ 156 callers
Method
toString
()
fe/src/main/java/org/apache/impala/planner/PlanId.java:38
↓ 155 callers
Method
isEmpty
()
fe/src/main/java/org/apache/impala/catalog/iceberg/GroupedContentFiles.java:99
↓ 154 callers
Method
end
be/src/service/query-state-record.cc:502
↓ 152 callers
Method
concat
(List<Expr> lhs, List<Expr> rhs)
fe/src/main/java/org/apache/impala/analysis/ExprSubstitutionMap.java:152
↓ 150 callers
Function
$
(t)
www/datatables/DataTables-1.13.2/datatables.min.js:16
↓ 147 callers
Method
end
be/src/scheduling/scheduler.h:145
↓ 147 callers
Method
exists
(self, path)
tests/util/adls_util.py:63
↓ 146 callers
Method
getChildren
()
fe/src/main/java/org/apache/impala/common/TreeNode.java:51
↓ 146 callers
Method
load
be/src/codegen/codegen-fn-ptr.h:53
↓ 145 callers
Method
total_time_counter
Returns the counter for the total elapsed time.
be/src/util/runtime-profile.h:209
↓ 144 callers
Method
create_impala_client
Create a new ImpalaConnection client. This client is registered at the class level and will be cleaned up during test method teardown. This s
tests/common/impala_test_suite.py:424
↓ 143 callers
Method
data
be/src/runtime/io/disk-file.h:89
↓ 143 callers
Method
substr
be/src/gutil/strings/stringpiece.cc:218
↓ 141 callers
Method
exploration_strategy
(cls)
tests/common/impala_test_suite.py:1569
↓ 140 callers
Method
getDesc
()
fe/src/main/java/org/apache/impala/analysis/SlotRef.java:294
↓ 140 callers
Method
wait_for_event_processing
(test_suite, timeout=10, error_status_possible=False)
tests/util/event_processor_utils.py:86
↓ 139 callers
Method
consumption
Returns the memory consumed in bytes.
be/src/runtime/mem-tracker.h:302
↓ 138 callers
Method
next
()
fe/src/main/java/org/apache/impala/util/IntIterator.java:23
↓ 137 callers
Method
add
Adds a version number to the collection of versions for in-flight events. If the collection is already at the max size defined by <code>MAX_NUMBER_OF_
fe/src/main/java/org/apache/impala/catalog/events/InFlightEvents.java:106
↓ 137 callers
Method
value
Returns a copy of the underlying storage. We cannot return a reference or pointer because it may be unaligned (this class is packed) and unaligned poi
be/src/runtime/decimal-value.h:184
↓ 136 callers
Method
Wait
be/src/kudu/util/subprocess.cc:544
↓ 136 callers
Method
equals
(Object o)
fe/src/test/java/org/apache/impala/util/RandomHiveQueryRunner.java:254
↓ 135 callers
Method
data
be/src/kudu/util/array_view.h:106
↓ 134 callers
Method
Ptr
be/src/runtime/string-value.h:110
↓ 134 callers
Function
abs
abs() is not defined for int128_t. Name it abs() so it can be compatible with native int types in templates.
be/src/runtime/multi-precision.h:121
↓ 134 callers
Method
id
be/src/exec/exec-node.h:286
↓ 132 callers
Method
Len
be/src/runtime/string-value.h:96
← previous
next →
101–200 of 43,496, ranked by callers