Gets the different tables from the hashmap and returns them as a set as some of our uses of this class were expecting @return The complete set of tabl

* gets all the message ids */

input: LogicalComputeWindow(min_keys=[MIN($0) OVER (PARTITION BY $2 ORDER BY $1)], max_keys=[MAX(4) OVER (PARTITION BY $2 ORDER BY $1)], lead_val=[LEA

input: CAST($0):TIMESTAMP output: 0

* Tries to get up to num_files data_handles. We use this instead of a get_all() because if there are too many files, * trying to get too many file h

* Checks if metadata has a specific key * @param key The key to check if is in the metadata * @return true if the key is in the metadata, otherwise

Initializes the application context by calling the private constructor if necessary before any operations occur.

Due to `avg` window aggregation the OVER clause is repeated three times from Calcite something like: CAST(/(CASE(>(COUNT($0) OVER (PARTITION BY $1), 0

Due to `sum` window aggregation the OVER clause is repeated two times from Calcite something like: CASE(>(COUNT($0) OVER (PARTITION BY $1), 0), $SUM0(

Creates a ProjectKernel using a valid `project_plan`

Calls put() and passes msg on a WaitingQueue instance pointer after waiting delayMs

* Put a vector of messages onto the WaitingQueue without locking. * @param messages A vector of messages that will be pushed into the WaitingQueue.

TODO: Rommel Use randomeString from StringUtil

Creates two CacheMachines and register them with the `project_kernel`

input: max_prices=[MAX($0) OVER (PARTITION BY $2 ORDER BY $0, $1)] output: max_prices=[MAX($0)]

* Checks a node for validity as a Sizzle context * @param {Element|Object=} context * @returns {Element|Object|Boolean} The input node if acceptable