public abstract class FlinkHints extends Object
Modifier and Type | Field and Description |
---|---|
static String |
HINT_NAME_OPTIONS |
Constructor and Description |
---|
FlinkHints() |
Modifier and Type | Method and Description |
---|---|
static Map<String,String> |
getHintedOptions(List<org.apache.calcite.rel.hint.RelHint> tableHints)
Returns the OPTIONS hint options from the given list of table hints
tableHints , never
null. |
static Map<String,String> |
mergeTableOptions(Map<String,String> hints,
Map<String,String> props)
Merges the dynamic table options from
hints and static table options from table
definition props . |
public static final String HINT_NAME_OPTIONS
public static Map<String,String> getHintedOptions(List<org.apache.calcite.rel.hint.RelHint> tableHints)
tableHints
, never
null.public static Map<String,String> mergeTableOptions(Map<String,String> hints, Map<String,String> props)
hints
and static table options from table
definition props
.
The options in hints
would override the ones in props
if they have the
same option key.
hints
- Dynamic table options, usually from the OPTIONS hintprops
- Static table options defined in DDL or connect APIprops
if there is
no dynamic table optionsCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.