public interface ActionFactory extends Factory
Action
.Modifier and Type | Field and Description |
---|---|
static String |
CATALOG_CONF |
static String |
DATABASE |
static String |
EXPIRATIONTIME |
static String |
EXPIRE_STRATEGY |
static String |
HELP |
static org.slf4j.Logger |
LOG |
static String |
PARTITION |
static String |
PATH |
static String |
TABLE |
static String |
TABLE_CONF |
static String |
TIMESTAMP_PATTERN |
static String |
TIMESTAMPFORMATTER |
static String |
WAREHOUSE |
Modifier and Type | Method and Description |
---|---|
default void |
checkRequiredArgument(MultipleParameterToolAdapter params,
String key) |
Optional<Action> |
create(MultipleParameterToolAdapter params) |
static Optional<Action> |
createAction(String[] args) |
default List<Map<String,String>> |
getPartitions(MultipleParameterToolAdapter params) |
default String |
getRequiredValue(MultipleParameterToolAdapter params,
String key) |
default org.apache.flink.api.java.tuple.Tuple3<String,String,String> |
getTablePath(MultipleParameterToolAdapter params) |
default Map<String,String> |
optionalConfigMap(MultipleParameterToolAdapter params,
String key) |
default Map<String,List<String>> |
optionalConfigMapList(MultipleParameterToolAdapter params,
String key) |
static void |
printDefaultHelp() |
void |
printHelp() |
identifier
static final org.slf4j.Logger LOG
static final String HELP
static final String WAREHOUSE
static final String DATABASE
static final String TABLE
static final String PATH
static final String CATALOG_CONF
static final String TABLE_CONF
static final String PARTITION
static final String EXPIRATIONTIME
static final String TIMESTAMPFORMATTER
static final String EXPIRE_STRATEGY
static final String TIMESTAMP_PATTERN
Optional<Action> create(MultipleParameterToolAdapter params)
void printHelp()
static void printDefaultHelp()
default org.apache.flink.api.java.tuple.Tuple3<String,String,String> getTablePath(MultipleParameterToolAdapter params)
default List<Map<String,String>> getPartitions(MultipleParameterToolAdapter params)
default Map<String,String> optionalConfigMap(MultipleParameterToolAdapter params, String key)
default void checkRequiredArgument(MultipleParameterToolAdapter params, String key)
default String getRequiredValue(MultipleParameterToolAdapter params, String key)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.