访问耗时统计，自定义传输对象，只能最后一个字段是字符串

lkfs · Sep 28, 2020 · 7d8a9ee · 7d8a9ee
1 parent d1662c5
commit 7d8a9ee
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/net/venusoft/duration/AccessDurationDriver.java b/src/main/java/net/venusoft/duration/AccessDurationDriver.java
@@ -82,8 +82,8 @@ protected void reduce(Text key, Iterable<AccessInfoBean> values, Context context
 
     public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {
 
-        String inputPath = "hdfs://hadoop01:9000/input/";
-        String outputPath = "hdfs://hadoop01:9000/output1_2";
+        String inputPath = "hdfs://hadoop01:9000/input/2020-09-25_ibd-info-log.log";
+        String outputPath = "hdfs://hadoop01:9000/output1_4";
 
         Configuration conf = new Configuration();
         Job job = Job.getInstance(conf);