Package | Description |
---|---|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
com.pervasive.datarush.operators.group |
Provides data aggregation components.
|
com.pervasive.datarush.operators.io.jdbc |
Provides operators for reading from JDBC sources and writing to JDBC targets.
|
com.pervasive.datarush.ports.physical |
Provides classes and interfaces for accessing and producing the data flowing
between operators in a dataflow graph.
|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
com.pervasive.datarush.tokens |
Provides classes and utilities for working with data tokens.
|
Modifier and Type | Method and Description |
---|---|
RecordInputSelector |
ExecutionContext.getRecordInputSelector(List<RecordInput> inputs)
Creates a selector over the specified inputs.
|
Modifier and Type | Method and Description |
---|---|
protected RecordInput |
SortedGroupHandler.current(ExecutionContext ctx)
Returns the current copy of the input port
|
protected RecordInput |
SortedGroupHandler.lookahead(ExecutionContext ctx)
Returns the lookahead copy of the input port
|
Modifier and Type | Field and Description |
---|---|
protected RecordInput |
AbstractWriteToJDBC.AbstractWriteHelper.input |
Modifier and Type | Method and Description |
---|---|
RecordInput |
RecordInputSelector.readyInput()
Gets the currently ready input.
|
Modifier and Type | Method and Description |
---|---|
RecordInput |
RecordPort.getInput(ExecutionContext ctx)
Returns the physical input port associated with this logical input port.
|
RecordInput |
RecordPort.getInput(ExecutionContext ctx,
int copyNumber)
Returns the physical input port associated with the specified copy number
of this logical input port.
|
RecordInput |
ExternalRecordSink.getOutput()
Returns the external port that an external application can use to receive
data from this sink.
|
Constructor and Description |
---|
InputModificationCountProvider(RecordInput input)
Creates a change sequence based on the specified input port.
|
Copyright © 2020 Actian Corporation. All rights reserved.