标签:url equal oop log login table protected leo context
今天我先搭建了环境
自己修改了网上的代码分为两个类 LogBean对数据进行封装打包
package org.apache.hadoop.examples;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
public class LogBean implements WritableComparable<LogBean> {
private String id;
private String time;
private String traffic;
private String book;
private String voide;
public LogBean() {
super();
}
public LogBean(String id, String traffic, String time,String book,String voide) {
this.time = time;
this.id = id;
this.traffic = traffic;
this.book=book;
this.voide=voide;
}
@Override
public String toString() {
return "LogBean{" +
"id=‘" + id + ‘ ‘ +
", time=‘" + time+ ‘ ‘ +
", traffic=‘" + traffic + ‘ ‘ +
", book=‘" + book + ‘ ‘ +
", voide=‘" + voide + ‘ ‘ +
‘}‘;
}
public String getTime() {
return time;
}
public void setTime(String time) {
this.time = time;
}
public String getId() {
return id;
}
public void setIp(String id) {
this.id = id;
}
public String getBook() {
return book;
}
public void setBook(String book) {
this.book = book;
}
public String getVoide() {
return voide;
}
public void setUrl(String voide) {
this.voide = voide;
}
@Override
public int compareTo(LogBean o) {
return 0;
}
@Override
public void write(DataOutput out) throws IOException {
out.writeUTF(id);
out.writeUTF(time);
out.writeUTF(traffic);
out.writeUTF(book);
out.writeUTF(voide);
}
@Override
public void readFields(DataInput in) throws IOException {
id = in.readUTF();
time = in.readUTF();
traffic =in.readUTF();
book =in.readUTF();
voide =in.readUTF();
}
}
BaiDuLog.java
负责对数据进行处理然后筛选
标签:url equal oop log login table protected leo context
原文地址:https://www.cnblogs.com/yang-qiu/p/11853953.html