Package | Description |
---|---|
com.pervasive.datarush.namespace |
Provides utilities for creating and managing collections of named
objects.
|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
com.pervasive.datarush.operators.io.jdbc |
Provides operators for reading from JDBC sources and writing to JDBC targets.
|
com.pervasive.datarush.types |
Provides classes and interfaces for the description of token data types.
|
Modifier and Type | Method and Description |
---|---|
static <T> Namespace<T> |
NamespaceUtil.merge(Namespace<? extends T>... namespaces)
Merges the specified namespaces into a new namespace, handling name collisions
by renaming.
|
static <T> Namespace<T> |
NamespaceUtil.overlay(Namespace<? extends T>... namespaces)
Merges the specified namespaces into a new namespace, handling name collisions
with a last-one-wins mechanism.
|
static <T> Namespace<T> |
NamespaceUtil.remove(Namespace<T> namespace,
Collection<String> excludeFields)
Creates a new namespace from an existing one, removing any fields matching the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.remove(Namespace<T> namespace,
String... excludeFields)
Creates a new namespace from an existing one, removing any fields matching the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.retain(Namespace<T> namespace,
Collection<String> retainFields)
Creates a new namespace from an existing one, copying any fields contained the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.retain(Namespace<T> namespace,
String... retainFields)
Creates a new namespace from an existing one, copying any fields matching the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.select(Namespace<T> namespace,
List<String> selectFields)
Creates a new namespace from an existing one, copying the specified fields.
|
static <T> Namespace<T> |
NamespaceUtil.select(Namespace<T> namespace,
String... selectFields)
Creates a new namespace from an existing one, copying the specified fields.
|
Namespace<T> |
NamespaceBuilder.toNamespace()
Constructs the currently defined namespace.
|
static <T> Namespace<T> |
NamespaceUtil.wrap(String prefix,
List<? extends T> flows)
Creates a new namespace with the specified flows.
|
static <T> Namespace<T> |
NamespaceUtil.wrap(String prefix,
T... flows)
Creates a new namespace with the specified flows.
|
static <T> Namespace<T> |
NamespaceUtil.wrap(String name,
T flow)
Creates a new namespace with specified flow as the named field.
|
Modifier and Type | Method and Description |
---|---|
void |
NamespaceBuilder.addAll(Namespace<T> entries)
Add all entries from a namespace into this namespace.
|
static <T> Namespace<T> |
NamespaceUtil.merge(Namespace<? extends T>... namespaces)
Merges the specified namespaces into a new namespace, handling name collisions
by renaming.
|
static <T> Namespace<T> |
NamespaceUtil.overlay(Namespace<? extends T>... namespaces)
Merges the specified namespaces into a new namespace, handling name collisions
with a last-one-wins mechanism.
|
static <T> Namespace<T> |
NamespaceUtil.remove(Namespace<T> namespace,
Collection<String> excludeFields)
Creates a new namespace from an existing one, removing any fields matching the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.remove(Namespace<T> namespace,
String... excludeFields)
Creates a new namespace from an existing one, removing any fields matching the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.retain(Namespace<T> namespace,
Collection<String> retainFields)
Creates a new namespace from an existing one, copying any fields contained the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.retain(Namespace<T> namespace,
String... retainFields)
Creates a new namespace from an existing one, copying any fields matching the
provided set of names.
|
static <T> Namespace<T> |
NamespaceUtil.select(Namespace<T> namespace,
List<String> selectFields)
Creates a new namespace from an existing one, copying the specified fields.
|
static <T> Namespace<T> |
NamespaceUtil.select(Namespace<T> namespace,
String... selectFields)
Creates a new namespace from an existing one, copying the specified fields.
|
Modifier and Type | Method and Description |
---|---|
Namespace<LogicalPort> |
LogicalOperator.getInputPorts()
Returns the list of input ports.
|
Namespace<LogicalPort> |
AbstractLogicalOperator.getInputPorts() |
Namespace<LogicalPort> |
LogicalOperator.getOutputPorts()
Returns the list of output ports.
|
Namespace<LogicalPort> |
AbstractLogicalOperator.getOutputPorts() |
Modifier and Type | Method and Description |
---|---|
static Namespace<JDBCField> |
ConnectionHelper.extractFields(ResultSetMetaData rsmd) |
static Namespace<JDBCField> |
ConnectionHelper.getMetadata(JDBCConnector connector,
String statement)
Acquires the metadata associated with a given SQL statement.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RecordTokenType
A description of a record data type.
|
Modifier and Type | Method and Description |
---|---|
static RecordTokenType |
TypeUtil.toType(DataRepresentation representation,
Namespace<ScalarTokenType> namespace)
Converts from a list of fields to a record token type.
|
Copyright © 2021 Actian Corporation. All rights reserved.