Returns the int value of event processor metric from the /events catalogd debug page

Returns the byte size of this type. Returns 0 for variable length types.

Get statistics about the cache (for monitoring/debugging). @return A human-readable string with cache statistics

Starts a scan. Called during query execution before any calls to getNext().

Removes a given version from the collection of version numbers for in-flight events. @param isInsertEvent If true, remove eventId from list of eventId

Waits for the given 'operation_handle' to reach the 'expected_impala_state'. 'expected_impala_state' must be a string of either 'INITIALIZED', 'PE

Return true if the given value is true (case-insensitive) or 1.

Sets the bit at 'bit_index' to v.

@return all partitions of this table

The allocated memory will be recycled in bulk after the UDF returns

The data buffer.

Allocates a section of memory of 'size' bytes with DEFAULT_ALIGNMENT at the end of the the current chunk. Creates a new chunk if there aren't any chun

Decrement the count of this latch by 'amount' If the new count is less than or equal to zero, then all waiting threads are woken up. If the count is a

Create result set from string 'summary', and attach it to 'response'.

Returns true if this expression should be treated as constant. I.e. if the frontend and backend should assume that two evaluations of the expression w

Returns the explicit alias or the fully-qualified implicit alias. The returned alias is guaranteed to be unique (i.e., column/field references against

Returns total time in cpu ticks for which the stopwatch was running, including the time since Start() was called, if it is currently running.

Returns the absolute path to the file.

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

Called by FeCatalogManager when new ImpalaCatalog is created and this one is no longer used. Wakes up all threads that wait for catalogUpdateEventNoti

Stores an event in sequence with the given label and the current time (relative to the first time Start() was called) as the timestamp.

Safe to call from PartitionedHashJoinNode threads during the probe phase.

Add an int at the end of the list.

Fetches query results up to max_rows given a handle and sql statement. Caller must ensure that query has passed PENDING state before calling fetch

Returns a new list of OrderByElements with the same (cloned) expressions but the ordering direction reversed (asc becomes desc, nulls first becomes nu

Stop the metastore service. @throws CatalogException

Draw the DOT format.

Helper function to read a certificate from the be/src/testutil directory.

If debug_action query option has a "global action" (i.e. not exec-node specific) and matches the given 'label' and 'args', apply the the action. See I

Runs a command in the Impala shell interactively.

Return a string representing an errno.