Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HADOOP-11388. Remove deprecated o.a.h.metrics.file.FileContext. Contributed by Li Lu.

This commit is contained in:
Haohui Mai 2014-12-10 12:46:42 -08:00
parent 7e51350d9a
commit df5af744ad
2 changed files with 3 additions and 154 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-common-project/hadoop-common/CHANGES.txt
View File

@ -194,6 +194,9 @@ Release 2.7.0 - UNRELEASED
HADOOP-10482. Fix various findbugs warnings in hadoop-common. (wheat9) HADOOP-10482. Fix various findbugs warnings in hadoop-common. (wheat9)
HADOOP-11388. Remove deprecated o.a.h.metrics.file.FileContext.
(Li Lu via wheat9)
Release 2.6.0 - 2014-11-18 Release 2.6.0 - 2014-11-18
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

154
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics/file/FileContext.java
View File

@ -1,154 +0,0 @@
/*
* FileContext.java
*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.hadoop.metrics.file;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import org.apache.hadoop.classification.InterfaceAudience;
import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.metrics.ContextFactory;
import org.apache.hadoop.metrics.spi.AbstractMetricsContext;
import org.apache.hadoop.metrics.spi.OutputRecord;
/**
* Metrics context for writing metrics to a file.<p/>
*
* This class is configured by setting ContextFactory attributes which in turn
* are usually configured through a properties file. All the attributes are
* prefixed by the contextName. For example, the properties file might contain:
* <pre>
* myContextName.fileName=/tmp/metrics.log
* myContextName.period=5
* </pre>
* @see org.apache.hadoop.metrics2.sink.FileSink for metrics 2.0.
*/
@InterfaceAudience.Public
@InterfaceStability.Evolving
@Deprecated
public class FileContext extends AbstractMetricsContext {
/* Configuration attribute names */
@InterfaceAudience.Private
protected static final String FILE_NAME_PROPERTY = "fileName";
@InterfaceAudience.Private
protected static final String PERIOD_PROPERTY = "period";
private File file = null; // file for metrics to be written to
private PrintWriter writer = null;
/** Creates a new instance of FileContext */
@InterfaceAudience.Private
public FileContext() {}
@InterfaceAudience.Private
public void init(String contextName, ContextFactory factory) {
super.init(contextName, factory);
String fileName = getAttribute(FILE_NAME_PROPERTY);
if (fileName != null) {
file = new File(fileName);
}
parseAndSetPeriod(PERIOD_PROPERTY);
}
/**
* Returns the configured file name, or null.
*/
@InterfaceAudience.Private
public String getFileName() {
if (file == null) {
return null;
} else {
return file.getName();
}
}
/**
* Starts or restarts monitoring, by opening in append-mode, the
* file specified by the <code>fileName</code> attribute,
* if specified. Otherwise the data will be written to standard
* output.
*/
@InterfaceAudience.Private
public void startMonitoring()
throws IOException
{
if (file == null) {
writer = new PrintWriter(new BufferedOutputStream(System.out));
} else {
writer = new PrintWriter(new FileWriter(file, true));
}
super.startMonitoring();
}
/**
* Stops monitoring, closing the file.
* @see #close()
*/
@InterfaceAudience.Private
public void stopMonitoring() {
super.stopMonitoring();
if (writer != null) {
writer.close();
writer = null;
}
}
/**
* Emits a metrics record to a file.
*/
@InterfaceAudience.Private
public void emitRecord(String contextName, String recordName, OutputRecord outRec) {
writer.print(contextName);
writer.print(".");
writer.print(recordName);
String separator = ": ";
for (String tagName : outRec.getTagNames()) {
writer.print(separator);
separator = ", ";
writer.print(tagName);
writer.print("=");
writer.print(outRec.getTag(tagName));
}
for (String metricName : outRec.getMetricNames()) {
writer.print(separator);
separator = ", ";
writer.print(metricName);
writer.print("=");
writer.print(outRec.getMetric(metricName));
}
writer.println();
}
/**
* Flushes the output writer, forcing updates to disk.
*/
@InterfaceAudience.Private
public void flush() {
writer.flush();
}
}