This method checks if the write lock of 'catalog_' is unlocked. If it's still locked then it logs an error and unlocks it.

Create a new ImpalaConnection client for the specified impalad. This client is registered at the class level and will be cleaned up during te

Prints a row with the given fields into the builder The last field could be a multiline field, and the extra lines should be padded @param fields The

@return the file format within this partition as an HdfsFileFormat enum

Inserts a new StringValue. Returns a pair consisting of an iterator to the element in the set, and a bool denoting whether the insertion took place (t

The cardinality check performed by this method allows for a margin of error. Specifically, two cardinalities are considered equal as long as the diffe

Set query options by setting client configuration.

Helper method to assert a trace exists in the trace file with the required inputs for log file path, trace file path, and trace file line count

Given list of debug actions, execute the debug action pertaining to the given label. The debugActions string is of the format specified for the query_

@return a partition name formed by concatenating partition keys and their values, compatible with the way Hive names partitions

Returns all affected target columns. @return list of expressions

Atomically sets the value.

Returns a uniformly distributed value in the range [0..n-1] REQUIRES: n > 0

Returns the number of milliseconds that have passed since the Unix epoch. This is affected by manual changes to the system clock but is more suitable

Returns a timer named 'name'. If the timer does not exist, it is registered in the metrics registry.

Within end-to-end tests, get the cluster under test with settings detected from the environment.

Call the Register() RPC

JWTPublicKey member functions. Verify JWT's signature for the given decoded token with jwt-cpp API.

Creates a deep copy of this expr including its analysis state. The method is abstract in this class to force new Exprs to implement it.

Creates mock notification event from the given list of parameters. The message should be a legal parsable message from a real notification event.

@return the original select list items from the query

Returns the size in bytes of the fixed-length portion that a slot of this type occupies in a tuple.

@return the general type of this table (e.g. "TABLE" or "VIEW")

Returns the json for the given Impala debug webpage, eg. '/queries

Asserts that "select literal" analyzes ok and that the expectedType matches the actual type.

TODO: is there a way to tell the user the expr in a reasonable way? Plumb the ToSql() from the FE? TODO: de-dup warnings

Gets the first character of 'str'. Returns 'default_value' if 'str' is empty. In UTF-8 mode, the first code point is returned. Otherwise, the first ch

Run a shell command 'cmd'. If 'shouldSucceed' is true, the command is expected to succeed, otherwise it is expected to fail. Returns the output (stdou

Helper to run an input query as a given user.

Specifies the privilege the user needs to have.

Returns whether the Bloom filter is empty and hence would return false for all lookups.

Returns the TableName of the statement. It might be null, e.g. when ResetMetadataStmt is a global INVALIDATE METADATA. It's extracted before analyzing

Helper method that polls a given url and asserts the return code is ok and the response contains the input string.

Gets a random name used to create unique database or table

If 'this' is a SlotRef or a Cast that wraps a SlotRef, returns that SlotRef. Otherwise returns null.

Asserts if stmt passes analysis or the error string doesn't match and it is non-null.