Deletes the specified connection. @param id the connection to delete

De-register all SQL drivers that are associated with the class

This method emits all metrics for the given list of directives @param directives a list of Wrangler directives @param metrics CDAP {@link Metrics} ob

Returns records that are errored out. @return records that have errored out.

Evaluates all the MACRO_FIELDS.

Evaluates all the MACRO_FIELDS.

Executes the pipeline on the input. @param rows List of Input record of type I. @param schema Schema to which the output should be mapped. @return Pa

Executes the directives on the record.

Executes the given list of directives on the given workspace locally in the same JVM. @param namespace the namespace to operate on for finding user d

Executes the given list of directives on the given workspace remotely using the task worker framework. @param namespace the namespace to operate on f

A method to fetch a file from an ADLS client @param connection Connection object @param fileQueryDetails @param namespaceID @throws IOException

Get the workspace name, the generation rule is like: 1. If the path is not null or empty, the name will be last portion of path starting from "/". If

Generates all json paths for the json being passed as a string. @param json string for which json paths need to be extracted. @return list of json pa

A value associated with the variable in the transient store. @param name of the variable to be retrieved. @return instance of object of type T.

Returns the root directive aliasee @param directive @return

Returns a <code>RecipeSymbol</code> for the recipe being parsed. This object has all the tokens that were successfully parsed along with source inform

Updates the configuration. @param request to gather information of the request. @param responder to respond to the service request.

Method to retrieve the spec that is known to connector/source, this is needed because the connection type handlers sometimes use a different config na

@return Context name.

@return time in second when the connection was created.

Get the default table column name using which results will be sorted.

@return a {@link DirectiveClass} which contains the class information of this directive.

Method to get the output schema of the directive. Returns a generated schema based on maintained map of fields only if directive does not return a cus

@return Environment this context is prepared for.

@return Multiplier to be applied when converting from base.

@return String representation of key deserializer of kafka topic.

Extracts all the macros within a string expression. @param expression specifies the expression. @return list of macros present within an expression.

@return Default {@link Messages} with resource bundle 'user' and default {@link Locale}

@return Method for sampling data.