MAPREDUCE-6887. Modifier 'static' is redundant for inner enums. Contributed by ZhangBing Lin.

This commit is contained in:
Akira Ajisaka 2017-05-30 14:48:58 +09:00
parent a7f085d6bf
commit d4015f8628
No known key found for this signature in database
GPG Key ID: C1EDBB9CA400FD50
38 changed files with 42 additions and 42 deletions

View File

@ -102,7 +102,7 @@ private void removeContainerIfDone(ContainerId id) {
} }
} }
private static enum ContainerState { private enum ContainerState {
PREP, FAILED, RUNNING, DONE, KILLED_BEFORE_LAUNCH PREP, FAILED, RUNNING, DONE, KILLED_BEFORE_LAUNCH
} }

View File

@ -114,7 +114,7 @@ public static String taskSymbol(TaskType type) {
throw new YarnRuntimeException("Unknown task type: "+ type.toString()); throw new YarnRuntimeException("Unknown task type: "+ type.toString());
} }
public static enum TaskAttemptStateUI { public enum TaskAttemptStateUI {
NEW( NEW(
new TaskAttemptState[] { TaskAttemptState.NEW, new TaskAttemptState[] { TaskAttemptState.NEW,
TaskAttemptState.STARTING }), TaskAttemptState.STARTING }),
@ -136,7 +136,7 @@ public boolean correspondsTo(TaskAttemptState state) {
} }
} }
public static enum TaskStateUI { public enum TaskStateUI {
RUNNING( RUNNING(
new TaskState[]{TaskState.RUNNING}), new TaskState[]{TaskState.RUNNING}),
PENDING(new TaskState[]{TaskState.SCHEDULED}), PENDING(new TaskState[]{TaskState.SCHEDULED}),

View File

@ -72,7 +72,7 @@ public abstract class FileInputFormat<K, V> implements InputFormat<K, V> {
LogFactory.getLog(FileInputFormat.class); LogFactory.getLog(FileInputFormat.class);
@Deprecated @Deprecated
public static enum Counter { public enum Counter {
BYTES_READ BYTES_READ
} }

View File

@ -36,7 +36,7 @@
public abstract class FileOutputFormat<K, V> implements OutputFormat<K, V> { public abstract class FileOutputFormat<K, V> implements OutputFormat<K, V> {
@Deprecated @Deprecated
public static enum Counter { public enum Counter {
BYTES_WRITTEN BYTES_WRITTEN
} }

View File

@ -152,7 +152,7 @@ public class JobClient extends CLI implements AutoCloseable {
public static final String MAPREDUCE_CLIENT_RETRY_POLICY_SPEC_DEFAULT = public static final String MAPREDUCE_CLIENT_RETRY_POLICY_SPEC_DEFAULT =
"10000,6,60000,10"; // t1,n1,t2,n2,... "10000,6,60000,10"; // t1,n1,t2,n2,...
public static enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL } public enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL }
private TaskStatusFilter taskOutputFilter = TaskStatusFilter.FAILED; private TaskStatusFilter taskOutputFilter = TaskStatusFilter.FAILED;
private int maxRetry = MRJobConfig.DEFAULT_MR_CLIENT_JOB_MAX_RETRIES; private int maxRetry = MRJobConfig.DEFAULT_MR_CLIENT_JOB_MAX_RETRIES;

View File

@ -30,7 +30,7 @@ public class JobInProgress {
* @deprecated Provided for compatibility. Use {@link JobCounter} instead. * @deprecated Provided for compatibility. Use {@link JobCounter} instead.
*/ */
@Deprecated @Deprecated
public static enum Counter { public enum Counter {
NUM_FAILED_MAPS, NUM_FAILED_MAPS,
NUM_FAILED_REDUCES, NUM_FAILED_REDUCES,
TOTAL_LAUNCHED_MAPS, TOTAL_LAUNCHED_MAPS,

View File

@ -28,7 +28,7 @@ public class JobTracker {
* <code>State</code> is no longer used since M/R 2.x. It is kept in case * <code>State</code> is no longer used since M/R 2.x. It is kept in case
* that M/R 1.x applications may still use it. * that M/R 1.x applications may still use it.
*/ */
public static enum State { public enum State {
INITIALIZING, RUNNING INITIALIZING, RUNNING
} }

View File

@ -90,7 +90,7 @@ abstract public class Task implements Writable, Configurable {
* @deprecated Provided for compatibility. Use {@link TaskCounter} instead. * @deprecated Provided for compatibility. Use {@link TaskCounter} instead.
*/ */
@Deprecated @Deprecated
public static enum Counter { public enum Counter {
MAP_INPUT_RECORDS, MAP_INPUT_RECORDS,
MAP_OUTPUT_RECORDS, MAP_OUTPUT_RECORDS,
MAP_SKIPPED_RECORDS, MAP_SKIPPED_RECORDS,

View File

@ -358,7 +358,7 @@ public void run() {
* The filter for userlogs. * The filter for userlogs.
*/ */
@InterfaceAudience.Private @InterfaceAudience.Private
public static enum LogName { public enum LogName {
/** Log on the stdout of the task. */ /** Log on the stdout of the task. */
STDOUT ("stdout"), STDOUT ("stdout"),

View File

@ -45,12 +45,12 @@ public abstract class TaskStatus implements Writable, Cloneable {
//enumeration for reporting current phase of a task. //enumeration for reporting current phase of a task.
@InterfaceAudience.Private @InterfaceAudience.Private
@InterfaceStability.Unstable @InterfaceStability.Unstable
public static enum Phase{STARTING, MAP, SHUFFLE, SORT, REDUCE, CLEANUP} public enum Phase{STARTING, MAP, SHUFFLE, SORT, REDUCE, CLEANUP}
// what state is the task in? // what state is the task in?
@InterfaceAudience.Private @InterfaceAudience.Private
@InterfaceStability.Unstable @InterfaceStability.Unstable
public static enum State {RUNNING, SUCCEEDED, FAILED, UNASSIGNED, KILLED, public enum State {RUNNING, SUCCEEDED, FAILED, UNASSIGNED, KILLED,
COMMIT_PENDING, FAILED_UNCLEAN, KILLED_UNCLEAN, PREEMPTED} COMMIT_PENDING, FAILED_UNCLEAN, KILLED_UNCLEAN, PREEMPTED}
private final TaskAttemptID taskid; private final TaskAttemptID taskid;

View File

@ -68,7 +68,7 @@ class BinaryProtocol<K1 extends WritableComparable, V1 extends Writable,
* The integer codes to represent the different messages. These must match * The integer codes to represent the different messages. These must match
* the C++ codes or massive confusion will result. * the C++ codes or massive confusion will result.
*/ */
private static enum MessageType { START(0), private enum MessageType { START(0),
SET_JOB_CONF(1), SET_JOB_CONF(1),
SET_INPUT_TYPES(2), SET_INPUT_TYPES(2),
RUN_MAP(3), RUN_MAP(3),

View File

@ -54,7 +54,7 @@
public class Cluster { public class Cluster {
@InterfaceStability.Evolving @InterfaceStability.Evolving
public static enum JobTrackerStatus {INITIALIZING, RUNNING}; public enum JobTrackerStatus {INITIALIZING, RUNNING};
private ClientProtocolProvider clientProtocolProvider; private ClientProtocolProvider clientProtocolProvider;
private ClientProtocol client; private ClientProtocol client;

View File

@ -79,7 +79,7 @@ public class Job extends JobContextImpl implements JobContext {
private static final Log LOG = LogFactory.getLog(Job.class); private static final Log LOG = LogFactory.getLog(Job.class);
@InterfaceStability.Evolving @InterfaceStability.Evolving
public static enum JobState {DEFINE, RUNNING}; public enum JobState {DEFINE, RUNNING};
private static final long MAX_JOBSTATUS_AGE = 1000 * 2; private static final long MAX_JOBSTATUS_AGE = 1000 * 2;
public static final String OUTPUT_FILTER = "mapreduce.client.output.filter"; public static final String OUTPUT_FILTER = "mapreduce.client.output.filter";
/** Key in mapred-*.xml that sets completionPollInvervalMillis */ /** Key in mapred-*.xml that sets completionPollInvervalMillis */
@ -104,7 +104,7 @@ public static enum JobState {DEFINE, RUNNING};
public static final boolean DEFAULT_USE_WILDCARD_FOR_LIBJARS = true; public static final boolean DEFAULT_USE_WILDCARD_FOR_LIBJARS = true;
@InterfaceStability.Evolving @InterfaceStability.Evolving
public static enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL } public enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL }
static { static {
ConfigUtil.loadResources(); ConfigUtil.loadResources();

View File

@ -52,7 +52,7 @@ public class JobStatus implements Writable, Cloneable {
/** /**
* Current state of the job * Current state of the job
*/ */
public static enum State { public enum State {
RUNNING(1), RUNNING(1),
SUCCEEDED(2), SUCCEEDED(2),
FAILED(3), FAILED(3),

View File

@ -85,7 +85,7 @@ public abstract class FileInputFormat<K, V> extends InputFormat<K, V> {
private static final double SPLIT_SLOP = 1.1; // 10% slop private static final double SPLIT_SLOP = 1.1; // 10% slop
@Deprecated @Deprecated
public static enum Counter { public enum Counter {
BYTES_READ BYTES_READ
} }

View File

@ -52,7 +52,7 @@ public class ControlledJob {
private static final Log LOG = LogFactory.getLog(ControlledJob.class); private static final Log LOG = LogFactory.getLog(ControlledJob.class);
// A job will be in one of the following states // A job will be in one of the following states
public static enum State {SUCCESS, WAITING, RUNNING, READY, FAILED, public enum State {SUCCESS, WAITING, RUNNING, READY, FAILED,
DEPENDENT_FAILED}; DEPENDENT_FAILED};
public static final String CREATE_DIR = "mapreduce.jobcontrol.createdir.ifnotexist"; public static final String CREATE_DIR = "mapreduce.jobcontrol.createdir.ifnotexist";
private State state; private State state;

View File

@ -58,7 +58,7 @@ public class JobControl implements Runnable {
private static final Log LOG = LogFactory.getLog(JobControl.class); private static final Log LOG = LogFactory.getLog(JobControl.class);
// The thread can be in one of the following state // The thread can be in one of the following state
public static enum ThreadState {RUNNING, SUSPENDED,STOPPED, STOPPING, READY}; public enum ThreadState {RUNNING, SUSPENDED,STOPPED, STOPPING, READY};
private ThreadState runnerState; // the thread state private ThreadState runnerState; // the thread state

View File

@ -61,7 +61,7 @@ public abstract class FileOutputFormat<K, V> extends OutputFormat<K, V> {
public static final String OUTDIR = "mapreduce.output.fileoutputformat.outputdir"; public static final String OUTDIR = "mapreduce.output.fileoutputformat.outputdir";
@Deprecated @Deprecated
public static enum Counter { public enum Counter {
BYTES_WRITTEN BYTES_WRITTEN
} }

View File

@ -71,7 +71,7 @@ class Fetcher<K,V> extends Thread {
private static final String FETCH_RETRY_AFTER_HEADER = "Retry-After"; private static final String FETCH_RETRY_AFTER_HEADER = "Retry-After";
protected final Reporter reporter; protected final Reporter reporter;
private static enum ShuffleErrors{IO_ERROR, WRONG_LENGTH, BAD_ID, WRONG_MAP, private enum ShuffleErrors{IO_ERROR, WRONG_LENGTH, BAD_ID, WRONG_MAP,
CONNECTION, WRONG_REDUCE} CONNECTION, WRONG_REDUCE}
private final static String SHUFFLE_ERR_GRP_NAME = "Shuffle Errors"; private final static String SHUFFLE_ERR_GRP_NAME = "Shuffle Errors";

View File

@ -29,7 +29,7 @@
@InterfaceStability.Unstable @InterfaceStability.Unstable
public class MapHost { public class MapHost {
public static enum State { public enum State {
IDLE, // No map outputs available IDLE, // No map outputs available
BUSY, // Map outputs are being fetched BUSY, // Map outputs are being fetched
PENDING, // Known map outputs which need to be fetched PENDING, // Known map outputs which need to be fetched

View File

@ -29,7 +29,7 @@
public class HSAuditLogger { public class HSAuditLogger {
private static final Log LOG = LogFactory.getLog(HSAuditLogger.class); private static final Log LOG = LogFactory.getLog(HSAuditLogger.class);
static enum Keys { enum Keys {
USER, OPERATION, TARGET, RESULT, IP, PERMISSIONS, DESCRIPTION USER, OPERATION, TARGET, RESULT, IP, PERMISSIONS, DESCRIPTION
} }

View File

@ -87,7 +87,7 @@ public class HistoryFileManager extends AbstractService {
private static final Log LOG = LogFactory.getLog(HistoryFileManager.class); private static final Log LOG = LogFactory.getLog(HistoryFileManager.class);
private static final Log SUMMARY_LOG = LogFactory.getLog(JobSummary.class); private static final Log SUMMARY_LOG = LogFactory.getLog(JobSummary.class);
private static enum HistoryInfoState { private enum HistoryInfoState {
IN_INTERMEDIATE, IN_DONE, DELETED, MOVE_FAILED IN_INTERMEDIATE, IN_DONE, DELETED, MOVE_FAILED
}; };

View File

@ -53,7 +53,7 @@ public class RandomTextWriterJob extends Configured implements Tool {
public static final String MIN_KEY = "mapreduce.randomtextwriter.minwordskey"; public static final String MIN_KEY = "mapreduce.randomtextwriter.minwordskey";
public static final String MAX_KEY = "mapreduce.randomtextwriter.maxwordskey"; public static final String MAX_KEY = "mapreduce.randomtextwriter.maxwordskey";
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
public Job createJob(Configuration conf) throws IOException { public Job createJob(Configuration conf) throws IOException {
long numBytesToWritePerMap = conf.getLong(BYTES_PER_MAP, 10 * 1024); long numBytesToWritePerMap = conf.getLong(BYTES_PER_MAP, 10 * 1024);

View File

@ -162,7 +162,7 @@ public class JHLogAnalyzer {
Configuration.addDefaultResource("hdfs-site.xml"); Configuration.addDefaultResource("hdfs-site.xml");
} }
static enum StatSeries { enum StatSeries {
STAT_ALL_SLOT_TIME STAT_ALL_SLOT_TIME
(AccumulatingReducer.VALUE_TYPE_LONG + "allSlotTime"), (AccumulatingReducer.VALUE_TYPE_LONG + "allSlotTime"),
STAT_FAILED_SLOT_TIME STAT_FAILED_SLOT_TIME

View File

@ -123,7 +123,7 @@ public class TestDFSIO implements Tool {
Configuration.addDefaultResource("mapred-site.xml"); Configuration.addDefaultResource("mapred-site.xml");
} }
private static enum TestType { private enum TestType {
TEST_TYPE_READ("read"), TEST_TYPE_READ("read"),
TEST_TYPE_WRITE("write"), TEST_TYPE_WRITE("write"),
TEST_TYPE_CLEANUP("cleanup"), TEST_TYPE_CLEANUP("cleanup"),
@ -145,7 +145,7 @@ public String toString() {
} }
} }
static enum ByteMultiple { enum ByteMultiple {
B(1L), B(1L),
KB(0x400L), KB(0x400L),
MB(0x100000L), MB(0x100000L),

View File

@ -46,7 +46,7 @@ class OperationOutput {
private static final String MEASUREMENT_SEP = "*"; private static final String MEASUREMENT_SEP = "*";
private static final String STRING_SEP = ";"; private static final String STRING_SEP = ";";
static enum OutputType { enum OutputType {
STRING, FLOAT, LONG, DOUBLE, INTEGER STRING, FLOAT, LONG, DOUBLE, INTEGER
} }

View File

@ -28,7 +28,7 @@
*/ */
class PathFinder { class PathFinder {
private static enum Type { private enum Type {
FILE, DIRECTORY FILE, DIRECTORY
} }

View File

@ -232,7 +232,7 @@ public void close() { }
} }
} }
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
static class RandomMapOutput extends MapReduceBase static class RandomMapOutput extends MapReduceBase
implements Mapper<Text,Text,Text,Text> { implements Mapper<Text,Text,Text,Text> {

View File

@ -48,7 +48,7 @@ public class MRBench extends Configured implements Tool{
private static Path INPUT_DIR = new Path(BASE_DIR, DEFAULT_INPUT_SUB); private static Path INPUT_DIR = new Path(BASE_DIR, DEFAULT_INPUT_SUB);
private static Path OUTPUT_DIR = new Path(BASE_DIR, DEFAULT_OUTPUT_SUB); private static Path OUTPUT_DIR = new Path(BASE_DIR, DEFAULT_OUTPUT_SUB);
public static enum Order {RANDOM, ASCENDING, DESCENDING}; public enum Order {RANDOM, ASCENDING, DESCENDING};
/** /**
* Takes input format as text lines, runs some processing on it and * Takes input format as text lines, runs some processing on it and

View File

@ -63,7 +63,7 @@ public class ThreadedMapBenchmark extends Configured implements Tool {
// (FACTOR * data_size) should // (FACTOR * data_size) should
// result in only 1 spill // result in only 1 spill
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
/** /**
* Generates random input data of given size with keys and values of given * Generates random input data of given size with keys and values of given

View File

@ -241,7 +241,7 @@ public void close() { }
} }
} }
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
static class RandomMapOutput extends Mapper<Text,Text,Text,Text> { static class RandomMapOutput extends Mapper<Text,Text,Text,Text> {
StringBuilder sentence = new StringBuilder(); StringBuilder sentence = new StringBuilder();

View File

@ -67,7 +67,7 @@ public class LargeSorter extends Configured implements Tool {
/** /**
* User counters * User counters
*/ */
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
/** /**
* A custom input format that creates virtual inputs of a single string * A custom input format that creates virtual inputs of a single string

View File

@ -97,7 +97,7 @@ static int printUsage() {
/** /**
* User counters * User counters
*/ */
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
static class RandomTextMapper extends Mapper<Text, Text, Text, Text> { static class RandomTextMapper extends Mapper<Text, Text, Text, Text> {

View File

@ -89,7 +89,7 @@ public class RandomWriter extends Configured implements Tool {
/** /**
* User counters * User counters
*/ */
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
/** /**
* A custom input format that creates virtual inputs of a single string * A custom input format that creates virtual inputs of a single string

View File

@ -157,7 +157,7 @@ public static boolean parseArgs(String[] args, Job job) throws IOException {
/** /**
* TimelineServer Performance counters * TimelineServer Performance counters
*/ */
static enum PerfCounters { enum PerfCounters {
TIMELINE_SERVICE_WRITE_TIME, TIMELINE_SERVICE_WRITE_TIME,
TIMELINE_SERVICE_WRITE_COUNTER, TIMELINE_SERVICE_WRITE_COUNTER,
TIMELINE_SERVICE_WRITE_FAILURES, TIMELINE_SERVICE_WRITE_FAILURES,

View File

@ -97,7 +97,7 @@ static int printUsage() {
/** /**
* User counters * User counters
*/ */
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
static class RandomTextMapper extends Mapper<Text, Text, Text, Text> { static class RandomTextMapper extends Mapper<Text, Text, Text, Text> {

View File

@ -89,7 +89,7 @@ public class RandomWriter extends Configured implements Tool {
/** /**
* User counters * User counters
*/ */
static enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN } enum Counters { RECORDS_WRITTEN, BYTES_WRITTEN }
/** /**
* A custom input format that creates virtual inputs of a single string * A custom input format that creates virtual inputs of a single string

View File

@ -68,7 +68,7 @@
public class TeraGen extends Configured implements Tool { public class TeraGen extends Configured implements Tool {
private static final Log LOG = LogFactory.getLog(TeraGen.class); private static final Log LOG = LogFactory.getLog(TeraGen.class);
public static enum Counters {CHECKSUM} public enum Counters {CHECKSUM}
/** /**
* An input format that assigns ranges of longs to each mapper. * An input format that assigns ranges of longs to each mapper.