Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_LOG_INTERVAL |
3600 |
public static final int |
DEFAULT_POLL_INTERVAL |
360 |
public static final int |
MAX_OUTPUT_LENGTH |
51200 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_LOG_INTERVAL |
3600 |
public static final int |
DEFAULT_POLL_INTERVAL |
360 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COMPRESSION_SUFFIX |
".zip" |
public static final char |
FIELD_SEPARATOR |
124 |
public static final char |
RECORD_SEPARATOR |
10 |
public static final int |
UPLOAD_INTERVAL |
600 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CACHE_ARCHIVES |
"mapred.cache.archives" |
public static final java.lang.String |
CACHE_ARCHIVES_SIZES |
"mapred.cache.archives.filesizes" |
public static final java.lang.String |
CACHE_ARCHIVES_TIMESTAMPS |
"mapred.cache.archives.timestamps" |
public static final java.lang.String |
CACHE_FILES |
"mapred.cache.files" |
public static final java.lang.String |
CACHE_FILES_SIZES |
"mapred.cache.files.filesizes" |
public static final java.lang.String |
CACHE_FILES_TIMESTAMPS |
"mapred.cache.files.timestamps" |
public static final java.lang.String |
CACHE_LOCALARCHIVES |
"mapred.cache.localArchives" |
public static final java.lang.String |
CACHE_LOCALFILES |
"mapred.cache.localFiles" |
public static final java.lang.String |
CACHE_SYMLINK |
"mapred.create.symlink" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
WORK_DIR_FIX |
"-work-" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
versionID |
3L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
UNINITIALIZED_MEMORY_VALUE |
-1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SUCCEEDED_FILE_NAME |
"_SUCCESS" |
public static final java.lang.String |
TEMP_DIR_NAME |
"_temporary" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HA_DT_SERVICE_PREFIX |
"ha-jt:" |
public static final int |
MR_CLIENT_FAILOVER_CONNECTION_RETRIES_DEFAULT |
0 |
public static final java.lang.String |
MR_CLIENT_FAILOVER_CONNECTION_RETRIES_KEY |
"mapred.client.failover.connection.retries" |
public static final int |
MR_CLIENT_FAILOVER_CONNECTION_RETRIES_ON_SOCKET_TIMEOUTS_DEFAULT |
0 |
public static final java.lang.String |
MR_CLIENT_FAILOVER_CONNECTION_RETRIES_ON_SOCKET_TIMEOUTS_KEY |
"mapred.client.failover.connection.retries.on.timeouts" |
public static final int |
MR_CLIENT_FAILOVER_MAX_ATTEMPTS_DEFAULT |
15 |
public static final java.lang.String |
MR_CLIENT_FAILOVER_MAX_ATTEMPTS_KEY |
"mapred.client.failover.max.attempts" |
public static final java.lang.String |
MR_CLIENT_FAILOVER_PROXY_PROVIDER_KEY_PREFIX |
"mapred.client.failover.proxy.provider" |
public static final int |
MR_CLIENT_FAILOVER_SLEEPTIME_BASE_DEFAULT |
500 |
public static final java.lang.String |
MR_CLIENT_FAILOVER_SLEEPTIME_BASE_KEY |
"mapred.client.failover.sleep.base.millis" |
public static final int |
MR_CLIENT_FAILOVER_SLEEPTIME_MAX_DEFAULT |
15000 |
public static final java.lang.String |
MR_CLIENT_FAILOVER_SLEEPTIME_MAX_KEY |
"mapred.client.failover.sleep.max.millis" |
public static final java.lang.String |
MR_HA_ACTIVE_CHECK_MILLIS |
"mapred.ha.jobtracker.active-check.millis" |
public static final int |
MR_HA_ACTIVE_CHECK_MILLIS_DEFAULT |
1000 |
public static final boolean |
MR_HA_AUTO_FAILOVER_ENABLED_DEFAULT |
false |
public static final java.lang.String |
MR_HA_AUTO_FAILOVER_ENABLED_KEY |
"mapred.ha.automatic-failover.enabled" |
public static final java.lang.String |
MR_HA_FENCING_METHODS_KEY |
"mapred.ha.fencing.methods" |
public static final java.lang.String |
MR_HA_JOBTRACKER_HTTP_REDIRECT_ADDRESS_KEY |
"mapred.ha.jobtracker.http-redirect-address" |
public static final java.lang.String |
MR_HA_JOBTRACKER_ID_KEY |
"mapred.ha.jobtracker.id" |
public static final java.lang.String |
MR_HA_JOBTRACKER_RPC_ADDRESS_KEY |
"mapred.ha.jobtracker.rpc-address" |
public static final java.lang.String |
MR_HA_JOBTRACKERS_KEY_PREFIX |
"mapred.jobtrackers" |
public static final int |
MR_HA_ZKFC_PORT_DEFAULT |
8018 |
public static final java.lang.String |
MR_HA_ZKFC_PORT_KEY |
"mapred.ha.zkfc.port" |
public static final java.lang.String |
MR_JOBTRACKER_ADDRESS_KEY |
"mapred.job.tracker" |
public static final java.lang.String |
MR_JOBTRACKER_HTTP_ADDRESS_KEY |
"mapred.job.tracker.http.address" |
public static final java.lang.String |
MR_JOBTRACKER_OLD_HTTP_ADDRESS_KEY |
"mapred.job.tracker.info.bindAddress" |
public static final java.lang.String |
MR_JOBTRACKER_OLD_HTTP_PORT_KEY |
"mapred.job.tracker.info.port" |
public static final java.lang.String |
MR_JOBTRACKER_RPC_ADDRESS_KEY |
"mapred.jobtracker.rpc-address" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
COUNTER_UPDATE_INTERVAL |
60000L |
public static final long |
DEFAULT_DISK_HEALTH_CHECK_INTERVAL |
60000L |
public static final int |
FILE_NOT_FOUND |
-1 |
public static final java.lang.String |
FOR_REDUCE_TASK |
"for-reduce-task" |
public static final java.lang.String |
FROM_MAP_TASK |
"from-map-task" |
public static final int |
HEARTBEAT_INTERVAL_MIN_DEFAULT |
300 |
public static final java.lang.String |
MAP_OUTPUT_LENGTH |
"Map-Output-Length" |
public static final int |
MAPREDUCE_CLIENT_RPC_TIMEOUT_DEFAULT |
-1 |
public static final java.lang.String |
MAPREDUCE_CLIENT_RPC_TIMEOUT_KEY |
"mapreduce.jobclient.rpc.timeout" |
public static final java.lang.String |
RAW_MAP_OUTPUT_LENGTH |
"Raw-Map-Output-Length" |
public static final int |
SUCCESS |
0 |
public static final java.lang.String |
WORKDIR |
"work" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_MAPRED_TASK_JAVA_OPTS |
"-Xmx200m" |
public static final java.lang.String |
DEFAULT_QUEUE_NAME |
"default" |
public static final long |
DISABLED_MEMORY_LIMIT |
-1L |
public static final java.lang.String |
JOB_LEVEL_AUTHORIZATION_ENABLING_FLAG |
"mapreduce.cluster.job-authorization-enabled" |
public static final java.lang.String |
MAPRED_LOCAL_DIR_PROPERTY |
"mapred.local.dir" |
public static final java.lang.String |
MAPRED_MAP_TASK_ENV |
"mapred.map.child.env" |
public static final java.lang.String |
MAPRED_MAP_TASK_JAVA_OPTS |
"mapred.map.child.java.opts" |
public static final java.lang.String |
MAPRED_MAP_TASK_LOG_LEVEL |
"mapred.map.child.log.level" |
public static final java.lang.String |
MAPRED_MAP_TASK_ULIMIT |
"mapred.map.child.ulimit" |
public static final java.lang.String |
MAPRED_REDUCE_TASK_ENV |
"mapred.reduce.child.env" |
public static final java.lang.String |
MAPRED_REDUCE_TASK_JAVA_OPTS |
"mapred.reduce.child.java.opts" |
public static final java.lang.String |
MAPRED_REDUCE_TASK_LOG_LEVEL |
"mapred.reduce.child.log.level" |
public static final java.lang.String |
MAPRED_REDUCE_TASK_ULIMIT |
"mapred.reduce.child.ulimit" |
public static final java.lang.String |
MAPRED_TASK_DEFAULT_MAXVMEM_PROPERTY |
"mapred.task.default.maxvmem" |
public static final java.lang.String |
MAPRED_TASK_ENV |
"mapred.child.env" |
public static final java.lang.String |
MAPRED_TASK_JAVA_OPTS |
"mapred.child.java.opts" |
public static final java.lang.String |
MAPRED_TASK_MAXPMEM_PROPERTY |
"mapred.task.maxpmem" |
public static final java.lang.String |
MAPRED_TASK_MAXVMEM_PROPERTY |
"mapred.task.maxvmem" |
public static final java.lang.String |
MAPRED_TASK_ULIMIT |
"mapred.child.ulimit" |
public static final java.lang.String |
UPPER_LIMIT_ON_TASK_VMEM_PROPERTY |
"mapred.task.limit.maxvmem" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAPREDUCE_JOBEND_NOTIFICATION_TIMEOUT_DEFAULT |
5000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
JOB_NAME_TRIM_LENGTH |
50 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
JOB_LOCAL_CTXT |
"mapred.job.local.dir" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FAILED |
3 |
public static final int |
KILLED |
5 |
public static final int |
PREP |
4 |
public static final int |
RUNNING |
1 |
public static final int |
SUCCEEDED |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
COUNTER_UPDATE_INTERVAL |
60000L |
public static final long |
DEFAULT_DISK_HEALTH_CHECK_INTERVAL |
60000L |
public static final long |
DELEGATION_KEY_UPDATE_INTERVAL_DEFAULT |
86400000L |
public static final java.lang.String |
DELEGATION_KEY_UPDATE_INTERVAL_KEY |
"mapreduce.cluster.delegation.key.update-interval" |
public static final long |
DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT |
604800000L |
public static final java.lang.String |
DELEGATION_TOKEN_MAX_LIFETIME_KEY |
"mapreduce.cluster.delegation.token.max-lifetime" |
public static final long |
DELEGATION_TOKEN_RENEW_INTERVAL_DEFAULT |
86400000L |
public static final java.lang.String |
DELEGATION_TOKEN_RENEW_INTERVAL_KEY |
"mapreduce.cluster.delegation.token.renew-interval" |
public static final int |
FILE_NOT_FOUND |
-1 |
public static final java.lang.String |
FOR_REDUCE_TASK |
"for-reduce-task" |
public static final java.lang.String |
FROM_MAP_TASK |
"from-map-task" |
public static final int |
HEARTBEAT_INTERVAL_MIN_DEFAULT |
300 |
public static final java.lang.String |
JT_KEYTAB_FILE |
"mapreduce.jobtracker.keytab.file" |
public static final java.lang.String |
JT_USER_NAME |
"mapreduce.jobtracker.kerberos.principal" |
public static final java.lang.String |
MAP_OUTPUT_LENGTH |
"Map-Output-Length" |
public static final java.lang.String |
MAPRED_CLUSTER_MAP_MEMORY_MB_PROPERTY |
"mapred.cluster.map.memory.mb" |
public static final java.lang.String |
MAPRED_CLUSTER_REDUCE_MEMORY_MB_PROPERTY |
"mapred.cluster.reduce.memory.mb" |
public static final java.lang.String |
MAX_USER_JOBCONF_SIZE_KEY |
"mapred.user.jobconf.limit" |
public static final java.lang.String |
RAW_MAP_OUTPUT_LENGTH |
"Raw-Map-Output-Length" |
public static final java.lang.String |
SHUFFLE_SSL_ADDRESS_DEFAULT |
"0.0.0.0" |
public static final java.lang.String |
SHUFFLE_SSL_ADDRESS_KEY |
"mapreduce.shuffle.ssl.address" |
public static final boolean |
SHUFFLE_SSL_ENABLED_DEFAULT |
false |
public static final java.lang.String |
SHUFFLE_SSL_ENABLED_KEY |
"mapreduce.shuffle.ssl.enabled" |
public static final int |
SHUFFLE_SSL_PORT_DEFAULT |
50443 |
public static final java.lang.String |
SHUFFLE_SSL_PORT_KEY |
"mapreduce.shuffle.ssl.port" |
public static final int |
SUCCESS |
0 |
public static final int |
TRACKERS_OK |
0 |
public static final int |
UNKNOWN_TASKTRACKER |
1 |
public static final long |
versionID |
32L |
public static final long |
versionID |
28L |
public static final java.lang.String |
WORKDIR |
"work" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SYSTEM_DIR_SEQUENCE_PREFIX |
"seq-" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
TRACKERS_OK |
0 |
public static final int |
UNKNOWN_TASKTRACKER |
1 |
public static final long |
versionID |
32L |
public static final long |
versionID |
28L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
LOCAL_MAX_MAPS |
"mapreduce.local.map.tasks.maximum" |
public static final long |
versionID |
28L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAP_OUTPUT_INDEX_RECORD_LENGTH |
24 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
COUNTER_UPDATE_INTERVAL |
60000L |
public static final long |
DEFAULT_DISK_HEALTH_CHECK_INTERVAL |
60000L |
public static final int |
FILE_NOT_FOUND |
-1 |
public static final java.lang.String |
FOR_REDUCE_TASK |
"for-reduce-task" |
public static final java.lang.String |
FROM_MAP_TASK |
"from-map-task" |
public static final int |
HEARTBEAT_INTERVAL_MIN_DEFAULT |
300 |
public static final java.lang.String |
MAP_OUTPUT_LENGTH |
"Map-Output-Length" |
public static final java.lang.String |
RAW_MAP_OUTPUT_LENGTH |
"Raw-Map-Output-Length" |
public static final int |
SUCCESS |
0 |
public static final java.lang.String |
WORKDIR |
"work" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MD5_LEN |
16 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COUNTER_GROUP |
"SkippingTaskCounters" |
public static final java.lang.String |
COUNTER_MAP_PROCESSED_RECORDS |
"MapProcessedRecords" |
public static final java.lang.String |
COUNTER_REDUCE_PROCESSED_GROUPS |
"ReduceProcessedGroups" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONF_CONNECT_TIMEOUT_KEY |
"mapred.ha.fencing.ssh.connect-timeout" |
public static final java.lang.String |
CONF_IDENTITIES_KEY |
"mapred.ha.fencing.ssh.private-key-files" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_MR_COMBINE_RECORDS_BEFORE_PROGRESS |
10000L |
protected static final java.lang.String |
FILESYSTEM_COUNTER_GROUP |
"FileSystemCounters" |
public static final java.lang.String |
MR_COMBINE_RECORDS_BEFORE_PROGRESS |
"mapred.combine.recordsBeforeProgress" |
public static final int |
PROGRESS_INTERVAL |
3000 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
COMMAND_FILE |
"taskjvm.sh" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
height |
200 |
public static final int |
width |
600 |
public static final int |
xmargin |
80 |
public static final int |
ymargin |
20 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
COUNTER_UPDATE_INTERVAL |
60000L |
public static final long |
DEFAULT_DISK_HEALTH_CHECK_INTERVAL |
60000L |
public static final int |
FILE_NOT_FOUND |
-1 |
public static final java.lang.String |
FOR_REDUCE_TASK |
"for-reduce-task" |
public static final java.lang.String |
FROM_MAP_TASK |
"from-map-task" |
public static final int |
HEARTBEAT_INTERVAL_MIN_DEFAULT |
300 |
public static final java.lang.String |
MAP_OUTPUT_LENGTH |
"Map-Output-Length" |
public static final java.lang.String |
MR_CLIENTTRACE_FORMAT |
"src: %s, dest: %s, bytes: %s, op: %s, cliID: %s, duration: %s" |
public static final java.lang.String |
RAW_MAP_OUTPUT_LENGTH |
"Raw-Map-Output-Length" |
public static final java.lang.String |
SHUFFLE_PROVIDER_PLUGIN_CLASSES |
"mapreduce.shuffle.provider.plugin.classes" |
public static final java.lang.String |
SUBDIR |
"taskTracker" |
public static final int |
SUCCESS |
0 |
public static final java.lang.String |
TT_KEYTAB_FILE |
"mapreduce.tasktracker.keytab.file" |
public static final java.lang.String |
TT_LOG_TMP_DIR |
"tt_log_tmp" |
public static final java.lang.String |
TT_RESOURCE_CALCULATOR_PLUGIN |
"mapreduce.tasktracker.resourcecalculatorplugin" |
public static final java.lang.String |
TT_USER_NAME |
"mapreduce.tasktracker.kerberos.principal" |
public static final java.lang.String |
WORKDIR |
"work" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
UNAVAILABLE |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
versionID |
18L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEPENDENT_FAILED |
5 |
public static final int |
FAILED |
4 |
public static final int |
READY |
3 |
public static final int |
RUNNING |
2 |
public static final int |
SUCCESS |
0 |
public static final int |
WAITING |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_PATH |
"_partition.lst" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DOUBLE_VALUE_SUM |
"DoubleValueSum" |
public static final java.lang.String |
LONG_VALUE_MAX |
"LongValueMax" |
public static final java.lang.String |
LONG_VALUE_MIN |
"LongValueMin" |
public static final java.lang.String |
LONG_VALUE_SUM |
"LongValueSum" |
public static final java.lang.String |
STRING_VALUE_MAX |
"StringValueMax" |
public static final java.lang.String |
STRING_VALUE_MIN |
"StringValueMin" |
public static final java.lang.String |
UNIQ_VALUE_COUNT |
"UniqValueCount" |
public static final java.lang.String |
VALUE_HISTOGRAM |
"ValueHistogram" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TYPE_SEPARATOR |
":" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DRIVER_CLASS_PROPERTY |
"mapred.jdbc.driver.class" |
public static final java.lang.String |
INPUT_CLASS_PROPERTY |
"mapred.jdbc.input.class" |
public static final java.lang.String |
INPUT_CONDITIONS_PROPERTY |
"mapred.jdbc.input.conditions" |
public static final java.lang.String |
INPUT_COUNT_QUERY |
"mapred.jdbc.input.count.query" |
public static final java.lang.String |
INPUT_FIELD_NAMES_PROPERTY |
"mapred.jdbc.input.field.names" |
public static final java.lang.String |
INPUT_ORDER_BY_PROPERTY |
"mapred.jdbc.input.orderby" |
public static final java.lang.String |
INPUT_QUERY |
"mapred.jdbc.input.query" |
public static final java.lang.String |
INPUT_TABLE_NAME_PROPERTY |
"mapred.jdbc.input.table.name" |
public static final java.lang.String |
OUTPUT_FIELD_COUNT_PROPERTY |
"mapred.jdbc.output.field.count" |
public static final java.lang.String |
OUTPUT_FIELD_NAMES_PROPERTY |
"mapred.jdbc.output.field.names" |
public static final java.lang.String |
OUTPUT_TABLE_NAME_PROPERTY |
"mapred.jdbc.output.table.name" |
public static final java.lang.String |
PASSWORD_PROPERTY |
"mapred.jdbc.password" |
public static final java.lang.String |
URL_PROPERTY |
"mapred.jdbc.url" |
public static final java.lang.String |
USERNAME_PROPERTY |
"mapred.jdbc.username" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final char |
SEPARATOR |
95 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CACHE_ARCHIVES_VISIBILITIES |
"mapreduce.job.cache.archives.visibilities" |
public static final java.lang.String |
CACHE_FILE_VISIBILITIES |
"mapreduce.job.cache.files.visibilities" |
public static final java.lang.String |
COMBINE_CLASS_ATTR |
"mapreduce.combine.class" |
public static final java.lang.String |
INPUT_FORMAT_CLASS_ATTR |
"mapreduce.inputformat.class" |
public static final java.lang.String |
JAR_UNPACK_PATTERN |
"mapreduce.job.jar.unpack.pattern" |
public static final java.lang.String |
JOB_ACL_MODIFY_JOB |
"mapreduce.job.acl-modify-job" |
public static final java.lang.String |
JOB_ACL_VIEW_JOB |
"mapreduce.job.acl-view-job" |
public static final java.lang.String |
JOB_CANCEL_DELEGATION_TOKEN |
"mapreduce.job.complete.cancel.delegation.tokens" |
public static final java.lang.String |
JOB_NAMENODES |
"mapreduce.job.hdfs-servers" |
public static final java.lang.String |
MAP_CLASS_ATTR |
"mapreduce.map.class" |
public static final java.lang.String |
MAP_MEMORY_PHYSICAL_MB |
"mapreduce.map.memory.physical.mb" |
public static final java.lang.String |
MAP_OUTPUT_COLLECTOR_CLASS_ATTR |
"mapreduce.job.map.output.collector.class" |
public static final java.lang.String |
MAPREDUCE_TASK_CLASSPATH_PRECEDENCE |
"mapreduce.task.classpath.user.precedence" |
public static final java.lang.String |
OUTPUT_FORMAT_CLASS_ATTR |
"mapreduce.outputformat.class" |
public static final java.lang.String |
PARTITIONER_CLASS_ATTR |
"mapreduce.partitioner.class" |
public static final java.lang.String |
REDUCE_CLASS_ATTR |
"mapreduce.reduce.class" |
public static final java.lang.String |
REDUCE_MEMORY_PHYSICAL_MB |
"mapreduce.reduce.memory.physical.mb" |
public static final java.lang.String |
SHUFFLE_CONSUMER_PLUGIN_ATTR |
"mapreduce.job.reduce.shuffle.consumer.plugin.class" |
public static final java.lang.String |
USER_LOG_RETAIN_HOURS |
"mapred.userlog.retain.hours" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
JOB |
"job" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COUNTER_GROUP_NAME_MAX_DEFAULT |
128 |
public static final java.lang.String |
COUNTER_GROUP_NAME_MAX_KEY |
"mapreduce.job.counters.group.name.max" |
public static final int |
COUNTER_GROUPS_MAX_DEFAULT |
50 |
public static final java.lang.String |
COUNTER_GROUPS_MAX_KEY |
"mapreduce.job.counters.groups.max" |
public static final int |
COUNTER_NAME_MAX_DEFAULT |
64 |
public static final java.lang.String |
COUNTER_NAME_MAX_KEY |
"mapreduce.job.counters.counter.name.max" |
public static final int |
COUNTERS_MAX_DEFAULT |
120 |
public static final java.lang.String |
COUNTERS_MAX_KEY |
"mapreduce.job.counters.max" |
public static final boolean |
DEFAULT_JOB_TOKEN_TRACKING_IDS_ENABLED |
false |
public static final java.lang.String |
JOB_TOKEN_TRACKING_IDS |
"mapreduce.job.token.tracking.ids" |
public static final java.lang.String |
JOB_TOKEN_TRACKING_IDS_ENABLED |
"mapreduce.job.token.tracking.ids.enabled" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
ATTEMPT |
"attempt" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
TASK |
"task" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SUBSTITUTE_TOKEN |
"$CONDITIONS" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DRIVER_CLASS_PROPERTY |
"mapred.jdbc.driver.class" |
public static final java.lang.String |
INPUT_BOUNDING_QUERY |
"mapred.jdbc.input.bounding.query" |
public static final java.lang.String |
INPUT_CLASS_PROPERTY |
"mapred.jdbc.input.class" |
public static final java.lang.String |
INPUT_CONDITIONS_PROPERTY |
"mapred.jdbc.input.conditions" |
public static final java.lang.String |
INPUT_COUNT_QUERY |
"mapred.jdbc.input.count.query" |
public static final java.lang.String |
INPUT_FIELD_NAMES_PROPERTY |
"mapred.jdbc.input.field.names" |
public static final java.lang.String |
INPUT_ORDER_BY_PROPERTY |
"mapred.jdbc.input.orderby" |
public static final java.lang.String |
INPUT_QUERY |
"mapred.jdbc.input.query" |
public static final java.lang.String |
INPUT_TABLE_NAME_PROPERTY |
"mapred.jdbc.input.table.name" |
public static final java.lang.String |
OUTPUT_FIELD_COUNT_PROPERTY |
"mapred.jdbc.output.field.count" |
public static final java.lang.String |
OUTPUT_FIELD_NAMES_PROPERTY |
"mapred.jdbc.output.field.names" |
public static final java.lang.String |
OUTPUT_TABLE_NAME_PROPERTY |
"mapred.jdbc.output.table.name" |
public static final java.lang.String |
PASSWORD_PROPERTY |
"mapred.jdbc.password" |
public static final java.lang.String |
URL_PROPERTY |
"mapred.jdbc.url" |
public static final java.lang.String |
USERNAME_PROPERTY |
"mapred.jdbc.username" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SESSION_TIMEZONE_KEY |
"oracle.sessionTimeZone" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DATA_FIELD_SEPERATOR |
"mapreduce.fieldsel.data.field.separator" |
public static final java.lang.String |
MAP_OUTPUT_KEY_VALUE_SPEC |
"mapreduce.fieldsel.map.output.key.value.fields.spec" |
public static final java.lang.String |
REDUCE_OUTPUT_KEY_VALUE_SPEC |
"mapreduce.fieldsel.reduce.output.key.value.fields.spec" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
LINES_PER_MAP |
"mapreduce.input.lineinputformat.linespermap" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
FILTER_CLASS |
"mapreduce.input.sequencefileinputfilter.class" |
public static final java.lang.String |
FILTER_FREQUENCY |
"mapreduce.input.sequencefileinputfilter.frequency" |
public static final java.lang.String |
FILTER_REGEX |
"mapreduce.input.sequencefileinputfilter.regex" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MD5_LEN |
16 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SUCCEEDED_FILE_NAME |
"_SUCCESS" |
protected static final java.lang.String |
TEMP_DIR_NAME |
"_temporary" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
BASE_OUTPUT_NAME |
"mapreduce.output.basename" |
protected static final java.lang.String |
PART |
"part" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_PATH |
"_partition.lst" |
public static final java.lang.String |
MAX_TRIE_DEPTH |
"mapreduce.totalorderpartitioner.trie.maxdepth" |
public static final java.lang.String |
NATURAL_ORDER |
"mapreduce.totalorderpartitioner.naturalorder" |
public static final java.lang.String |
PARTITIONER_PATH |
"mapreduce.totalorderpartitioner.path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HTTP_HEADER_REPLY_URL_HASH |
"ReplyHash" |
public static final java.lang.String |
HTTP_HEADER_URL_HASH |
"UrlHash" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JOB_TOKEN_HDFS_FILE |
"jobToken" |
public static final java.lang.String |
JOB_TOKENS_FILENAME |
"mapreduce.job.jobTokenFile" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SCHEME |
"hdfs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
versionID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
versionID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
versionID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
LINK_URI |
"You need to specify the uris as hdfs://host:port/#linkname,Please specify a different link name for all of your caching URIs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
RAW_BYTES_ID |
"rawbytes" |
public static final java.lang.String |
TEXT_ID |
"text" |
public static final java.lang.String |
TYPED_BYTES_ID |
"typedbytes" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TOBEDELETED |
"toBeDeleted" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final long |
DEFAULT_SLEEPTIME_BEFORE_SIGKILL |
5000L |
Copyright © 2009 The Apache Software Foundation