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

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

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

Given a key, returns the object of type T from the table. @param key to be used to retrieve the object. @return instance of type T object if found, e

@return original {@link Row} that errored.

@return Sampling specification associated with the request.

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

@return String representation of enum.

@return Version of specification of request.

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

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

Checks if the directive is aliased. @param directive to be checked for aliasing. @return true if the directive has an alias, false otherwise.

Static method to be used with jexl Checks if Point is inside any of the given polygonal geofences based on the winding number algorithm. @param latit

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

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

@return Returns an iterator to iterate through all the <code>DirectiveInfo</code> objects maintained within the registry.

Returns an iterator to the list of token groups maintained by this object. @return iterator to the list of tokens maintained.

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

List all kafka topics. @param request HTTP requets handler. @param responder HTTP response handler.

Adds a property to the connection. @param key to be added. @param value to be added.

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

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

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

Sets the created date in seconds for the connection. @param created date for the connection.

Sets the list of directives that make a recipe. @param directives List of directives that are part of recipe.

Sets the id for the connection. @param id to be set.

Sets the name for the connection. @param name of the connection.

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

Sets the time when the recipe was updated. @param updated unix timestamp of when recipe was updated.

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

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 list of {@link Row} into populated list of {@link StructuredRecord} @param rows Collection of rows. @param schema Schema associated with {

Validates that the project and credentials are either explicitly set in the connection or are available through the environment. @param connection th

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

Explores the path provided on the filesystem. @param path to be explored. @return Information about all the files/directories in the path. @throws Ex

Closes the iterator, handling null and ignoring exceptions. @param iterator the iterator to close

Returns true if connection identified by connectionName already exists

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

Deletes the entrie schema definition for the id specified. @param id of the schema.

Deletes the workspace. @param id to be deleted. @throws WorkspaceException thrown if there is issue deleting workspace.

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

Returns the root directive aliasee @param directive @return

Return the list of default connections to be created

@return Unix timestamp about when the recipe was created.

Parses the dataset whitelist in the connection properties into a set of DatasetId. The whitelist is expected to be a comma separated list of dataset i

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

Return the set of disabled connection types

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

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

<pre> Unique ID number for this person. </pre> <code>int32 id = 2;</code>

@return Abstract method implemented by the extending class to provide the key namespace.

@return String representation of enum.

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

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

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

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