Allocates a {@code String} object representing the {@code value} argument. @param value the value of the {@code String}.

Adds a {@link ErrorRecord} to the error collector. @param record

Adds a class that extends from <code>AbstractDirective</code> to usage registry. @param classz representing an AbstractDirective</code> implementatio

Creates a merged record after iterating through all rows. @param rows list of all rows. @return A single record will rows merged across all columns.

Converts a Wrangler {@link Row} into a {@link StructuredRecord}. @param row defines a single {@link Row} @param schema Schema associated with {@li

Delete the given workspace @param workspaceId the workspace id to delete @throws WorkspaceNotFoundException if the workspace is not found

Executes the directives on the record specified and returns the results as well as the errors. @param recipe to be executed. @param rows to be execut

Dereferences an alias if defined, else returns the directive itself. @param directive to be dereferenced. @return dereferenced directive or null.

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

@return List of directives specified by the user.

Constructs a list of {@link Field}s that map table column names to values @param namespaceField table column name for storing namespace name @param ge

Constructs a ProgramFailureException using the provided exception details. @param exception the exception to wrap @param errorSubCategory spec

Get the Recipe associated with given recipe Id @param recipeId id of the recipe to fetch @return {@link Recipe} metadata for given recipe id @throws R

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

Checks if a variable exists in the context. @param name of the variable to be checked. @return true if found, false otherwise.

Initializes this validator. @throws Exception thrown when reserved words file is not accessible.

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

This function checks if the type is wrangle-able of not. <p>It detects it based on the type, currently we only support types that are of MIME type 't

Loads the data models located at the url. All available data models should be listed within a manifest.json file found at the root of the url. The man

Parses the recipe provided to this class and instantiate a list of {@link Directive} from the recipe. @return List of {@link Directive}.

Pick up the latest artifact, this method assumes the name of the artifact is same

Get the nth power of a decimal

This methods provides an efficiently way to read a file from the file system specified by the <code>Location.</code>. It uses a bounded line stream th

Iterates through each key of the object, and depending on the type of the object -- either it being {@link JsonArray} or {@link JsonObject}, it proces

Deletes a specified version of the schema. TODO: (CDAP-14661) update latest version pointer if the latest version was removed @param id of the schem

Updates an existing connection in the store. @param id the id of the object to be update @param meta metadata to update @throws ConnectionNotFoundExc

@return a <code>String</code> array providing the categories the directive is associated with.

@return a <code>String</code> type specifying the definition information of directive.

This method provides a way for the directive to de-initialize or destroy the resources that were acquired during the initialization phase. This method

Converts the string representation of type into a {@link DataType}. @param text representation of the type. @return an instance of {@link DataType} b

<code>string email = 3;</code>

Get the Recipe associated with given recipe name if it exists, else throws {@link RecipeNotFoundException} @param namespace @param recipeName @return

Increments a measure counter for a column. @param column name of the column @param measure to be incremented for a column.

Detect if the given value is a date type. <br> @param value the value to be detected. @return true if the value is a date type, false otherwise.

Detect if the given value is a double type. <p> Note:<br> 1. This method support only English locale.<br> e.g. {@code TypeInference.isDouble("3.4")}

Get a paginated list of recipes in given namespace @param request {@link RecipePageRequest} that contains necessary query parameters @return {@link Re

Loads and parses an AVRO data model schema. @return a map with keys representing the name of the schema. The value is a set of all of the revisions o

Loads the driver and gets the connection to the database. @param connection the connection to be connected to.

Multiply the column by a given value

Return whether the header needs to be copied when creating the pipeline source for the specified workspace. This just amounts to checking whether pars