Package | Description |
---|---|
com.pervasive.datarush.operators |
Provides classes and interfaces for developing dataflow operators.
|
com.pervasive.datarush.ports |
Provides classes and interfaces related to receiving and sending data in a dataflow graph.
|
Modifier and Type | Method and Description |
---|---|
PortSetting[] |
OperatorProxies.ExecutableOperatorProxy.getPortSettings(LogicalPort outputPort)
Public only as a matter of implementation; not intended for external use
|
protected PortSetting[] |
ExecutableOperator.getPortSettings(LogicalPort outputPort)
May be overridden to specify port settings for a given output port
|
Modifier and Type | Method and Description |
---|---|
static PortSetting |
PortSettings.batchSize(int size)
Specifies the port should publish pushed data in batches
of the specified size.
|
static PortSetting |
PortSettings.immediate()
Specifies that the port should immediately publish data
when pushed.
|
static PortSetting |
PortSettings.noSpooling()
Disables writers writing published batches to disk.
|
static PortSetting |
PortSettings.sizeByReaders(boolean enabled)
Specifies whether the initial writeahead for a port should
be automatically determined based on the number of readers.
|
static PortSetting |
PortSettings.spoolThreshold(int size)
Specifies the threshold at which the writer begins writing
published batches to disk.
|
static PortSetting |
PortSettings.writeahead(int size)
Specifies the number of unread batches which a port
can publish before blocking.
|
Modifier and Type | Method and Description |
---|---|
static EngineConfig |
PortSettings.apply(EngineConfig config,
PortSetting... settings)
Specifies the default properties for ports in the graph.
|
Copyright © 2016 Actian Corporation. All rights reserved.