public class OlapConfigurations extends java.lang.Object implements ConfigurationDefault
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ACTIVE_TRANSACTION_CACHE_SIZE |
static java.lang.String |
DEFAULT_OLAP_LOG4J_CONFIG |
static boolean |
DEFAULT_SPARK_COMPACTION_BLOCKING |
static int |
DEFAULT_SPARK_COMPACTION_MAXIMUM_CONCURRENT |
static int |
DEFAULT_SPARK_COMPACTION_MAXIMUM_WAIT |
static int |
DEFAULT_SPARK_COMPACTION_RESOLUTION_BUFFER_SIZE |
static double |
DEFAULT_SPARK_COMPACTION_RESOLUTION_SHARE |
static java.lang.String |
OLAP_CLIENT_RETRIES |
static java.lang.String |
OLAP_CLIENT_TICK_TIME
The number of milliseconds the OLAP client should wait for performing a status check.
|
static java.lang.String |
OLAP_CLIENT_WAIT_TIME
The number of milliseconds the OLAP client should wait for a result.
|
static java.lang.String |
OLAP_LOG4J_CONFIG |
static java.lang.String |
OLAP_SERVER_BIND_PORT
The Port to bind the OLAP Server connection to
Defaults to 60014
|
static java.lang.String |
OLAP_SERVER_EXTERNAL
Run OlapServer externally on YARN
Defaults to true
|
static java.lang.String |
OLAP_SERVER_MEMORY |
static java.lang.String |
OLAP_SERVER_MEMORY_OVERHEAD |
static java.lang.String |
OLAP_SERVER_STAGING_DIR
The directory to use for staging files sent to the Olap Server
Defaults to NULL
|
static java.lang.String |
OLAP_SERVER_SUBMIT_ATTEMPTS |
static java.lang.String |
OLAP_SERVER_THREADS
Number of threads used by the Olap server, determines the maximum number of concurrent
Olap jobs
Defaults to 16
|
static java.lang.String |
OLAP_SERVER_TICK_LIMIT |
static java.lang.String |
OLAP_SERVER_VIRTUAL_CORES |
static java.lang.String |
OLAP_SHUFFLE_PARTITIONS |
static java.lang.String |
SPARK_COMPACTION_BLOCKING |
static java.lang.String |
SPARK_COMPACTION_MAXIMUM_CONCURRENT |
static java.lang.String |
SPARK_COMPACTION_MAXIMUM_WAIT |
static java.lang.String |
SPARK_COMPACTION_RESOLUTION_BUFFER_SIZE |
static java.lang.String |
SPARK_COMPACTION_RESOLUTION_SHARE |
Constructor and Description |
---|
OlapConfigurations() |
Modifier and Type | Method and Description |
---|---|
void |
setDefaults(ConfigurationBuilder builder,
ConfigurationSource configurationSource)
Called by
ConfigurationBuilder.build(ConfigurationDefaultsList, ConfigurationSource)
to give instances of this interface the opportunity to affect the configuration by setting
their default values for configuration properties. |
public static final java.lang.String OLAP_CLIENT_WAIT_TIME
public static final java.lang.String OLAP_CLIENT_TICK_TIME
public static final java.lang.String OLAP_SERVER_BIND_PORT
public static final java.lang.String OLAP_SERVER_THREADS
public static final java.lang.String OLAP_SERVER_TICK_LIMIT
public static final java.lang.String OLAP_CLIENT_RETRIES
public static final java.lang.String OLAP_SHUFFLE_PARTITIONS
public static final java.lang.String OLAP_SERVER_STAGING_DIR
public static final java.lang.String OLAP_SERVER_EXTERNAL
public static final java.lang.String OLAP_SERVER_SUBMIT_ATTEMPTS
public static final java.lang.String OLAP_SERVER_MEMORY
public static final java.lang.String OLAP_SERVER_MEMORY_OVERHEAD
public static final java.lang.String OLAP_SERVER_VIRTUAL_CORES
public static final java.lang.String ACTIVE_TRANSACTION_CACHE_SIZE
public static final java.lang.String SPARK_COMPACTION_MAXIMUM_WAIT
public static final int DEFAULT_SPARK_COMPACTION_MAXIMUM_WAIT
public static final java.lang.String SPARK_COMPACTION_MAXIMUM_CONCURRENT
public static final int DEFAULT_SPARK_COMPACTION_MAXIMUM_CONCURRENT
public static final java.lang.String SPARK_COMPACTION_RESOLUTION_SHARE
public static final double DEFAULT_SPARK_COMPACTION_RESOLUTION_SHARE
public static final java.lang.String SPARK_COMPACTION_RESOLUTION_BUFFER_SIZE
public static final int DEFAULT_SPARK_COMPACTION_RESOLUTION_BUFFER_SIZE
public static final java.lang.String SPARK_COMPACTION_BLOCKING
public static final boolean DEFAULT_SPARK_COMPACTION_BLOCKING
public static final java.lang.String OLAP_LOG4J_CONFIG
public static final java.lang.String DEFAULT_OLAP_LOG4J_CONFIG
public void setDefaults(ConfigurationBuilder builder, ConfigurationSource configurationSource)
ConfigurationDefault
ConfigurationBuilder.build(ConfigurationDefaultsList, ConfigurationSource)
to give instances of this interface the opportunity to affect the configuration by setting
their default values for configuration properties. These default values are only set if the
ConfigurationSource
does not already have a value for the given property. Otherwise,
we'll get the value that was previously set on the configuration source.
Example:
builder.ddlRefreshInterval = configurationSource.getLong(DDL_REFRESH_INTERVAL, DEFAULT_DDL_REFRESH_INTERVAL);
setDefaults
in interface ConfigurationDefault
builder
- the configuration builder that's collecting the configuration values.configurationSource
- the source of the configuration which may already