lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-209] Implement JMX metrics reporter (#1045)

Browse Source
This commit is contained in:
ForwardXu
2019-11-28 19:17:34 +08:00
committed by leesf
parent da8d1334ee
commit 0b52ae3ac2
8 changed files with 159 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
hudi-client/src/test/java/org/apache/hudi/metrics/TestHoodieJmxMetrics.java Normal file
View File

@@ -0,0 +1,52 @@
/*
* 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.hudi.metrics;
import static org.apache.hudi.metrics.Metrics.registerGauge;
import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import org.apache.hudi.config.HoodieMetricsConfig;
import org.apache.hudi.config.HoodieWriteConfig;
import org.junit.Test;
/**
* Test for the Jmx metrics report.
*/
public class TestHoodieJmxMetrics extends TestHoodieMetrics {
@Override
public void start() {
HoodieWriteConfig config = mock(HoodieWriteConfig.class);
when(config.isMetricsOn()).thenReturn(true);
when(config.getMetricsReporterType()).thenReturn(MetricsReporterType.JMX);
when(config.getJmxHost()).thenReturn(HoodieMetricsConfig.DEFAULT_JMX_HOST);
when(config.getJmxPort()).thenReturn(HoodieMetricsConfig.DEFAULT_JMX_PORT);
new HoodieMetrics(config, "raw_table");
}
@Test
public void testRegisterGauge() {
registerGauge("jmx_metric", 123L);
assertTrue(Metrics.getInstance().getRegistry().getGauges()
.get("jmx_metric").getValue().toString().equals("123"));
}
}

4
hudi-client/src/test/java/org/apache/hudi/metrics/TestHoodieMetrics.java
View File

@@ -30,14 +30,12 @@ import static org.mockito.Mockito.when;
public class TestHoodieMetrics {
private HoodieMetrics metrics = null;
@Before
public void start() {
HoodieWriteConfig config = mock(HoodieWriteConfig.class);
when(config.isMetricsOn()).thenReturn(true);
when(config.getMetricsReporterType()).thenReturn(MetricsReporterType.INMEMORY);
metrics = new HoodieMetrics(config, "raw_table");
new HoodieMetrics(config, "raw_table");
}
@Test