This class {@link AbstractAvroDecoder} is implementation of {@link Decoder} interface using type {@link Row}. All implementations of AVRO decoder shou

This abstract class {@link AbstractTableStore} is an abstraction over the generic table with ability to store multiple type of objects. Any type of st

<pre> Our address book file is just one of these. </pre> Protobuf type {@code tutorial.AddressBook}

This class {@code Arguments} represents the wrapped tokens that are tokenized and parsed arguments provided to the {@code Executor}. This class <code

Created by nitin on 2/4/17.

Tests {@link BasicStatistics}

A sampler implementation built upon a Bernoulli trail. This sampler is used to sample with fraction and without replacement. Whether an element is sam

Service for testing, browsing, and reading using a BigQuery connection.

Tests for {@link BigQueryService}.

This class {@link BinaryAvroDecoder} decodes a byte array of AVRO Json Records into the {@link Row} structure.

Tests {@link BinaryAvroDecoder}

The Bool class wraps the primitive type {@code Boolean} in a object. An object of type {@code Bool} contains the value in primitive type as well as th

The Bool List class wraps the list of primitive type {@code Boolean} in a object. An object of type {@code BoolList} contains the value as a {@code Li

This class provides an wrapper over the {@link InputStream} that limits the number of lines being read from the file. Uses a <code>BufferedReader</co

Tests {@link BoundedLineInputStream}

Holds GCS {@link Bucket} and whether number of buckets added has exceeded the limit. This is a workaround for CDAP-14446 and should be removed once pa

Protobuf type {@code tutorial.Person.PhoneNumber}

<pre> [START messages] </pre> Protobuf type {@code tutorial.Person}

<pre> Our address book file is just one of these. </pre> Protobuf type {@code tutorial.AddressBook}

This inner class provides a builder pattern for building the <code>RecipeSymbol</code> object. In order to create the this builder, one has to use the

This inner builder class provides a way to create <code>UsageDefinition</code> object. It exposes different methods that allow users to configure the

Class description here.

A directive that looks up ICD Code from the catalog.

Tests {@link CatalogLookup}

This class <code>ChangeColCaseNames</code> converts the case of the columns to either lower-case or uppercase.

Tests {@link ChangeColCaseNames}

A directive implements unix cut directive.

Tests {@link CharacterCut}

A directive for cleanses columns names. <p> <ul> <li>Lowercases the column name</li> <li>Trims space</li> <li>Replace characters other

Tests {@link CleanseColumnNames}

A directive for apply an expression to store the result in a column. The expressions are specified in JEXL format (http://commons.apache.org/proper/c

This class stores and manages {@link Measurements} for each column.

Class description here.

This class performs validation on the column names of the record. <p> Following are the checks that this validator performs on the column. <ul>

Tests {@link ColumnNameValidator}

Applies a sed expression on the column names. This directive helps clearing out the columns names to make it more readable.

Tests {@link ColumnsReplace}

This class <code>CompileException</code> is thrown when there is any issue with compiling the <code>Recipe</code>. It's content include the exact line

This class <code>CompileStatus</code> contains the status of compilation. If there are errors - syntax or semnatic it records the details of the error

This <code>Compiler</code> interface provides a way to implement your own version of compiler for directive or recipe. <p>This interface contains met

This class implements a Composition of multiple registries. <p>It implements the <tt>DirectiveRegistry</tt> interface. Search for a directives uses t

Tests {@link CompositeDirectiveRegistry}

This class <code>CompositeRegistryIterator</code> iterators each of the registeries in entirity before moving on to the next registry managed by the <

Config for the plugin.

This class {@link ConfigDirectiveContext} manages the context for directive by either retrieving the configuration from a service or from a provided i

Tests {@link NoOpDirectiveContext}

Basic connection object.

Response sent by listing connections endpoint @param <T>

This service exposes REST APIs for managing the lifecycle of a connection in the connection store.

This class {@link ConnectionStore} manages all the connections defined. It manages the lifecycle of the {@link Connection} including all CRUD operatio

Tests {@link Connection}

This class {@link ConnectionType} defines different connections from which the data is extracted.

Default connections to create at startup and connection types that needs to be disabled

ConnectionTypeInfo - sent as response in listing connection types

Class description here.

Class for converting distances from one to another.

Tests {@link ConvertDistances}

Useful String conversion operations.

Class description here.

A directive for copying value of one column to another.

Tests {@link co.cask.directives.column.Copy}

A CSV Parser Stage for parsing the {@link Row} provided based on configuration.

Tests {@link CsvParser}

Structured Row and Schema DDL.

Tests {@link DDL}

Wrangler Application.

Data Quality Checks consolidated.

Tests {@link DataQuality}

Class that specifies type of data.

This class {@link DataType} defines types of data that can be stored in a workspace.

Class description here.

Class description here.

This class implements the provider pattern for providing dataset at runtime.

Collection of useful expression functions made available in the context of an expression. set-column column <expression>

A directive that decodes a column that was encoded as base-32, base-64, or hex.

Decoder interface for decoding the data.

This exception is thrown when there are issues related decoder.

@return List of registered functions.

This class implements a transient store interface for storing variables that can be set within a step and are available across all the steps when the

A directive for taking difference in Dates.

Directive is a user defined directive. DIE - Define, Initialize & Execute - Pattern Following is a simple example of how to use this interface. <code

This interface {@link DirectiveAlias} provides a way to check if a directive is aliased and if there it is aliased to what it is being aliased.

This class {@link DirectiveConfig} defines the configuration for the Wrangler. It specifies the directive exclusions -- meaning directives that should

Tests {@link DirectiveConfig} @see DirectiveConfig @see co.cask.wrangler.api.DirectiveAlias @see co.cask.wrangler.api.DirectiveEnforcer

{@link DirectiveContext} provides the context object to the processing of directives.

This class defines the interfaces that would provide the ability to check whether the user should be provided access to the directive being used.

A Executor specific exception used for communicating issues with execution of pipeline in that step.

This class <code>DirectiveInfo</code> contains information about each individual directive loaded. It also holds additional information like usage, de

Class description here.

Class description here.

Class description here.

An exception thrown when there is error in parsing specification.

A directive registry maintains a collection of directives either system provided or user provided. <p>The directive information is stored within the

Service for managing workspaces and also application of directives on to the workspace.