Subtract a value from a column

Get the row from the given transform. @param record the record to transform @return the row corresponding to the record

Check if a given reference name is valid @param referenceName reference name to check

Walks the grammar tree generated by the recipe. @param recipe the recipe to parse @param visitor the visitor for walking the grammar tree @param <E>

Returns true when an expression evaluates to the null value. @param value to be evaluated. @return false when not null, true otherwise.

Get the absolute value

If any user directives was found, adds load-directives pragma as the first command.

Given a row, finds the length of the row. @param row length needs to be determined. @return length of the row.

Delete all connection with the namespace and generation id

@return a <code>String</code> type providing the description for a directive.

Execute the url provided, and return the response based on given type.

Executes the given list of directives on the given workspace. @param namespace the namespace to operate on for finding user defined directives @param

Executes directives by extracting them from request. @param id data to be used for executing directives. @param directives the list of directives to

Creates a {@link DirectiveInfo} of the given class coming from the {@link DirectiveScope#USER} scope.

Generates a MD5 hash for a given string. This implementation is based on Bouncycastle. So, you would need to initialize the security provider to use

@return Kafka connection property.

@return Set of columns tracked.

Get connection id for the given connection name @param name name of the connection. @return connection id.

@return Number of records to be read before applying directives.

@return Original line that has the syntax error.

Returns a set of dynamically loaded directives as plugins. These are the set of plugins or directives that are in the recipe, but are provided as the

Get a connector path from the v1 workspace @param connectionType connectionType of the workspace @param workspace the v1 workspace information @retur

@return original {@link Row} that errored.

@return Sampling specification associated with the request.

@return status of the processing on the backend.

Create and return {@link Storage} based on the credentials and project information provided in the connection

This method returns the list of <code>TokenDefinition</code> that should be used for parsing the directive into <code>Arguments</code>. @return List

This method attempts to detect the encoding type of the byte array being passed to it. @return String representation of the encoding.

Finds if the row has a column. @param row in which a column needs to be checked. @param column name of the column to be checked. @return true if colu

Increments a value of the variable. @param name of the variable. @param value associated with the variable.

Create an ADLS client using connection details from the HTTP request. @param connection connection details from the HTTP request. @return ADLStoreCli

Checks if the value is within the range. @param value to be checked if it's in the range. @param lower end of the defined range. @param upper end of

Creates a new instance of <code>Directive</code>. @return a <code>Directive</code> instance. @throws IllegalAccessException thrown when an applicatio

Detect if the given value is a boolean type. @param value the value to be detected. @return true if the value is a boolean type, false otherwise.

Checks if the directive is being excluded from being used. @param directive to be checked for exclusion. @return true if excluded, false otherwise.

Detect if the given value is a time type. @param value @return

Recursively flattens JSON until the 'depth' is reached. @param root of the JSONObject @param field name to be used to be stored in the row. @param de

Negate a decimal

@return true, if this <code>TokenDefinition</code> is optional, false otherwise.

@return a <code>Scope</code> type specifying either USER or SYSTEM scope the directive is deployed in.

Sets the read timeout in milliseconds. @param readTimeout

@return string representation of object.

Converts a list of {@link Row} into populated list of {@link StructuredRecord} @param rows Collection of rows. @param schema Schema associated with

Update a recipe @param recipeId id of the recipe @param recipeRow recipe to create/update