Package | Description |
---|---|
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.util |
Provides common utilities
|
Modifier and Type | Method and Description |
---|---|
long |
RecordInput.stepUntil(long n,
Timeout timeout)
Advances the cursor position as many tokens as possible up to the specified
number of tokens, within a given amount of time.
|
long |
RecordInput.stepUntil(Timeout timeout)
Advances the cursor position of this input by one token, if it can be be done in
a given amount of time.
|
Modifier and Type | Field and Description |
---|---|
static Timeout |
Timeout.IMMEDIATE
Specifies a timeout which is always expired; that is, no period of time at all.
|
static Timeout |
Timeout.NEVER
Specifies a timeout which never expires; that is, an infinite period of time.
|
Modifier and Type | Method and Description |
---|---|
static Timeout |
Timeout.millis(long duration)
Creates a timeout expiring in the specified number of milliseconds from now.
|
Timeout |
Timeout.reset()
Resets the timeout to the full duration with which it was created.
|
static Timeout |
Timeout.seconds(long duration)
Creates a timeout expiring in the specified number of seconds from now.
|
static Timeout |
Timeout.timeout(long duration,
TimeUnit unit)
Creates a timeout expiring in the specified duration from now.
|
Copyright © 2024 Actian Corporation. All rights reserved.