Class | Description |
---|---|
AsyncLookupJoinRunner |
The async join runner to lookup the dimension table.
|
AsyncLookupJoinWithCalcRunner |
The async join runner with an additional calculate function on the dimension table.
|
DelegatingResultFuture<OUT> |
Delegates actions of
CompletableFuture to ResultFuture . |
KeyedLookupJoinWrapper |
The lookup join handler which holds a
LookupJoinRunner to process lookup for insert or
update_after record and directly process delete and update_before record via local state. |
LookupJoinRunner |
The join runner to lookup the dimension table.
|
LookupJoinWithCalcRunner |
The join runner with an additional calculate function on the dimension table.
|
ResultRetryStrategy |
A utility class to wrap the data stream api
AsyncRetryStrategy to support both sync and
async retry in table module. |
RetryableAsyncLookupFunctionDelegator |
A delegator holds user's
AsyncLookupFunction to handle retries. |
RetryableLookupFunctionDelegator |
A delegator holds user's
LookupFunction to handle retries. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.