public class WorkerConf extends Object
Modifier and Type | Method and Description |
---|---|
static void |
clear()
This is for unit test only.
|
static WorkerConf |
get() |
static boolean |
getBooleanProperty(String property) |
static boolean |
getBooleanProperty(String property,
boolean defaultValue) |
static <T extends Enum<T>> |
getEnumProperty(String property,
T defaultValue) |
static Integer |
getIntegerProperty(String property,
Integer defaultValue) |
static int |
getIntProperty(String property) |
static int |
getIntProperty(String property,
int defaultValue) |
static com.google.common.collect.ImmutableList<String> |
getListProperty(String property,
com.google.common.collect.ImmutableList<String> defaultValue) |
static long |
getLongProperty(String property) |
static long |
getLongProperty(String property,
int defaultValue) |
static String |
getProperty(String property) |
static String |
getProperty(String property,
String defaultValue) |
public final String MASTER_HOSTNAME
public final int MASTER_PORT
public final int PORT
public final int DATA_PORT
public final String DATA_FOLDER
public final long MEMORY_SIZE
public final long HEARTBEAT_TIMEOUT_MS
public final int TO_MASTER_HEARTBEAT_INTERVAL_MS
public final int SELECTOR_THREADS
public final int QUEUE_SIZE_PER_SELECTOR
public final int SERVER_THREADS
public final int USER_TIMEOUT_MS
public static final String USER_TEMP_RELATIVE_FOLDER
public final int WORKER_CHECKPOINT_THREADS
public final int WORKER_PER_THREAD_CHECKPOINT_CAP_MB_SEC
public final NetworkType NETWORK_TYPE
public final String KEYTAB_KEY
public final String KEYTAB
public final String PRINCIPAL_KEY
public final String PRINCIPAL
public final ChannelType NETTY_CHANNEL_TYPE
public final FileTransferType NETTY_FILE_TRANSFER_TYPE
public final int NETTY_HIGH_WATER_MARK
public final int NETTY_BOSS_THREADS
public final int NETTY_WORKER_THREADS
public final int NETTY_LOW_WATER_MARK
public final com.google.common.base.Optional<Integer> NETTY_BACKLOG
public final com.google.common.base.Optional<Integer> NETTY_SEND_BUFFER
public final com.google.common.base.Optional<Integer> NETTY_RECIEVE_BUFFER
public final EvictStrategyType EVICT_STRATEGY_TYPE
public final AllocateStrategyType ALLOCATE_STRATEGY_TYPE
public final int STORAGE_LEVELS
public final StorageLevelAlias[] STORAGE_LEVEL_ALIAS
public final String[] STORAGE_TIER_DIRS
public final String[] STORAGE_TIER_DIR_QUOTA
public static void clear()
public static WorkerConf get()
public static boolean getBooleanProperty(String property)
public static boolean getBooleanProperty(String property, boolean defaultValue)
public static <T extends Enum<T>> T getEnumProperty(String property, T defaultValue)
public static int getIntProperty(String property)
public static int getIntProperty(String property, int defaultValue)
public static long getLongProperty(String property)
public static long getLongProperty(String property, int defaultValue)
public static com.google.common.collect.ImmutableList<String> getListProperty(String property, com.google.common.collect.ImmutableList<String> defaultValue)
Copyright © 2015. All Rights Reserved.