This method reloads the directives from the artifacts into the registry. Any implementation of this method should provide support for deletes, updates

Sample the input elements, for each input element, generate its count following a poisson distribution. @param input Elements to be sampled. @return

Get the scale of a decimal value

Validates the T properties. @param name to be validated. @throws ValidatorException thrown when there are issues with validation.

Specifies a relation that has no cause but effect. @param targets a list of targets. @return a instance of {@link Mutation.Builder}.

Deletes the schema and all associated entries. @param id of the schema to delete @throws IOException if there was an error reading from or writing to

Attempts to detect the type of the file through extensions and by reading the content of the file. @param location of the file who's content type nee

Retrieves the {@link Schema} from the glossary. @param name the name of the schema to retrieve. @param revision the revision of the schema to retriev

@return Count of objects within the list.

Get the project id for the connection

Get information about the workspace. @param id the workspace id @return information about the workspace @throws WorkspaceNotFoundException if the wor

Sets a variable with the value. @param name of the variable. @param value of the variable.

Provided the sampling method as string, determine the enum type of {@link SamplingMethod}. @param from string for which the {@link SamplingMethod} in

@return Code associated with the error.

Trick, to extract the URI for a location. @param path to a Dataset. @return Location @throws URISyntaxException issue constructing the URI.

@return Measurements handler.

Return the "largest" (e.g. most general) type of the given numbers. Used for operations applied to columns of multiple types, in order to determine th

Traverses the causal chain of the given Throwable to find specific exceptions. If a terminal exception is found, it returns a corresponding ProgramFai

Checks if the directive should be excluded. @param directive to checked if it has to be excluded. @return true if directive is excluded, false otherw

Rewrites the directives in version 1.0 to version 2.0. @return directives converted to version 2.0.

Sets the name of the column at a given index. @param idx at which the new name to be set. @param name of the column to be set at idx.

Set the upgrade complete status for the entity type

Updates the value of the row at index idx. @param idx index at which the value needs to be updated. @param value value to be updated at index (idx).

Update the properties of the specified workspace. @param id the workspace id @param properties the properties to update @throws WorkspaceNotFoundExce

Arithmetic operation - Check if all values are equal across any number of Short columns.

Generates the list of {@link FieldOperation} required for generating lineage. @return a {@link List} of {@link FieldOperation}

Retrieve the directives available in the namespace

This method parses the JEXL function category from the given JEXL script and returns the metric if the category is present in {@link io.cdap.wrangler.

Get the workspace detail about the given workspace id @param workspaceId the id of the workspace to look up @return the workspace detail about the gi

Initializes the data model glossary with the data models located at the url. All available data models should be listed within a manifest.json file fo

Unsupported. @throws UnsupportedOperationException always

Remove all repeated white spaces which include all strings in {@link #WHITESPACE_CHARS} like as " ","\n","\r","\t". <pre> removeRepeatedWhitespaces(n

Resets the state of this store.

Returns the number of tokens that are mapped to arguments. <p>The optional arguments specified during the <code>UsageDefinition</code> are not includ

Converts a serialized object byte array back into object. @param bytes to be converted to object of type T. @return an instance of object deserialize

@return Returns the type of this <code>TokenDefinition</code>.

Creates a workspace if it does not already exist, or update an existing workspace if it does. @param id the id of the workspace to write @param meta

Static method to be used with jexl Checks if the coordinate is inside any of the given polygonal geofences based on the winding number algorithm. If a

A relation that's conditional, depending on whether source and target are same. @param source a instance of {@link String} source. @param target a in

@return connection information of kafka.

Returns the name of the directive for which the this <code>UsageDefinition</code> object is created. @return name of the directive.

Returns the full content of the error stream for the given {@link HttpURLConnection}.

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

Returns a valid service url. @param applicationId id of the application to which a service url. @param serviceId id of the service within application

Set of all the variables. @return list of all the variables.

Initialize the upgrade timestamp and state for the given upgrade types if not there and return the upgrade timestamp. This method should be called bef