Package | Description |
---|---|
org.apache.flink.table.runtime.operators.join.lookup |
Modifier and Type | Class and Description |
---|---|
class |
LookupJoinWithCalcRunner
The join runner with an additional calculate function on the dimension table.
|
Constructor and Description |
---|
KeyedLookupJoinWrapper(LookupJoinRunner lookupJoinRunner,
StateTtlConfig ttlConfig,
TypeSerializer<RowData> serializer,
boolean lookupKeyContainsPrimaryKey) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.