List the directives in the specified namespace @param namespace the namespace to list from @return directives in the specified namespace

Same as calling {@link #compile(ELRegistration, String)} using {@link DefaultFunctions}.

Get all the workspaces in the given namespace @param namespace the namespace to look up @return the list of workspaces in this namespace

This method checks if there exists a token named <code>name</code> registered with this object. The <code>name</code> is expected to the same as spec

Get the field value from the given record @param input input record @param fieldName field name to get value from @return the value of the field in t

Update the sample data for the specified workspace. @param id the workspace id @param data the sample data @throws WorkspaceNotFoundException if the

Get the upgrade state

@return A transient store.

Indicates whether the <code>Reader has more lines. If there is an <code>IOException then {@link #close()} will be called on this instance. @return <c

Arithmetic operation - Find the minimum of any number of columns, of any valid types. Output type is most general of input types. Returns null if any

Utility method for creating ValidationExceptions without access to the proper constructor.

@return Content as received by the HTTP multipart/form body.

Returns a instance of {@link SchemaRegistryClient} initialized with service url. @param context of the pipeline in which this client is invoked. @ret

Extracts the HTTP header, if the header is not present, then default value is returned. @param name of the HTTP header to be extracted. @param defaul

Creates a workspace. Following is the response { "status" : 200, "message" : Successfully created workspace 'test'. } @param request Handler fo

@return Recipe specification associated with the request.

Arithmetic operation - Find the maximum of any number of columns, of any valid types. Output type is most general of input types. Returns null if any

<code>string name = 1;</code>

Writes an entry in the schema registry. If the schema already exists, it is overwritten. @param schemaDescriptor information about the schema to writ

Compiles the recipe that is supplied in a <code>String</code> format. @param recipe representing the <code>String</code> form of recipe. @return <cod

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

A static method to create instance of <code>BoundedLineInputStream</code>. This method creates the instance specifying the character encoding and numb

set credentials and project_id if those are provided in the input connection

This method provides a way to add a <code>Token</code> to the <code>TokenGroup</code>. @param token to be added to the token group.

Cleanse the given reference name. This method will remove all the disallowed characters in the given reference name. For example, 111-22-33(1).csv wil

Configures the {@link AvroSchemaGlossary} with the schemas accessible through the {@link AvroSchemaLoader}. @return true if successfully configure, o

Arithmetic operation - divides one column by another. Output type is Double, except when there is an input of type BigDecimal, in which case the outpu

Arithmetic operation - divides one column by another and returns the remainder. Output type is most general of input types, except 2 Shorts should giv

Accessor for the data model glossary. @return the {@link AvroSchemaGlossary} instance.

@param type the expected type @param value the value to be detected @return true if the type of value is expected, false otherwise.

Generates a {@link Schema} given a row. @param id Schema id @return returns {@link Schema} @throws UnsupportedTypeException @throws JSONException

Add a value to a column

Creates a new workspace @param namespace the namespace to create the workspace in @param meta the workspace metadata @return the id of the newly crea

Utility function to convert a number type to BigDecimal

Remove consecutive repeated characters by a specified char. @param input the source String @return the string with the source string removed if found

@param recipe directives to be executed. @param rows input data @param inputSchema {@link Schema} of the input data @return {@link Schema} of output a

Get a specific version of the specified schema. @param id the schema id @param version the entry version to get @return the schema entry @throws Sche

Create/update the workspace from given workspace. @param workspaceId the id of the workspace @param workspace workspace to create/update

Arithmetic operation - calculate average of any number of columns. Returns Number - BigDecimal if any column is of type BigDecimal, double otherwise.

Drops a path from the schema to generate a new {@link Schema}. @param schema to be modified. @param path to be removed from {@link Schema}. @return m

Get a ConnectionMeta object from the request body. @return the connection meta object @throws IllegalArgumentException if the body is empty or not a

@return {@link Schema} of the input data before transformation

Return all versions of the specified schema. @param id the schema id @return list of schema versions @throws SchemaNotFoundException if the schema do

Arithmetic operation - calculates the LCM of two columns. Output type is most general of input types. Returns null if any input value is null.

Arithmetic operation - subtract a column from another column. Output type is most general of input types. Returns null if any input value is null.

@return List of the objects of type T.

@return Version of specification of request.

Checks if schema id and version combination exists in the registry. @param id of the schema to be checked @param version version of the schema to be

This method provides a way for the custom directive writer the ability to access the arguments passed by the users. <p>This method is invoked only on

Migrates each directive from one version to other. @return directives transformed into a newer version.