Shutdown the events processor. Cannot be restarted again.

Collects basic info of a partition level topic item.

Helper function to assert that a specific OpenTelemetry attribute exists in a span.

* Fire callback functions and trigger events. Note that the loop over the * callback array store is done backwards! Further note that you do not wan

* Fire callback functions and trigger events. Note that the loop over the * callback array store is done backwards! Further note that you do not wan

Add a warning that will be displayed to the user. Ignores null messages. Once getWarnings() has been called, no warning may be added to the Analyzer a

A shorthand for create_impala_client with test vector as input. Vector must have 'protocol' and 'exec_option' dimension. Return a client of sp

Drops the table from this catalog. If purge is true, delete all data and metadata files in the table. Return true if the table was dropped, false if t

@return an unmodifiable list of all columns, but with partition columns at the end of the list rather than the beginning. This is equivalent to the or

Util method to return the fully qualified table name which is of the format dbName.tblName for this event

@return the file descriptors that were loaded after an invocation of load()

Returns the current method name. Note: this method may be expensive. Use it judiciously.

Selects a random impalad from the list of known processes

This method is to set the event executor status without actually starting it. It is only for testing and must not be used anywhere else. @param status

@param [in] msg The informational message on the error. @param [in] msg2 Additional information on the error (optional). @param [in] posix_code POSIX

Convert time point 't' into date-time string at precision 'p'. Output string is in UTC time zone if 'utc' is true, else it is in the local time zone.

Cancels an in-flight operation

Convenience function for creating a function class. The class is put into the global namespace just as though the class had been declared using t

Returns the configuration.

Get query profile. Might hit exception if QueryState has been released.

Returns a pointer to the underlying histogram. The implementation of HdrHistogram is thread safe.

@see CatalogObject#isLoaded()

Log 'message' at INFO level, along with id of 'operation_handle'.

Computes and returns the product of two cardinality numbers. If an overflow occurs, the maximum Long value is returned (Long.MAX_VALUE). Both number s

Walk through impala query plan and parse each section accordingly. A section ends when delimiter of that section is found.

Asserts that Impala has the given number of rows in its result set cache. Also sanity checks the metric for tracking the bytes consumed by the cac

Helper method to get debug string with helpful event information prepended to the message. This can be used to generate helpful exception messages @p

Tries to fetch exactly 'size' rows from the given query handle, with the given fetch orientation, by repeatedly issuing fetch(size - num rows alre

Returns the values associated with this partition. @return an immutable list of partition key expressions