Credentials of the authorized user connecting to ADLS Gen1

ADLS connection sample information.

Information about an ADLS directory entry.

Service to explore ADLS Gen1 filesystem.

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

Abstract handler which contains common logic for v1 and v2 endpoints TODO: CDAP-18015 Refactor and add unit test for methods in this class

Common functionality for wrangler services.

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

Information about an allowed JDBC driver plugin.

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

Cross-column operations for arithmetic

Tests {@link ArithmeticOperations}

An artifact.

Comparator for artifact summary

The {@link AvroSchemaGlossary} class is used for management of AVRO data model schema definitions.

The {@link AvroSchemaLoader} interface abstracts loading an AVRO data model schema definitions.

Thrown if user provided input is invalid.

Basic class to compute summary from a list of rows

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 BigQueryHandler}.

Plugin specification for a BigQuery pipeline source. TODO: (CDAP-14652) clean up this API. There is no reason for this class to exist.

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

Creates ConnectionMeta objects. @param <T> type of builder

Creates Connections.

Creates Workspace meta objects.

Builds ADLSDirectoryEntryInfo instances.

Builds S3ObjectInfo instances.

Creates a Recipe id object

Creates a Recipe meta object

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}

Creates a WorkspaceMeta instance. @param <T> type of builder

Creates Workspace objects.

Creates a {@link RecipePageRequest} object

Creates a RecipeRow storage object

Builds a SchemaRow.

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

Builder to create Mutation.

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}

Utility class that converts a {@link Row} column into another column.

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}

Statistics about the result of executing directives on a workspace.

Whether a column is valid or not.

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}

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}

Stores the DirectiveConfig and other config settings. The actual store just has two columns -- key and value. Currently the only thing it stores is t

Thrown when there is some conflict

Contains information about an issue that occurred when trying to validate some data (against a schema).

Conformer represents a type that can check whether some object instance of type T follows a set of restrictions (a schema) enforced by this conformer.

Basic connection object.

Thrown when a connection already exists when none is expected.

Discover for connection related operations

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

Metadata about a connection.

Thrown when a connection does not exist when one is expected to exist.

Response sent by listing connections endpoint @param <T>

Information about a sample taken using a connection. TODO: (CDAP-14652) check if these fields are all used/needed. For example, why are 'connection'

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

Tests for the {@link ConnectionStore}.

This class {@link ConnectionType} defines different connections from which the data is extracted. TODO: (CDAP-14619) make casing consistent. User req

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

ConnectionTypeInfo - sent as response in listing connection types

Upgrader for connections