Java 类org.apache.log4j.LogManager 实例源码
项目：log4j-aws-appenders
文件：SNSAppenderIntegrationTest.java
/**
* Loads the test-specific Log4J configuration and resets the environment.
*/
public void setUp(String propertiesName)
throws Exception
{
URL config = ClassLoader.getSystemResource(propertiesName);
assertNotNull("missing configuration: " + propertiesName, config);
LogManager.resetConfiguration();
PropertyConfigurator.configure(config);
localLogger = Logger.getLogger(getClass());
runId = String.valueOf(System.currentTimeMillis());
resourceName = "SNSAppenderIntegrationTest-" + runId;
System.setProperty("SNSAppenderIntegrationTest.resourceName", resourceName);
localSNSclient = AmazonSNSClientBuilder.defaultClient();
localSQSclient = AmazonSQSClientBuilder.defaultClient();
}
项目：oscm
文件：Initializer.java
/**
* On change event
*/
void handleOnChange(File logFile) {
try {
long lastModif = logFile.lastModified();
if (lastModif > logFileLastModified) {
logFileLastModified = lastModif;
logger.debug("Reload log4j configuration from "
+ logFile.getAbsolutePath());
new PropertyConfigurator().doConfigure(
logFile.getAbsolutePath(),
LogManager.getLoggerRepository());
logFileWarning = false;
}
} catch (Exception e) {
if (!logFileWarning) {
logFileWarning = true;
logger.error(logFile.getAbsolutePath(), e);
}
}
}
项目：jwala
文件：JGroupsReportingLifeCycleListenerImplTest.java
@Before
public void setup() {
initMocks(this);
lifeCycleListener.setServerId("1");
lifeCycleListener.setServerName("testJvm");
lifeCycleListener.setJgroupsPreferIpv4Stack("true");
lifeCycleListener.setJgroupsConfigXml("tcp.xml");
lifeCycleListener.setJgroupsCoordinatorIp(prop.getProperty("coordinator.ip"));
lifeCycleListener.setJgroupsCoordinatorHostname("testHostname");
lifeCycleListener.setJgroupsCoordinatorPort("30000");
lifeCycleListener.setJgroupsClusterName("testCluster");
lifeCycleListener.setSchedulerDelayInitial("1");
lifeCycleListener.setSchedulerDelaySubsequent("1");
lifeCycleListener.setSchedulerDelayUnit("SECONDS");
lifeCycleListener.setSchedulerThreadCount("1");
LogManager.getRootLogger().addAppender(mockAppender);
}
项目：eds
文件：Log4jLoggerAdapter.java
@SuppressWarnings("unchecked")
public Log4jLoggerAdapter() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：ripme
文件：Utils.java
/**
* Configures root logger, either for FILE output or just console.
*/
public static void configureLogger() {
LogManager.shutdown();
String logFile;
if (getConfigBoolean("log.save", false)) {
logFile = "log4j.file.properties";
}
else {
logFile = "log4j.properties";
}
InputStream stream = Utils.class.getClassLoader().getResourceAsStream(logFile);
if (stream == null) {
PropertyConfigurator.configure("src/main/resources/" + logFile);
} else {
PropertyConfigurator.configure(stream);
}
logger.info("Loaded " + logFile);
try {
stream.close();
} catch (IOException e) { }
}
项目：dds-examples
文件：PublicationObserverTest.java
@Test(timeout = 10000)
public void testRunWithLevelDebug() {
// remember current level
Level originalLevel = LogManager.getRootLogger().getLevel();
try {
// set logging to TRACE
LogManager.getRootLogger().setLevel(Level.DEBUG);
// execute run method
testRun();
} finally {
// restore level
LogManager.getRootLogger().setLevel(originalLevel);
}
}
项目：dds-examples
文件：PublicationObserverTest.java
@Test(timeout = 10000)
public void testRunWithLevelTrace() {
// remember current level
Level originalLevel = LogManager.getRootLogger().getLevel();
try {
// set logging to TRACE
LogManager.getRootLogger().setLevel(Level.TRACE);
// execute run method
testRun();
} finally {
// restore level
LogManager.getRootLogger().setLevel(originalLevel);
}
}
项目：hadoop
文件：TestAuditLogs.java
private void configureAuditLogs() throws IOException {
// Shutdown the LogManager to release all logger open file handles.
// Unfortunately, Apache commons logging library does not provide
// means to release underlying loggers. For additional info look up
// commons library FAQ.
LogManager.shutdown();
File file = new File(auditLogFile);
if (file.exists()) {
assertTrue(file.delete());
}
Logger logger = ((Log4JLogger) FSNamesystem.auditLog).getLogger();
// disable logging while the cluster startup preps files
logger.setLevel(Level.OFF);
PatternLayout layout = new PatternLayout("%m%n");
RollingFileAppender appender = new RollingFileAppender(layout, auditLogFile);
logger.addAppender(appender);
}
项目：dds-examples
文件：SubscriptionObserverTest.java
@Test(timeout = 10000)
public void testRunWithLevelTrace() {
// remember current level
Level originalLevel = LogManager.getRootLogger().getLevel();
try {
// set logging to TRACE
LogManager.getRootLogger().setLevel(Level.TRACE);
// execute run method
testRun();
} finally {
// restore level
LogManager.getRootLogger().setLevel(originalLevel);
}
}
项目：EatDubbo
文件：LogPageHandler.java
@SuppressWarnings("unchecked")
public LogPageHandler() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：EatDubbo
文件：Log4jLoggerAdapter.java
@SuppressWarnings("unchecked")
public Log4jLoggerAdapter() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：oscm-app
文件：Initializer.java
/**
* On change event
*/
void handleOnChange(File logFile) {
try {
long lastModif = logFile.lastModified();
if (lastModif > logFileLastModified) {
logFileLastModified = lastModif;
logger.debug("Reload log4j configuration from "
+ logFile.getAbsolutePath());
new PropertyConfigurator().doConfigure(
logFile.getAbsolutePath(),
LogManager.getLoggerRepository());
logFileWarning = false;
}
} catch (Exception e) {
if (!logFileWarning) {
logFileWarning = true;
logger.error(logFile.getAbsolutePath(), e);
}
}
}
项目：hadoop
文件：ApplicationMaster.java
/**
* @param args Command line args
*/
public static void main(String[] args) {
boolean result = false;
try {
ApplicationMaster appMaster = new ApplicationMaster();
LOG.info("Initializing ApplicationMaster");
boolean doRun = appMaster.init(args);
if (!doRun) {
System.exit(0);
}
appMaster.run();
result = appMaster.finish();
} catch (Throwable t) {
LOG.fatal("Error running ApplicationMaster", t);
LogManager.shutdown();
ExitUtil.terminate(1, t);
}
if (result) {
LOG.info("Application Master completed successfully. exiting");
System.exit(0);
} else {
LOG.info("Application Master failed. exiting");
System.exit(2);
}
}
项目：dubbo2
文件：LogPageHandler.java
@SuppressWarnings("unchecked")
public LogPageHandler() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：dubbo2
文件：Log4jLoggerAdapter.java
@SuppressWarnings("unchecked")
public Log4jLoggerAdapter() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：dubbocloud
文件：Log4jLoggerAdapter.java
@SuppressWarnings("unchecked")
public Log4jLoggerAdapter() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：oscm
文件：Initializer.java
/**
* On change event
*/
void handleOnChange(File logFile) {
try {
long lastModif = logFile.lastModified();
if (lastModif > logFileLastModified) {
logFileLastModified = lastModif;
LOGGER.debug("Reload log4j configuration from " + logFile.getAbsolutePath());
new PropertyConfigurator().doConfigure(logFile.getAbsolutePath(), LogManager.getLoggerRepository());
logFileWarning = false;
}
} catch (Exception e) {
if (!logFileWarning) {
logFileWarning = true;
LOGGER.error(logFile.getAbsolutePath(), e);
}
}
}
项目：oscm
文件：Initializer.java
/**
* On change event
*/
void handleOnChange(File logFile) {
try {
long lastModif = logFile.lastModified();
if (lastModif > logFileLastModified) {
logFileLastModified = lastModif;
LOGGER.debug("Reload log4j configuration from "
+ logFile.getAbsolutePath());
new PropertyConfigurator().doConfigure(
logFile.getAbsolutePath(),
LogManager.getLoggerRepository());
logFileWarning = false;
}
} catch (Exception e) {
if (!logFileWarning) {
logFileWarning = true;
LOGGER.error(logFile.getAbsolutePath(), e);
}
}
}
项目：dubbocloud
文件：LogPageHandler.java
@SuppressWarnings("unchecked")
public LogPageHandler() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：flume-release-1.7.0
文件：TestLog4jAppender.java
@Test(expected = EventDeliveryException.class)
public void testSlowness() throws Throwable {
ch = new SlowMemoryChannel(2000);
Configurables.configure(ch, new Context());
configureSource();
props.put("log4j.appender.out2.Timeout", "1000");
props.put("log4j.appender.out2.layout", "org.apache.log4j.PatternLayout");
props.put("log4j.appender.out2.layout.ConversionPattern",
"%-5p [%t]: %m%n");
PropertyConfigurator.configure(props);
Logger logger = LogManager.getLogger(TestLog4jAppender.class);
Thread.currentThread().setName("Log4jAppenderTest");
int level = 10000;
String msg = "This is log message number" + String.valueOf(1);
try {
logger.log(Level.toLevel(level), msg);
} catch (FlumeException ex) {
throw ex.getCause();
}
}
项目：FSTestTools
文件：InitLog4jLoggingRule.java
/**
* Returns true if it appears that log4j have been previously configured. This code checks to see if there are any appenders defined for log4j
* which is the definitive way to tell if log4j is already initialized. See http://wiki.apache.org/logging-log4j/UsefulCode
*
* @return true if Log4J is configured, false otherwise.
*/
private static boolean isLog4JConfigured() {
final Enumeration<?> appenders = Logger.getRootLogger().getAllAppenders();
if (appenders.hasMoreElements()) {
return true;
} else {
final Enumeration<?> loggers = LogManager.getCurrentLoggers();
while (loggers.hasMoreElements()) {
final Logger c = (Logger) loggers.nextElement();
if (c.getAllAppenders().hasMoreElements()) {
return true;
}
}
}
return false;
}
项目：hadoop
文件：TaskLog.java
@SuppressWarnings("unchecked")
public synchronized static void syncLogs(String logLocation,
TaskAttemptID taskid,
boolean isCleanup)
throws IOException {
System.out.flush();
System.err.flush();
Enumeration<Logger> allLoggers = LogManager.getCurrentLoggers();
while (allLoggers.hasMoreElements()) {
Logger l = allLoggers.nextElement();
Enumeration<Appender> allAppenders = l.getAllAppenders();
while (allAppenders.hasMoreElements()) {
Appender a = allAppenders.nextElement();
if (a instanceof TaskLogAppender) {
((TaskLogAppender)a).flush();
}
}
}
if (currentTaskid != taskid) {
currentTaskid = taskid;
resetPrevLengths(logLocation);
}
writeToIndexFile(logLocation, isCleanup);
}
项目：hadoop
文件：Server.java
/**
* Initializes Log4j logging.
*
* @throws ServerException thrown if Log4j could not be initialized.
*/
protected void initLog() throws ServerException {
verifyDir(logDir);
LogManager.resetConfiguration();
File log4jFile = new File(configDir, name + "-log4j.properties");
if (log4jFile.exists()) {
PropertyConfigurator.configureAndWatch(log4jFile.toString(), 10 * 1000); //every 10 secs
log = LoggerFactory.getLogger(Server.class);
} else {
Properties props = new Properties();
try {
InputStream is = getResource(DEFAULT_LOG4J_PROPERTIES);
try {
props.load(is);
} finally {
is.close();
}
} catch (IOException ex) {
throw new ServerException(ServerException.ERROR.S03, DEFAULT_LOG4J_PROPERTIES, ex.getMessage(), ex);
}
PropertyConfigurator.configure(props);
log = LoggerFactory.getLogger(Server.class);
log.warn("Log4j [{}] configuration file not found, using default configuration from classpath", log4jFile);
}
}
项目：dubbox-hystrix
文件：LogPageHandler.java
@SuppressWarnings("unchecked")
public LogPageHandler() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：dubbox-hystrix
文件：Log4jLoggerAdapter.java
@SuppressWarnings("unchecked")
public Log4jLoggerAdapter() {
try {
org.apache.log4j.Logger logger = LogManager.getRootLogger();
if (logger != null) {
Enumeration<Appender> appenders = logger.getAllAppenders();
if (appenders != null) {
while (appenders.hasMoreElements()) {
Appender appender = appenders.nextElement();
if (appender instanceof FileAppender) {
FileAppender fileAppender = (FileAppender)appender;
String filename = fileAppender.getFile();
file = new File(filename);
break;
}
}
}
}
} catch (Throwable t) {
}
}
项目：api2swagger
文件：LogHelper.java
public synchronized static void initializeLogger() {
if(isInitialized)
return;
InputStream configStream = null;
try {
configStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("log4j.xml");
if(configStream != null){
new DOMConfigurator().doConfigure(configStream, LogManager.getLoggerRepository());
} else {
System.out.println("Error reading log configurstion file. Could not initialize logger.");
}
} finally{
if(configStream != null){
try {
configStream.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
isInitialized = true;
}
项目：sstore-soft
文件：LoggerUtil.java
/**
* Flush the appenders for all of the active loggers
*/
public static void flushAllLogs() {
LoggerRepository loggerRepo = LogManager.getLoggerRepository();
for (Logger logger : CollectionUtil.iterable(loggerRepo.getCurrentLoggers(), Logger.class)) {
LoggerUtil.flushLogs(logger);
} // FOR
}
项目：hadoop
文件：Server.java
/**
* Destroys the server.
* <p>
* All services are destroyed in reverse order of initialization, then the
* Log4j framework is shutdown.
*/
public void destroy() {
ensureOperational();
destroyServices();
log.info("Server [{}] shutdown!", name);
log.info("======================================================");
if (!Boolean.getBoolean("test.circus")) {
LogManager.shutdown();
}
status = Status.SHUTDOWN;
}
项目：EatDubbo
文件：LogPageHandler.java
public Page handle(URL url) {
long size = 0;
String content = "";
String modified = "Not exist";
if (file != null && file.exists()) {
try {
FileInputStream fis = new FileInputStream(file);
FileChannel channel = fis.getChannel();
size = channel.size();
ByteBuffer bb;
if (size <= SHOW_LOG_LENGTH) {
bb = ByteBuffer.allocate((int) size);
channel.read(bb, 0);
} else {
int pos = (int) (size - SHOW_LOG_LENGTH);
bb = ByteBuffer.allocate(SHOW_LOG_LENGTH);
channel.read(bb, pos);
}
bb.flip();
content = new String(bb.array()).replace("<", "<")
.replace(">", ">").replace("\n", "<br/><br/>");
modified = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
.format(new Date(file.lastModified()));
} catch (IOException e) {
}
}
Level level = LogManager.getRootLogger().getLevel();
List<List<String>> rows = new ArrayList<List<String>>();
List<String> row = new ArrayList<String>();
row.add(content);
rows.add(row);
return new Page("Log", "Log", new String[] {(file == null ? "" : file.getName()) + ", " + size + " bytes, " + modified + ", " + level}, rows);
}
项目：ats-framework
文件：AutoLogger.java
/**
* Send an event to the logging system
*
* @param event the event to send
*/
private void sendEvent( LoggingEvent event ) {
// check if this level is allowed for the repository at all
if (LogManager.getLoggerRepository().isDisabled(event.getLevel().toInt())) {
return;
}
// check if the event level is allowed for this logger
if (event.getLevel().isGreaterOrEqual(logger.getEffectiveLevel())) {
logger.callAppenders(event);
}
}
项目：log4j-aws-appenders
文件：TestCloudWatchAppender.java
@Test
public void testWriteHeaderAndFooter() throws Exception
{
initialize("TestCloudWatchAppender/testWriteHeaderAndFooter.properties");
logger.debug("blah blah blah");
// must retrieve writer before we shut down
MockCloudWatchWriter mockWriter = appender.getMockWriter();
LogManager.shutdown();
assertEquals("number of messages written to log", 3, mockWriter.messages.size());
assertEquals("header is first", HeaderFooterLayout.HEADER, mockWriter.getMessage(0));
assertEquals("footer is last", HeaderFooterLayout.FOOTER, mockWriter.getMessage(2));
}
项目：cli-java
文件：Utils.java
/**
* Set logging level to given value. If not explicitly
* specified, default level is used from *logger* properties file.
* (As of the time writing - simplelogger.properties is used as default.)
* <p/>
* NOTE: SLF4J is not capable of changing log levels programatically!
* We have to change the System/File property of given underlying logger.
*
* @param logLevel logging level to be logger set to
*/
public static void setLogLevel(String logLevel) {
org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger("com.redhat.mqe.jms");
Level level;
switch (logLevel.toLowerCase()) {
case "all":
level = Level.ALL;
break;
case "trace":
level = Level.TRACE;
break;
case "debug":
level = Level.DEBUG;
break;
case "info":
level = Level.INFO;
break;
case "warn":
level = Level.WARN;
break;
case "error":
level = Level.ERROR;
break;
case "fatal":
level = Level.FATAL;
break;
case "off":
level = Level.OFF;
break;
default:
level = Level.INFO;
}
LogManager.getRootLogger().setLevel(level);
logger.setLevel(level);
}
项目：log4j-aws-appenders
文件：TestKinesisAppender.java
@Test
public void testWriteHeaderAndFooter() throws Exception
{
initialize("TestKinesisAppender/testWriteHeaderAndFooter.properties");
logger.debug("blah blah blah");
// must retrieve writer before we shut down
MockKinesisWriter writer = appender.getMockWriter();
LogManager.shutdown();
assertEquals("number of messages written to log", 3, writer.messages.size());
assertEquals("header is first", HeaderFooterLayout.HEADER, writer.getMessage(0));
assertEquals("footer is last", HeaderFooterLayout.FOOTER, writer.getMessage(2));
}
项目：log4j-aws-appenders
文件：CloudWatchAppenderIntegrationTest.java
/**
* Loads the test-specific Log4J configuration and resets the environment.
*/
public void setUp(String propertiesName, String logGroupName) throws Exception
{
URL config = ClassLoader.getSystemResource(propertiesName);
assertNotNull("missing configuration: " + propertiesName, config);
LogManager.resetConfiguration();
PropertyConfigurator.configure(config);
localLogger = Logger.getLogger(getClass());
localClient = AWSLogsClientBuilder.defaultClient();
deleteLogGroupIfExists(logGroupName);
}
项目：log4j-aws-appenders
文件：KinesisAppenderIntegrationTest.java
/**
* Loads the test-specific Log4J configuration and resets the environment.
*/
public void setUp(String propertiesName, String streamName) throws Exception
{
URL config = ClassLoader.getSystemResource(propertiesName);
assertNotNull("missing configuration: " + propertiesName, config);
LogManager.resetConfiguration();
PropertyConfigurator.configure(config);
localLogger = Logger.getLogger(getClass());
localClient = AmazonKinesisClientBuilder.defaultClient();
deleteStreamIfExists(streamName);
}
项目：dubbo2
文件：LogPageHandler.java
public Page handle(URL url) {
long size = 0;
String content = "";
String modified = "Not exist";
if (file != null && file.exists()) {
try {
FileInputStream fis = new FileInputStream(file);
FileChannel channel = fis.getChannel();
size = channel.size();
ByteBuffer bb;
if (size <= SHOW_LOG_LENGTH) {
bb = ByteBuffer.allocate((int) size);
channel.read(bb, 0);
} else {
int pos = (int) (size - SHOW_LOG_LENGTH);
bb = ByteBuffer.allocate(SHOW_LOG_LENGTH);
channel.read(bb, pos);
}
bb.flip();
content = new String(bb.array()).replace("<", "<")
.replace(">", ">").replace("\n", "<br/><br/>");
modified = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
.format(new Date(file.lastModified()));
} catch (IOException e) {
}
}
Level level = LogManager.getRootLogger().getLevel();
List<List<String>> rows = new ArrayList<List<String>>();
List<String> row = new ArrayList<String>();
row.add(content);
rows.add(row);
return new Page("Log", "Log", new String[] {(file == null ? "" : file.getName()) + ", " + size + " bytes, " + modified + ", " + level}, rows);
}
项目：Apache-Spark-2x-for-Java-Developers
文件：XMLFileOperations.java
public static void main(String[] args) {
System.setProperty("hadoop.home.dir", "E:\\sumitK\\Hadoop");
SparkSession sparkSession = SparkSession
.builder()
.master("local")
.config("spark.sql.warehouse.dir","file:///E:/sumitK/Hadoop/warehouse")
.appName("JavaALSExample")
.getOrCreate();
Logger rootLogger = LogManager.getRootLogger();
rootLogger.setLevel(Level.WARN);
HashMap<String, String> params = new HashMap<String, String>();
params.put("rowTag", "food");
params.put("failFast", "true");
Dataset<Row> docDF = sparkSession.read()
.format("com.databricks.spark.xml")
.options(params)
.load("C:/Users/sumit.kumar/git/learning/src/main/resources/breakfast_menu.xml");
docDF.printSchema();
docDF.show();
docDF.write().format("com.databricks.spark.xml")
.option("rootTag", "food")
.option("rowTag", "food")
.save("C:/Users/sumit.kumar/git/learning/src/main/resources/newMenu.xml");
}
项目：Apache-Spark-2x-for-Java-Developers
文件：FileStreamingEx.java
public static void main(String[] args) {
//Window Specific property if Hadoop is not instaalled or HADOOP_HOME is not set
System.setProperty("hadoop.home.dir", "E:\\hadoop");
//Logger rootLogger = LogManager.getRootLogger();
//rootLogger.setLevel(Level.WARN);
SparkConf conf = new SparkConf().setAppName("KafkaExample").setMaster("local[*]");
String inputDirectory="E:\\hadoop\\streamFolder\\";
JavaSparkContext sc = new JavaSparkContext(conf);
JavaStreamingContext streamingContext = new JavaStreamingContext(sc, Durations.seconds(1));
// streamingContext.checkpoint("E:\\hadoop\\checkpoint");
Logger rootLogger = LogManager.getRootLogger();
rootLogger.setLevel(Level.WARN);
JavaDStream<String> streamfile = streamingContext.textFileStream(inputDirectory);
streamfile.print();
streamfile.foreachRDD(rdd-> rdd.foreach(x -> System.out.println(x)));
JavaPairDStream<LongWritable, Text> streamedFile = streamingContext.fileStream(inputDirectory, LongWritable.class, Text.class, TextInputFormat.class);
streamedFile.print();
streamingContext.start();
try {
streamingContext.awaitTermination();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
项目：hadoop
文件：TaskLog.java
public static synchronized void syncLogsShutdown(
ScheduledExecutorService scheduler)
{
// flush standard streams
//
System.out.flush();
System.err.flush();
if (scheduler != null) {
scheduler.shutdownNow();
}
// flush & close all appenders
LogManager.shutdown();
}
项目：flume-release-1.7.0
文件：TestLog4jAppender.java
@Test
public void testLog4jAppenderFailureUnsafeMode() throws Throwable {
configureSource();
props.setProperty("log4j.appender.out2.UnsafeMode", String.valueOf(true));
PropertyConfigurator.configure(props);
Logger logger = LogManager.getLogger(TestLog4jAppender.class);
source.stop();
sendAndAssertFail(logger);
}