commit a35576502ac775c4267629368aa793691b67e9e6 Author: fly6516 Date: Sun May 11 10:15:41 2025 +0000 init code and settings diff --git a/.idea/.gitignore b/.idea/.gitignore new file mode 100644 index 0000000..26d3352 --- /dev/null +++ b/.idea/.gitignore @@ -0,0 +1,3 @@ +# Default ignored files +/shelf/ +/workspace.xml diff --git a/.idea/artifacts/elec_producer_jar.xml b/.idea/artifacts/elec_producer_jar.xml new file mode 100644 index 0000000..964f463 --- /dev/null +++ b/.idea/artifacts/elec_producer_jar.xml @@ -0,0 +1,112 @@ + + + $PROJECT_DIR$/out/artifacts/elec_producer_jar + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/compiler.xml b/.idea/compiler.xml new file mode 100644 index 0000000..4e8d850 --- /dev/null +++ b/.idea/compiler.xml @@ -0,0 +1,15 @@ + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml new file mode 100644 index 0000000..712ab9d --- /dev/null +++ b/.idea/jarRepositories.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/misc.xml b/.idea/misc.xml new file mode 100644 index 0000000..132404b --- /dev/null +++ b/.idea/misc.xml @@ -0,0 +1,14 @@ + + + + + + + + + + \ No newline at end of file diff --git a/.idea/uiDesigner.xml b/.idea/uiDesigner.xml new file mode 100644 index 0000000..e96534f --- /dev/null +++ b/.idea/uiDesigner.xml @@ -0,0 +1,124 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/.idea/vcs.xml b/.idea/vcs.xml new file mode 100644 index 0000000..94a25f7 --- /dev/null +++ b/.idea/vcs.xml @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/elec-common/pom.xml b/elec-common/pom.xml new file mode 100644 index 0000000..e152adc --- /dev/null +++ b/elec-common/pom.xml @@ -0,0 +1,33 @@ + + + + project-elec + com.educg + 1.0-SNAPSHOT + + 4.0.0 + + elec-common + + + 8 + 8 + + + + + org.apache.hbase + hbase-server + 1.3.1 + + + + org.apache.hbase + hbase-client + 1.3.1 + + + + \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/api/Column.java b/elec-common/src/main/java/com/educg/elec/common/api/Column.java new file mode 100644 index 0000000..c5e019e --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/api/Column.java @@ -0,0 +1,16 @@ +package com.educg.elec.common.api; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +@Target({ElementType.FIELD}) +@Retention(RetentionPolicy.RUNTIME) +public @interface Column { + + String family() default "info"; + + String column() default ""; + +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/api/RowKey.java b/elec-common/src/main/java/com/educg/elec/common/api/RowKey.java new file mode 100644 index 0000000..661781a --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/api/RowKey.java @@ -0,0 +1,12 @@ +package com.educg.elec.common.api; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +@Target({ElementType.FIELD}) +@Retention(RetentionPolicy.RUNTIME) +public @interface RowKey { + +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/api/TableRef.java b/elec-common/src/main/java/com/educg/elec/common/api/TableRef.java new file mode 100644 index 0000000..a60fec0 --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/api/TableRef.java @@ -0,0 +1,12 @@ +package com.educg.elec.common.api; + +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; + +@Target({ElementType.TYPE}) +@Retention(RetentionPolicy.RUNTIME) +public @interface TableRef { + String value(); +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/bean/BaseDao.java b/elec-common/src/main/java/com/educg/elec/common/bean/BaseDao.java new file mode 100644 index 0000000..be8b33b --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/bean/BaseDao.java @@ -0,0 +1,182 @@ +package com.educg.elec.common.bean; + +import com.educg.elec.common.api.Column; +import com.educg.elec.common.api.RowKey; +import com.educg.elec.common.api.TableRef; +import com.educg.elec.common.constant.Names; +import com.educg.elec.common.constant.ValueConstant; +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.hbase.*; +import org.apache.hadoop.hbase.client.*; +import org.apache.hadoop.hbase.util.Bytes; + + +import java.lang.reflect.Field; +import java.util.ArrayList; +import java.util.List; + +public abstract class BaseDao { + + private ThreadLocal connHolder = new ThreadLocal(); + private ThreadLocal adminHolder = new ThreadLocal(); + + protected void start() throws Exception{ + getConnection(); + getAdmin(); + } + + protected void end() throws Exception{ + Admin admin = getAdmin(); + if(admin != null){ + admin.close(); + adminHolder.remove(); + } + Connection conn = getConnection(); + if(conn != null){ + conn.close(); + connHolder.remove(); + } + } + + /* + get connection object + */ + protected synchronized Connection getConnection() throws Exception{ + Connection conn = connHolder.get(); + if(conn == null){ + Configuration conf = HBaseConfiguration.create(); + conn = ConnectionFactory.createConnection(conf); + connHolder.set(conn); + } + return conn; + } + + /* + get admin object + */ + protected synchronized Admin getAdmin() throws Exception{ + Admin admin = adminHolder.get(); + if(admin == null){ + admin = getConnection().getAdmin(); + adminHolder.set(admin); + } + return admin; + } + + protected void createNamespaceNX(String namespace) throws Exception{ + Admin admin = getAdmin(); + try { + admin.getNamespaceDescriptor(namespace); + }catch (NamespaceNotFoundException e){ + NamespaceDescriptor namespaceDescriptor = NamespaceDescriptor.create(namespace).build(); + admin.createNamespace(namespaceDescriptor); + } + } + + protected void createTableXX(String name,String... families) throws Exception{ + createTableXX(name,null,families); + } + protected void createTableXX(String name,Integer regionCount,String... families) throws Exception{ + Admin admin = getAdmin(); + TableName tableName = TableName.valueOf(name); + + if(admin.tableExists(tableName)){ + //delete table + deleteTable(name); + } + + //create table + createTable(name,regionCount,families); + } + + protected void deleteTable(String name) throws Exception{ + Admin admin = getAdmin(); + TableName tableName = TableName.valueOf(name); + admin.disableTable(tableName); + admin.deleteTable(tableName); + } + + private void createTable(String name,Integer regionCount,String... families) throws Exception{ + Admin admin = getAdmin(); + TableName tableName = TableName.valueOf(name); + + HTableDescriptor tableDescriptor = new HTableDescriptor(tableName); + if(families == null || families.length == 0){ + families = new String[1]; + families[0] = Names.CF_INFO.getValue(); + } + for (String family : families) { + HColumnDescriptor columnDescriptor = new HColumnDescriptor(family); + tableDescriptor.addFamily(columnDescriptor); + } + if(regionCount == null || regionCount <= 1){ + admin.createTable(tableDescriptor); + }else { + byte[][] splitKeys = genSplitKeys(regionCount); + admin.createTable(tableDescriptor,splitKeys); + } + } + + private byte[][] genSplitKeys(Integer regionCount){ + int splitKeyCount = regionCount - 1; + byte[][] bs = new byte[splitKeyCount][]; + List bsList = new ArrayList(); + for(int i = 0; i < splitKeyCount; i++){ + String splitKey = i + "|"; + bsList.add(Bytes.toBytes(splitKey)); + } + bsList.toArray(bs); + return bs; + } + + protected void putData(Object obj) throws Exception{ + + Class clazz = obj.getClass(); + TableRef tableRef = (TableRef) clazz.getAnnotation(TableRef.class); + String tableName = tableRef.value(); + + String strRowKey = ""; + Field[] fs = clazz.getDeclaredFields(); + for(Field f : fs){ + RowKey rowKey = f.getAnnotation(RowKey.class); + if (rowKey != null){ + f.setAccessible(true); + strRowKey = (String)f.get(obj); + break; + } + } + Connection conn = getConnection(); + Table table = conn.getTable(TableName.valueOf(tableName)); + + Put put = new Put(Bytes.toBytes(strRowKey)); + + for (Field f : fs){ + Column column = f.getAnnotation(Column.class); + if (column != null){ + String family = column.family(); + String colName = column.column(); + if ( colName == null || "".equals(colName)){ + colName = f.getName(); + } + f.setAccessible(true); + String value =(String) f.get(obj); + put.addColumn(Bytes.toBytes(family), Bytes.toBytes(colName), Bytes.toBytes(value)); + } + } + //insert + table.put(put); + //close + table.close(); + } + + + protected int genRegionNumber(String date){ + + int sub = Integer.parseInt(date.substring(0, 4)) - 2006; + + + int regionNum = sub % ValueConstant.REGION_COUNT; + + return regionNum; + } +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/bean/Consumer.java b/elec-common/src/main/java/com/educg/elec/common/bean/Consumer.java new file mode 100644 index 0000000..0094af5 --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/bean/Consumer.java @@ -0,0 +1,7 @@ +package com.educg.elec.common.bean; + +import java.io.Closeable; + +public interface Consumer extends Closeable { + public void consume() throws Exception; +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/bean/Val.java b/elec-common/src/main/java/com/educg/elec/common/bean/Val.java new file mode 100644 index 0000000..efb4dad --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/bean/Val.java @@ -0,0 +1,11 @@ +package com.educg.elec.common.bean; + +/** + * value object + */ +public interface Val { + + public void setValue(Object val); + public Object getValue(); + +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/constant/Names.java b/elec-common/src/main/java/com/educg/elec/common/constant/Names.java new file mode 100644 index 0000000..2569f4d --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/constant/Names.java @@ -0,0 +1,30 @@ +package com.educg.elec.common.constant; + +import com.educg.elec.common.bean.Val; + +/** + * Name Enums + */ +public enum Names implements Val { + NAMESPACE("elec"), + TABLE("elec:eleclog"), + CF_INFO("info"), + TOPIC("eleclog") + ; + + private String name; + + private Names(String name){ + this.name=name; + } + + @Override + public void setValue(Object val) { + this.name = (String) val; + } + + @Override + public String getValue() { + return name; + } +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/constant/ValueConstant.java b/elec-common/src/main/java/com/educg/elec/common/constant/ValueConstant.java new file mode 100644 index 0000000..fbbbd00 --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/constant/ValueConstant.java @@ -0,0 +1,5 @@ +package com.educg.elec.common.constant; + +public class ValueConstant { + public static final Integer REGION_COUNT = 6; +} \ No newline at end of file diff --git a/elec-common/src/main/java/com/educg/elec/common/util/DateFormatUtil.java b/elec-common/src/main/java/com/educg/elec/common/util/DateFormatUtil.java new file mode 100644 index 0000000..3648c5d --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/util/DateFormatUtil.java @@ -0,0 +1,23 @@ +package com.educg.elec.common.util; + + +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Date; + +public class DateFormatUtil { + public static String format(String originalDate) { + String newDate = null; + SimpleDateFormat originalFormat = new SimpleDateFormat("d/M/yyyy"); + originalFormat.setLenient(false); + SimpleDateFormat newFormat = new SimpleDateFormat("yyyyMMdd"); + try { + Date date = originalFormat.parse(originalDate); + newDate = newFormat.format(date); + } catch (ParseException e) { + System.out.println("fail: " + originalDate); + e.printStackTrace(); + } + return newDate; + } +} diff --git a/elec-common/src/main/java/com/educg/elec/common/util/TimeFormatUtil.java b/elec-common/src/main/java/com/educg/elec/common/util/TimeFormatUtil.java new file mode 100644 index 0000000..ac0c7c9 --- /dev/null +++ b/elec-common/src/main/java/com/educg/elec/common/util/TimeFormatUtil.java @@ -0,0 +1,25 @@ +package com.educg.elec.common.util; + +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.Date; + +public class TimeFormatUtil { + + public static String format(String originalTime){ + String newTime = null; + SimpleDateFormat originalFormat = new SimpleDateFormat("HH:mm:ss"); + SimpleDateFormat newFormat = new SimpleDateFormat("HHmmss"); + + try { + Date time = originalFormat.parse(originalTime); + newTime = newFormat.format(time); + + System.out.println(newTime); + } catch (ParseException e) { + e.printStackTrace(); + } + return newTime; + } + +} diff --git a/elec-common/target/classes/com/educg/elec/common/api/Column.class b/elec-common/target/classes/com/educg/elec/common/api/Column.class new file mode 100644 index 0000000..2d50c64 Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/api/Column.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/api/RowKey.class b/elec-common/target/classes/com/educg/elec/common/api/RowKey.class new file mode 100644 index 0000000..8d6baf8 Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/api/RowKey.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/api/TableRef.class b/elec-common/target/classes/com/educg/elec/common/api/TableRef.class new file mode 100644 index 0000000..84e26eb Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/api/TableRef.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/bean/BaseDao.class b/elec-common/target/classes/com/educg/elec/common/bean/BaseDao.class new file mode 100644 index 0000000..9752eba Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/bean/BaseDao.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/bean/Consumer.class b/elec-common/target/classes/com/educg/elec/common/bean/Consumer.class new file mode 100644 index 0000000..d0fde2b Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/bean/Consumer.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/bean/Val.class b/elec-common/target/classes/com/educg/elec/common/bean/Val.class new file mode 100644 index 0000000..a765251 Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/bean/Val.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/constant/Names.class b/elec-common/target/classes/com/educg/elec/common/constant/Names.class new file mode 100644 index 0000000..46dffc7 Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/constant/Names.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/constant/ValueConstant.class b/elec-common/target/classes/com/educg/elec/common/constant/ValueConstant.class new file mode 100644 index 0000000..eec2df8 Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/constant/ValueConstant.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/util/DateFormatUtil.class b/elec-common/target/classes/com/educg/elec/common/util/DateFormatUtil.class new file mode 100644 index 0000000..63ad5fa Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/util/DateFormatUtil.class differ diff --git a/elec-common/target/classes/com/educg/elec/common/util/TimeFormatUtil.class b/elec-common/target/classes/com/educg/elec/common/util/TimeFormatUtil.class new file mode 100644 index 0000000..8495701 Binary files /dev/null and b/elec-common/target/classes/com/educg/elec/common/util/TimeFormatUtil.class differ diff --git a/elec-consumer/pom.xml b/elec-consumer/pom.xml new file mode 100644 index 0000000..1579ac1 --- /dev/null +++ b/elec-consumer/pom.xml @@ -0,0 +1,39 @@ + + + + project-elec + com.educg + 1.0-SNAPSHOT + + 4.0.0 + + elec-consumer + + + 8 + 8 + + + + + org.apache.kafka + kafka-clients + 2.0.0 + + + + org.apache.kafka + kafka_2.12 + 0.11.0.0 + + + + com.educg + elec-common + 1.0-SNAPSHOT + + + + \ No newline at end of file diff --git a/elec-consumer/src/main/java/com/educg/elec/consumer/Bootstrap.java b/elec-consumer/src/main/java/com/educg/elec/consumer/Bootstrap.java new file mode 100644 index 0000000..ce0cc77 --- /dev/null +++ b/elec-consumer/src/main/java/com/educg/elec/consumer/Bootstrap.java @@ -0,0 +1,22 @@ +package com.educg.elec.consumer; + +import com.educg.elec.common.bean.Consumer; +import com.educg.elec.consumer.bean.ElecConsumer; + +import java.io.IOException; + +/** + * Consumer Bootstrap + */ +public class Bootstrap { + public static void main(String[] args) throws Exception { + //create consumer + Consumer consumer = new ElecConsumer(); + + //consume data + consumer.consume(); + + //close consumer + consumer.close(); + } +} \ No newline at end of file diff --git a/elec-consumer/src/main/java/com/educg/elec/consumer/bean/ElecConsumer.java b/elec-consumer/src/main/java/com/educg/elec/consumer/bean/ElecConsumer.java new file mode 100644 index 0000000..cfad96e --- /dev/null +++ b/elec-consumer/src/main/java/com/educg/elec/consumer/bean/ElecConsumer.java @@ -0,0 +1,54 @@ +package com.educg.elec.consumer.bean; + +import com.educg.elec.common.bean.Consumer; +import com.educg.elec.common.constant.Names; +import com.educg.elec.consumer.dao.HBaseDao; +import org.apache.kafka.clients.consumer.ConsumerRecord; +import org.apache.kafka.clients.consumer.ConsumerRecords; +import org.apache.kafka.clients.consumer.KafkaConsumer; + +import java.io.IOException; +import java.time.Duration; +import java.util.Arrays; +import java.util.Properties; + +public class ElecConsumer implements Consumer { + + @Override + public void consume() throws Exception { + //kafka configuration + Properties prop = new Properties(); + try { + prop.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("consumer.properties")); + } catch (IOException e) { + e.printStackTrace(); + } + //get flume data + KafkaConsumer consumer = new KafkaConsumer(prop); + //subscribe kafka topic + consumer.subscribe(Arrays.asList(Names.TOPIC.getValue())); + + HBaseDao dao = new HBaseDao(); + dao.init(); + //consume + + Record beforeRecord = new Record(); + while (true){ + ConsumerRecords consumerRecords = consumer.poll(Duration.ofMillis(100)); + for (ConsumerRecord consumerRecord : consumerRecords) { +// System.out.println(consumerRecord.value()); +// dao.insertData(consumerRecord.value()); + + Record record = new Record(consumerRecord.value()); + dao.insertData(record); + System.out.println(record); + } + } + + } + + @Override + public void close() throws IOException { + + } +} diff --git a/elec-consumer/src/main/java/com/educg/elec/consumer/bean/Record.java b/elec-consumer/src/main/java/com/educg/elec/consumer/bean/Record.java new file mode 100644 index 0000000..5859126 --- /dev/null +++ b/elec-consumer/src/main/java/com/educg/elec/consumer/bean/Record.java @@ -0,0 +1,151 @@ +package com.educg.elec.consumer.bean; + +import com.educg.elec.common.api.Column; +import com.educg.elec.common.api.RowKey; +import com.educg.elec.common.api.TableRef; +import com.educg.elec.common.util.DateFormatUtil; +import com.educg.elec.common.util.TimeFormatUtil; + +/** + * Hbase Record Class + */ +@TableRef("elec:eleclog") +public class Record { + + @RowKey + private String rowkey; + @Column + private String date; + @Column + private String time; + @Column + private String globalActivePower; + @Column + private String globalReactivePower; + @Column + private String voltage; + @Column + private String globalIntensity; + @Column + private String subMetering1; + @Column + private String subMetering2; + @Column + private String subMetering3; + + public Record(){ + + } + + public Record(String value){ + String[] values = value.split("\t"); + String date = DateFormatUtil.format(values[0]); + String time = TimeFormatUtil.format(values[1]); + + this.date = date; + this.time = time; + this.globalActivePower = values[2]; + this.globalReactivePower = values[3]; + this.voltage = values[4]; + this.globalIntensity = values[5]; + this.subMetering1 = values[6]; + this.subMetering2 = values[7]; + this.subMetering3 = values[8]; + } + + public String getRowkey() { + return rowkey; + } + + public void setRowkey(String rowkey) { + this.rowkey = rowkey; + } + + public String getDate() { + return date; + } + + public void setDate(String date) { + this.date = date; + } + + public String getTime() { + return time; + } + + public void setTime(String time) { + this.time = time; + } + + public String getGlobalActivePower() { + return globalActivePower; + } + + public void setGlobalActivePower(String globalActivePower) { + this.globalActivePower = globalActivePower; + } + + public String getGlobalReactivePower() { + return globalReactivePower; + } + + public void setGlobalReactivePower(String globalReactivePower) { + this.globalReactivePower = globalReactivePower; + } + + public String getVoltage() { + return voltage; + } + + public void setVoltage(String voltage) { + this.voltage = voltage; + } + + public String getGlobalIntensity() { + return globalIntensity; + } + + public void setGlobalIntensity(String globalIntensity) { + this.globalIntensity = globalIntensity; + } + + public String getSubMetering1() { + return subMetering1; + } + + public void setSubMetering1(String subMetering1) { + this.subMetering1 = subMetering1; + } + + public String getSubMetering2() { + return subMetering2; + } + + public void setSubMetering2(String subMetering2) { + this.subMetering2 = subMetering2; + } + + public String getSubMetering3() { + return subMetering3; + } + + public void setSubMetering3(String subMetering3) { + this.subMetering3 = subMetering3; + } + + @Override + public String toString() { + return "Record{" + + "rowkey='" + rowkey + '\'' + + ", date='" + date + '\'' + + ", time='" + time + '\'' + + ", globalActivePower='" + globalActivePower + '\'' + + ", globalReactivePower='" + globalReactivePower + '\'' + + ", voltage='" + voltage + '\'' + + ", globalIntensity='" + globalIntensity + '\'' + + ", subMetering1='" + subMetering1 + '\'' + + ", subMetering2='" + subMetering2 + '\'' + + ", subMetering3='" + subMetering3 + '\'' + + '}'; + } +} \ No newline at end of file diff --git a/elec-consumer/src/main/java/com/educg/elec/consumer/dao/HBaseDao.java b/elec-consumer/src/main/java/com/educg/elec/consumer/dao/HBaseDao.java new file mode 100644 index 0000000..c320574 --- /dev/null +++ b/elec-consumer/src/main/java/com/educg/elec/consumer/dao/HBaseDao.java @@ -0,0 +1,25 @@ +package com.educg.elec.consumer.dao; + +import com.educg.elec.common.bean.BaseDao; +import com.educg.elec.common.constant.Names; +import com.educg.elec.common.constant.ValueConstant; +import com.educg.elec.consumer.bean.Record; +public class HBaseDao extends BaseDao { + public void init() throws Exception{ + start(); + createNamespaceNX(Names.NAMESPACE.getValue()); + createTableXX(Names.TABLE.getValue(), ValueConstant.REGION_COUNT,Names.CF_INFO.getValue()); + end(); + } + + public void insertData(Record record) throws Exception{ + String date = record.getDate(); + String time = record.getTime(); + String rkDateTime = date+time; + record.setRowkey(genRegionNumber(date)+"_" + + rkDateTime); + + putData(record); + } + +} \ No newline at end of file diff --git a/elec-consumer/src/main/resources/consumer.properties b/elec-consumer/src/main/resources/consumer.properties new file mode 100644 index 0000000..bf5293f --- /dev/null +++ b/elec-consumer/src/main/resources/consumer.properties @@ -0,0 +1,6 @@ +bootstrap.servers=master:9092 +key.deserializer=org.apache.kafka.common.serialization.StringDeserializer +value.deserializer=org.apache.kafka.common.serialization.StringDeserializer +group.id=cg +enable.auto.commit=true +auto.commit.interval.ms=1000 \ No newline at end of file diff --git a/elec-consumer/src/main/resources/hbase-site.xml b/elec-consumer/src/main/resources/hbase-site.xml new file mode 100755 index 0000000..b7e65e3 --- /dev/null +++ b/elec-consumer/src/main/resources/hbase-site.xml @@ -0,0 +1,54 @@ + + + + + + hbase.rootdir + hdfs://master:9000/hbase-1.1.5/data + + + hbase.cluster.distributed + true + + + hbase.zookeeper.property.dataDir + /opt/module/zookeeper-3.4.10/zkData + + + hbase.zookeeper.quorum + master:2181,slave1:2181,slave2:2181,slave3:2181 + + + hbase.security.authorization + true + + + + hbase.coprocessor.master.classes + org.apache.hadoop.hbase.security.access.AccessController + + + + hbase.coprocessor.region.classes + org.apache.hadoop.hbase.security.token.TokenProvider,org.apache.hadoop.hbase.security.access.AccessController + + diff --git a/elec-consumer/target/classes/com/educg/elec/consumer/Bootstrap.class b/elec-consumer/target/classes/com/educg/elec/consumer/Bootstrap.class new file mode 100644 index 0000000..3623678 Binary files /dev/null and b/elec-consumer/target/classes/com/educg/elec/consumer/Bootstrap.class differ diff --git a/elec-consumer/target/classes/com/educg/elec/consumer/bean/ElecConsumer.class b/elec-consumer/target/classes/com/educg/elec/consumer/bean/ElecConsumer.class new file mode 100644 index 0000000..4388538 Binary files /dev/null and b/elec-consumer/target/classes/com/educg/elec/consumer/bean/ElecConsumer.class differ diff --git a/elec-consumer/target/classes/com/educg/elec/consumer/bean/Record.class b/elec-consumer/target/classes/com/educg/elec/consumer/bean/Record.class new file mode 100644 index 0000000..7c35fd1 Binary files /dev/null and b/elec-consumer/target/classes/com/educg/elec/consumer/bean/Record.class differ diff --git a/elec-consumer/target/classes/com/educg/elec/consumer/dao/HBaseDao.class b/elec-consumer/target/classes/com/educg/elec/consumer/dao/HBaseDao.class new file mode 100644 index 0000000..4b36b66 Binary files /dev/null and b/elec-consumer/target/classes/com/educg/elec/consumer/dao/HBaseDao.class differ diff --git a/elec-consumer/target/classes/consumer.properties b/elec-consumer/target/classes/consumer.properties new file mode 100644 index 0000000..bf5293f --- /dev/null +++ b/elec-consumer/target/classes/consumer.properties @@ -0,0 +1,6 @@ +bootstrap.servers=master:9092 +key.deserializer=org.apache.kafka.common.serialization.StringDeserializer +value.deserializer=org.apache.kafka.common.serialization.StringDeserializer +group.id=cg +enable.auto.commit=true +auto.commit.interval.ms=1000 \ No newline at end of file diff --git a/elec-consumer/target/classes/hbase-site.xml b/elec-consumer/target/classes/hbase-site.xml new file mode 100755 index 0000000..b7e65e3 --- /dev/null +++ b/elec-consumer/target/classes/hbase-site.xml @@ -0,0 +1,54 @@ + + + + + + hbase.rootdir + hdfs://master:9000/hbase-1.1.5/data + + + hbase.cluster.distributed + true + + + hbase.zookeeper.property.dataDir + /opt/module/zookeeper-3.4.10/zkData + + + hbase.zookeeper.quorum + master:2181,slave1:2181,slave2:2181,slave3:2181 + + + hbase.security.authorization + true + + + + hbase.coprocessor.master.classes + org.apache.hadoop.hbase.security.access.AccessController + + + + hbase.coprocessor.region.classes + org.apache.hadoop.hbase.security.token.TokenProvider,org.apache.hadoop.hbase.security.access.AccessController + + diff --git a/elec-producer/pom.xml b/elec-producer/pom.xml new file mode 100644 index 0000000..ff41ed8 --- /dev/null +++ b/elec-producer/pom.xml @@ -0,0 +1,27 @@ + + + + project-elec + com.educg + 1.0-SNAPSHOT + + 4.0.0 + + elec-producer + + + 8 + 8 + + + + + com.educg + elec-common + 1.0-SNAPSHOT + + + + \ No newline at end of file diff --git a/elec-producer/src/main/java/com/educg/elec/producer/Bootstrap.java b/elec-producer/src/main/java/com/educg/elec/producer/Bootstrap.java new file mode 100644 index 0000000..81076dd --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/Bootstrap.java @@ -0,0 +1,31 @@ +package com.educg.elec.producer; + +import com.educg.elec.producer.bean.LocalFileProducer; +import com.educg.elec.producer.bean.Producer; +import com.educg.elec.producer.io.LocalFileDataIn; +import com.educg.elec.producer.io.LocalFileDataOut; + +/** + * Starter + */ +public class Bootstrap { + public static void main(String[] args) throws Exception{ + + if(args.length < 2){ + System.out.println("invalid arguments"); + System.exit(1); + } + + String inPath = args[0]; + String outPath = args[1]; + // create obejct producer + Producer producer = new LocalFileProducer(); + producer.setIn(new LocalFileDataIn(inPath)); + producer.setOut(new LocalFileDataOut(outPath)); + // produce data + producer.produce(); + System.out.println("Ending Producer------------------"); + // close producer + producer.close(); + } +} \ No newline at end of file diff --git a/elec-producer/src/main/java/com/educg/elec/producer/bean/Data.java b/elec-producer/src/main/java/com/educg/elec/producer/bean/Data.java new file mode 100644 index 0000000..2e1d47b --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/bean/Data.java @@ -0,0 +1,19 @@ +package com.educg.elec.producer.bean; + +import com.educg.elec.common.bean.Val; + +public abstract class Data implements Val { + + public String content; + + + @Override + public void setValue(Object val) { + content = (String) val; + } + + @Override + public String getValue() { + return content; + } +} \ No newline at end of file diff --git a/elec-producer/src/main/java/com/educg/elec/producer/bean/DataIn.java b/elec-producer/src/main/java/com/educg/elec/producer/bean/DataIn.java new file mode 100644 index 0000000..11f5eb9 --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/bean/DataIn.java @@ -0,0 +1,16 @@ +package com.educg.elec.producer.bean; + +import java.io.Closeable; +import java.io.IOException; +import java.util.List; + +public interface DataIn extends Closeable { + + public Object read() throws IOException; + + public List read(Class clazz) throws IOException; + + public void setPath(String path); + +} + diff --git a/elec-producer/src/main/java/com/educg/elec/producer/bean/DataOut.java b/elec-producer/src/main/java/com/educg/elec/producer/bean/DataOut.java new file mode 100644 index 0000000..069145c --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/bean/DataOut.java @@ -0,0 +1,12 @@ +package com.educg.elec.producer.bean; + +import java.io.Closeable; + +public interface DataOut extends Closeable { + + public void setPath(String path); + + public void write( Object data ) throws Exception; + + public void write( String data ) throws Exception; +} diff --git a/elec-producer/src/main/java/com/educg/elec/producer/bean/Line.java b/elec-producer/src/main/java/com/educg/elec/producer/bean/Line.java new file mode 100644 index 0000000..215fe20 --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/bean/Line.java @@ -0,0 +1,109 @@ +package com.educg.elec.producer.bean; + + +public class Line extends Data { + private String date; + private String time; + private String globalActivePower; + private String globalReactivePower; + private String voltage; + private String globalIntensity; + private String subMetering1; + private String subMetering2; + private String subMetering3; + + public String getDate() { + return date; + } + + public void setDate(String date) { + this.date = date; + } + + public String getTime() { + return time; + } + + public void setTime(String time) { + this.time = time; + } + + public String getGlobalActivePower() { + return globalActivePower; + } + + public void setGlobalActivePower(String globalActivePower) { + this.globalActivePower = globalActivePower; + } + + public String getGlobalReactivePower() { + return globalReactivePower; + } + + public void setGlobalReactivePower(String globalReactivePower) { + this.globalReactivePower = globalReactivePower; + } + + public String getVoltage() { + return voltage; + } + + public void setVoltage(String voltage) { + this.voltage = voltage; + } + + public String getGlobalIntensity() { + return globalIntensity; + } + + public void setGlobalIntensity(String globalIntensity) { + this.globalIntensity = globalIntensity; + } + + public String getSubMetering1() { + return subMetering1; + } + + public void setSubMetering1(String subMetering1) { + this.subMetering1 = subMetering1; + } + + public String getSubMetering2() { + return subMetering2; + } + + public void setSubMetering2(String subMetering2) { + this.subMetering2 = subMetering2; + } + + public String getSubMetering3() { + return subMetering3; + } + + public void setSubMetering3(String subMetering3) { + this.subMetering3 = subMetering3; + } + + @Override + public void setValue(Object val) { + content = (String) val; + String[] values = content.split(";"); + setDate(values[0]); + setTime(values[1]); + setGlobalActivePower(values[2]); + setGlobalReactivePower(values[3]); + setVoltage(values[4]); + setGlobalIntensity(values[5]); + setSubMetering1(values[6]); + setSubMetering2(values[7]); + setSubMetering3(values[8]); + } + + @Override + public String toString() { + return getDate() + "\t" + getTime() + "\t" +getGlobalActivePower() + "\t" + + getGlobalReactivePower() + "\t" + getVoltage() + "\t" + getGlobalIntensity() + + "\t" + getSubMetering1() + "\t" + getSubMetering2() + "\t" + getSubMetering3(); + } + +} \ No newline at end of file diff --git a/elec-producer/src/main/java/com/educg/elec/producer/bean/LocalFileProducer.java b/elec-producer/src/main/java/com/educg/elec/producer/bean/LocalFileProducer.java new file mode 100644 index 0000000..318775b --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/bean/LocalFileProducer.java @@ -0,0 +1,60 @@ +package com.educg.elec.producer.bean; + +import java.io.IOException; +import java.util.List; + +/** + * Local File Producer + */ +public class LocalFileProducer implements Producer { + + private DataIn in; + private DataOut out; + + @Override + public void setIn(DataIn in) { + this.in = in; + } + + @Override + public void setOut(DataOut out) { + this.out = out; + } + + /** + * produce data + */ + @Override + public void produce() { + try{ + List lines = in.read(Line.class); + int size = lines.size() - 1; + int index = 0; + while(index<=size){ + Line curLine = lines.get(index); + out.write(curLine); + Thread.sleep(100); + index++; + } + } + catch (Exception e){ + e.printStackTrace(); + } + + } + + /** + * close Producer + * @throws IOException + */ + @Override + public void close() throws IOException { + if(in != null){ + in.close(); + } + if (out != null) { + out.close(); + } + + } +} \ No newline at end of file diff --git a/elec-producer/src/main/java/com/educg/elec/producer/bean/Producer.java b/elec-producer/src/main/java/com/educg/elec/producer/bean/Producer.java new file mode 100644 index 0000000..ee24e2c --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/bean/Producer.java @@ -0,0 +1,19 @@ +package com.educg.elec.producer.bean; + +import java.io.Closeable; + +/** + * producer interface + */ +public interface Producer extends Closeable { + + public void setIn(DataIn in); + public void setOut(DataOut out); + + /** + * produce data + */ + public void produce(); + + +} \ No newline at end of file diff --git a/elec-producer/src/main/java/com/educg/elec/producer/io/LocalFileDataIn.java b/elec-producer/src/main/java/com/educg/elec/producer/io/LocalFileDataIn.java new file mode 100644 index 0000000..00f247d --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/io/LocalFileDataIn.java @@ -0,0 +1,68 @@ +package com.educg.elec.producer.io; + +import com.educg.elec.producer.bean.Data; +import com.educg.elec.producer.bean.DataIn; + +import java.io.*; +import java.util.ArrayList; +import java.util.List; + +/** + * Local File DataIn Obejct + */ +public class LocalFileDataIn implements DataIn { + + private BufferedReader reader = null; + + public LocalFileDataIn( String path ){ + setPath(path); + } + + @Override + public Object read() throws IOException { + return null; + } + + /** + * read data, return collection + * @param clazz + * @param + * @return + * @throws IOException + */ + @Override + public List read(Class clazz) throws IOException { + List ts = new ArrayList(); + reader.readLine(); + try{ + String line = null; + while( (line = reader.readLine()) != null){ + T t = clazz.newInstance(); + t.setValue(line); + ts.add(t); + } + } + catch (Exception e){ + e.printStackTrace(); + } + return ts; + } + + @Override + public void setPath(String path) { + try { + reader = new BufferedReader(new InputStreamReader(new FileInputStream(path), "UTF-8")); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } catch (FileNotFoundException e) { + e.printStackTrace(); + } + } + + @Override + public void close() throws IOException { + if(reader != null) { + reader.close(); + } + } +} diff --git a/elec-producer/src/main/java/com/educg/elec/producer/io/LocalFileDataOut.java b/elec-producer/src/main/java/com/educg/elec/producer/io/LocalFileDataOut.java new file mode 100644 index 0000000..bd3127f --- /dev/null +++ b/elec-producer/src/main/java/com/educg/elec/producer/io/LocalFileDataOut.java @@ -0,0 +1,52 @@ +package com.educg.elec.producer.io; + +import com.educg.elec.producer.bean.DataOut; + +import java.io.*; + +/** + * Local File DataOut Object; + */ +public class LocalFileDataOut implements DataOut { + + private PrintWriter writer = null; + + public LocalFileDataOut( String path ){ + setPath(path); + } + + @Override + public void setPath(String path) { + try { + writer = new PrintWriter(new OutputStreamWriter(new FileOutputStream(path, true), "UTF-8")); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } catch (FileNotFoundException e) { + e.printStackTrace(); + } + } + + @Override + public void write(Object data) throws Exception { + this.write(data.toString()); + } + + /** + * actual write + * @param data + * @throws Exception + */ + @Override + public void write(String data) throws Exception { + System.out.println(data); + writer.println(data); + writer.flush(); + } + + @Override + public void close() throws IOException { + if (writer != null) { + writer.close(); + } + } +} \ No newline at end of file diff --git a/elec-producer/src/main/resources/META-INF/MANIFEST.MF b/elec-producer/src/main/resources/META-INF/MANIFEST.MF new file mode 100644 index 0000000..c37fac8 --- /dev/null +++ b/elec-producer/src/main/resources/META-INF/MANIFEST.MF @@ -0,0 +1,38 @@ +Manifest-Version: 1.0 +Main-Class: com.educg.elec.producer.Bootstrap +Class-Path: commons-net-3.1.jar jaxb-impl-2.2.3-1.jar hadoop-mapreduce-c + lient-jobclient-2.5.1.jar jersey-guice-1.9.jar commons-collections-3.2. + 2.jar jersey-json-1.9.jar hamcrest-core-1.3.jar httpcore-4.1.2.jar jsp- + api-2.1-6.1.14.jar tools.jar hadoop-client-2.5.1.jar commons-daemon-1.0 + .13.jar xmlenc-0.52.jar metrics-core-2.2.0.jar apacheds-kerberos-codec- + 2.0.0-M15.jar junit-4.12.jar hbase-protocol-1.3.1.jar hadoop-auth-2.5.1 + .jar aopalliance-1.0.jar jaxb-api-2.2.2.jar hbase-hadoop-compat-1.3.1.j + ar commons-httpclient-3.1.jar jsch-0.1.42.jar jersey-server-1.9.jar jet + ty-6.1.26.jar commons-lang-2.6.jar commons-el-1.0.jar jackson-xc-1.8.3. + jar jettison-1.1.jar hadoop-mapreduce-client-app-2.5.1.jar jersey-core- + 1.9.jar htrace-core-3.1.0-incubating.jar guice-servlet-3.0.jar apacheds + -i18n-2.0.0-M15.jar zookeeper-3.4.6.jar jasper-runtime-5.5.23.jar xz-1. + 0.jar jetty-util-6.1.26.jar hadoop-annotations-2.5.1.jar hbase-common-1 + .3.1-tests.jar slf4j-api-1.7.2.jar javax.inject-1.jar hbase-common-1.3. + 1.jar jackson-core-asl-1.9.13.jar api-util-1.0.0-M20.jar commons-codec- + 1.9.jar hadoop-mapreduce-client-common-2.5.1.jar hadoop-common-2.5.1.ja + r findbugs-annotations-1.3.9-1.jar guice-3.0.jar jackson-jaxrs-1.9.13.j + ar hadoop-yarn-common-2.5.1.jar disruptor-3.3.0.jar commons-io-2.4.jar + commons-math3-3.1.1.jar guava-12.0.1.jar commons-math-2.2.jar jackson-m + apper-asl-1.9.13.jar hbase-annotations-1.3.1.jar commons-compress-1.4.1 + .jar asm-3.1.jar hadoop-mapreduce-client-core-2.5.1.jar commons-configu + ration-1.6.jar hbase-client-1.3.1.jar avro-1.7.4.jar java-xmlbuilder-0. + 4.jar jamon-runtime-2.4.1.jar paranamer-2.3.jar servlet-api-2.5-6.1.14. + jar commons-beanutils-core-1.8.0.jar log4j-1.2.17.jar commons-beanutils + -1.7.0.jar api-asn1-api-1.0.0-M20.jar jcodings-1.0.8.jar hbase-server-1 + .3.1.jar commons-digester-1.8.jar jsp-2.1-6.1.14.jar protobuf-java-2.5. + 0.jar commons-cli-1.2.jar slf4j-log4j12-1.6.1.jar jasper-compiler-5.5.2 + 3.jar jets3t-0.9.0.jar hadoop-yarn-api-2.5.1.jar hadoop-yarn-server-com + mon-2.5.1.jar jersey-client-1.9.jar hbase-prefix-tree-1.3.1.jar httpcli + ent-4.2.5.jar hbase-procedure-1.3.1.jar netty-all-4.0.23.Final.jar jett + y-sslengine-6.1.26.jar joni-2.1.2.jar servlet-api-2.5.jar activation-1. + 1.jar leveldbjni-all-1.8.jar stax-api-1.0-2.jar hbase-hadoop2-compat-1. + 3.1.jar commons-logging-1.2.jar hadoop-mapreduce-client-shuffle-2.5.1.j + ar hadoop-yarn-client-2.5.1.jar snappy-java-1.0.4.1.jar hadoop-hdfs-2.5 + .1.jar + diff --git a/elec-producer/target/classes/META-INF/MANIFEST.MF b/elec-producer/target/classes/META-INF/MANIFEST.MF new file mode 100644 index 0000000..c37fac8 --- /dev/null +++ b/elec-producer/target/classes/META-INF/MANIFEST.MF @@ -0,0 +1,38 @@ +Manifest-Version: 1.0 +Main-Class: com.educg.elec.producer.Bootstrap +Class-Path: commons-net-3.1.jar jaxb-impl-2.2.3-1.jar hadoop-mapreduce-c + lient-jobclient-2.5.1.jar jersey-guice-1.9.jar commons-collections-3.2. + 2.jar jersey-json-1.9.jar hamcrest-core-1.3.jar httpcore-4.1.2.jar jsp- + api-2.1-6.1.14.jar tools.jar hadoop-client-2.5.1.jar commons-daemon-1.0 + .13.jar xmlenc-0.52.jar metrics-core-2.2.0.jar apacheds-kerberos-codec- + 2.0.0-M15.jar junit-4.12.jar hbase-protocol-1.3.1.jar hadoop-auth-2.5.1 + .jar aopalliance-1.0.jar jaxb-api-2.2.2.jar hbase-hadoop-compat-1.3.1.j + ar commons-httpclient-3.1.jar jsch-0.1.42.jar jersey-server-1.9.jar jet + ty-6.1.26.jar commons-lang-2.6.jar commons-el-1.0.jar jackson-xc-1.8.3. + jar jettison-1.1.jar hadoop-mapreduce-client-app-2.5.1.jar jersey-core- + 1.9.jar htrace-core-3.1.0-incubating.jar guice-servlet-3.0.jar apacheds + -i18n-2.0.0-M15.jar zookeeper-3.4.6.jar jasper-runtime-5.5.23.jar xz-1. + 0.jar jetty-util-6.1.26.jar hadoop-annotations-2.5.1.jar hbase-common-1 + .3.1-tests.jar slf4j-api-1.7.2.jar javax.inject-1.jar hbase-common-1.3. + 1.jar jackson-core-asl-1.9.13.jar api-util-1.0.0-M20.jar commons-codec- + 1.9.jar hadoop-mapreduce-client-common-2.5.1.jar hadoop-common-2.5.1.ja + r findbugs-annotations-1.3.9-1.jar guice-3.0.jar jackson-jaxrs-1.9.13.j + ar hadoop-yarn-common-2.5.1.jar disruptor-3.3.0.jar commons-io-2.4.jar + commons-math3-3.1.1.jar guava-12.0.1.jar commons-math-2.2.jar jackson-m + apper-asl-1.9.13.jar hbase-annotations-1.3.1.jar commons-compress-1.4.1 + .jar asm-3.1.jar hadoop-mapreduce-client-core-2.5.1.jar commons-configu + ration-1.6.jar hbase-client-1.3.1.jar avro-1.7.4.jar java-xmlbuilder-0. + 4.jar jamon-runtime-2.4.1.jar paranamer-2.3.jar servlet-api-2.5-6.1.14. + jar commons-beanutils-core-1.8.0.jar log4j-1.2.17.jar commons-beanutils + -1.7.0.jar api-asn1-api-1.0.0-M20.jar jcodings-1.0.8.jar hbase-server-1 + .3.1.jar commons-digester-1.8.jar jsp-2.1-6.1.14.jar protobuf-java-2.5. + 0.jar commons-cli-1.2.jar slf4j-log4j12-1.6.1.jar jasper-compiler-5.5.2 + 3.jar jets3t-0.9.0.jar hadoop-yarn-api-2.5.1.jar hadoop-yarn-server-com + mon-2.5.1.jar jersey-client-1.9.jar hbase-prefix-tree-1.3.1.jar httpcli + ent-4.2.5.jar hbase-procedure-1.3.1.jar netty-all-4.0.23.Final.jar jett + y-sslengine-6.1.26.jar joni-2.1.2.jar servlet-api-2.5.jar activation-1. + 1.jar leveldbjni-all-1.8.jar stax-api-1.0-2.jar hbase-hadoop2-compat-1. + 3.1.jar commons-logging-1.2.jar hadoop-mapreduce-client-shuffle-2.5.1.j + ar hadoop-yarn-client-2.5.1.jar snappy-java-1.0.4.1.jar hadoop-hdfs-2.5 + .1.jar + diff --git a/elec-producer/target/classes/com/educg/elec/producer/Bootstrap.class b/elec-producer/target/classes/com/educg/elec/producer/Bootstrap.class new file mode 100644 index 0000000..0f77a71 Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/Bootstrap.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/bean/Data.class b/elec-producer/target/classes/com/educg/elec/producer/bean/Data.class new file mode 100644 index 0000000..0bb80a7 Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/bean/Data.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/bean/DataIn.class b/elec-producer/target/classes/com/educg/elec/producer/bean/DataIn.class new file mode 100644 index 0000000..ec6d9aa Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/bean/DataIn.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/bean/DataOut.class b/elec-producer/target/classes/com/educg/elec/producer/bean/DataOut.class new file mode 100644 index 0000000..fb2ca99 Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/bean/DataOut.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/bean/Line.class b/elec-producer/target/classes/com/educg/elec/producer/bean/Line.class new file mode 100644 index 0000000..005a317 Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/bean/Line.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/bean/LocalFileProducer.class b/elec-producer/target/classes/com/educg/elec/producer/bean/LocalFileProducer.class new file mode 100644 index 0000000..8dd16b3 Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/bean/LocalFileProducer.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/bean/Producer.class b/elec-producer/target/classes/com/educg/elec/producer/bean/Producer.class new file mode 100644 index 0000000..b51ccce Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/bean/Producer.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/io/LocalFileDataIn.class b/elec-producer/target/classes/com/educg/elec/producer/io/LocalFileDataIn.class new file mode 100644 index 0000000..5e3fee6 Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/io/LocalFileDataIn.class differ diff --git a/elec-producer/target/classes/com/educg/elec/producer/io/LocalFileDataOut.class b/elec-producer/target/classes/com/educg/elec/producer/io/LocalFileDataOut.class new file mode 100644 index 0000000..4507df3 Binary files /dev/null and b/elec-producer/target/classes/com/educg/elec/producer/io/LocalFileDataOut.class differ diff --git a/flume-2-kafka.conf b/flume-2-kafka.conf new file mode 100644 index 0000000..dff83a2 --- /dev/null +++ b/flume-2-kafka.conf @@ -0,0 +1,21 @@ +a1.sources = r1 +a1.channels = c1 +a1.sinks = k1 + +a1.sources.r1.type = exec +a1.sources.r1.command = tail -F -c +0 /support/output.txt + +a1.channels.c1.type = memory +a1.channels.c1.capacity = 1000 +a1.channels.c1.transactionCapacity = 100 +a1.channels.c1.byteCapacityBufferPercentage = 20 +a1.channels.c1.byteCapacity = 800000 + +a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink +a1.sinks.k1.kafka.topic = eleclog +a1.sinks.k1.kafka.bootstrap.servers = master:9092,slave1:9092,slave2:9092,slave3:9092 +a1.sinks.k1.kafka.flumeBatchSize = 20 +a1.sinks.k1.kafka.producer.acks = 1 + +a1.sources.r1.channels = c1 +a1.sinks.k1.channel = c1 \ No newline at end of file diff --git a/out/artifacts/elec_producer_jar/activation-1.1.jar b/out/artifacts/elec_producer_jar/activation-1.1.jar new file mode 100644 index 0000000..53f82a1 Binary files /dev/null and b/out/artifacts/elec_producer_jar/activation-1.1.jar differ diff --git a/out/artifacts/elec_producer_jar/aopalliance-1.0.jar b/out/artifacts/elec_producer_jar/aopalliance-1.0.jar new file mode 100644 index 0000000..578b1a0 Binary files /dev/null and b/out/artifacts/elec_producer_jar/aopalliance-1.0.jar differ diff --git a/out/artifacts/elec_producer_jar/apacheds-i18n-2.0.0-M15.jar b/out/artifacts/elec_producer_jar/apacheds-i18n-2.0.0-M15.jar new file mode 100644 index 0000000..11dccb3 Binary files /dev/null and b/out/artifacts/elec_producer_jar/apacheds-i18n-2.0.0-M15.jar differ diff --git a/out/artifacts/elec_producer_jar/apacheds-kerberos-codec-2.0.0-M15.jar b/out/artifacts/elec_producer_jar/apacheds-kerberos-codec-2.0.0-M15.jar new file mode 100644 index 0000000..82e564e Binary files /dev/null and b/out/artifacts/elec_producer_jar/apacheds-kerberos-codec-2.0.0-M15.jar differ diff --git a/out/artifacts/elec_producer_jar/api-asn1-api-1.0.0-M20.jar b/out/artifacts/elec_producer_jar/api-asn1-api-1.0.0-M20.jar new file mode 100644 index 0000000..68dee3a Binary files /dev/null and b/out/artifacts/elec_producer_jar/api-asn1-api-1.0.0-M20.jar differ diff --git a/out/artifacts/elec_producer_jar/api-util-1.0.0-M20.jar b/out/artifacts/elec_producer_jar/api-util-1.0.0-M20.jar new file mode 100644 index 0000000..ff9780e Binary files /dev/null and b/out/artifacts/elec_producer_jar/api-util-1.0.0-M20.jar differ diff --git a/out/artifacts/elec_producer_jar/asm-3.1.jar b/out/artifacts/elec_producer_jar/asm-3.1.jar new file mode 100644 index 0000000..8217cae Binary files /dev/null and b/out/artifacts/elec_producer_jar/asm-3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/avro-1.7.4.jar b/out/artifacts/elec_producer_jar/avro-1.7.4.jar new file mode 100644 index 0000000..69dd87d Binary files /dev/null and b/out/artifacts/elec_producer_jar/avro-1.7.4.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-beanutils-1.7.0.jar b/out/artifacts/elec_producer_jar/commons-beanutils-1.7.0.jar new file mode 100644 index 0000000..b1b89c9 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-beanutils-1.7.0.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-beanutils-core-1.8.0.jar b/out/artifacts/elec_producer_jar/commons-beanutils-core-1.8.0.jar new file mode 100644 index 0000000..87c15f4 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-beanutils-core-1.8.0.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-cli-1.2.jar b/out/artifacts/elec_producer_jar/commons-cli-1.2.jar new file mode 100644 index 0000000..ce4b9ff Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-cli-1.2.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-codec-1.9.jar b/out/artifacts/elec_producer_jar/commons-codec-1.9.jar new file mode 100644 index 0000000..ef35f1c Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-codec-1.9.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-collections-3.2.2.jar b/out/artifacts/elec_producer_jar/commons-collections-3.2.2.jar new file mode 100644 index 0000000..fa5df82 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-collections-3.2.2.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-compress-1.4.1.jar b/out/artifacts/elec_producer_jar/commons-compress-1.4.1.jar new file mode 100644 index 0000000..b58761e Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-compress-1.4.1.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-configuration-1.6.jar b/out/artifacts/elec_producer_jar/commons-configuration-1.6.jar new file mode 100644 index 0000000..2d4689a Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-configuration-1.6.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-daemon-1.0.13.jar b/out/artifacts/elec_producer_jar/commons-daemon-1.0.13.jar new file mode 100644 index 0000000..ac77321 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-daemon-1.0.13.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-digester-1.8.jar b/out/artifacts/elec_producer_jar/commons-digester-1.8.jar new file mode 100644 index 0000000..1110f0a Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-digester-1.8.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-el-1.0.jar b/out/artifacts/elec_producer_jar/commons-el-1.0.jar new file mode 100644 index 0000000..608ed79 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-el-1.0.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-httpclient-3.1.jar b/out/artifacts/elec_producer_jar/commons-httpclient-3.1.jar new file mode 100644 index 0000000..7c59774 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-httpclient-3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-io-2.4.jar b/out/artifacts/elec_producer_jar/commons-io-2.4.jar new file mode 100644 index 0000000..90035a4 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-io-2.4.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-lang-2.6.jar b/out/artifacts/elec_producer_jar/commons-lang-2.6.jar new file mode 100644 index 0000000..98467d3 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-lang-2.6.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-logging-1.2.jar b/out/artifacts/elec_producer_jar/commons-logging-1.2.jar new file mode 100644 index 0000000..93a3b9f Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-logging-1.2.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-math-2.2.jar b/out/artifacts/elec_producer_jar/commons-math-2.2.jar new file mode 100644 index 0000000..b29a39c Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-math-2.2.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-math3-3.1.1.jar b/out/artifacts/elec_producer_jar/commons-math3-3.1.1.jar new file mode 100644 index 0000000..43b5215 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-math3-3.1.1.jar differ diff --git a/out/artifacts/elec_producer_jar/commons-net-3.1.jar b/out/artifacts/elec_producer_jar/commons-net-3.1.jar new file mode 100644 index 0000000..b75f1a5 Binary files /dev/null and b/out/artifacts/elec_producer_jar/commons-net-3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/disruptor-3.3.0.jar b/out/artifacts/elec_producer_jar/disruptor-3.3.0.jar new file mode 100644 index 0000000..6f88ada Binary files /dev/null and b/out/artifacts/elec_producer_jar/disruptor-3.3.0.jar differ diff --git a/out/artifacts/elec_producer_jar/elec-producer.jar b/out/artifacts/elec_producer_jar/elec-producer.jar new file mode 100644 index 0000000..e067a40 Binary files /dev/null and b/out/artifacts/elec_producer_jar/elec-producer.jar differ diff --git a/out/artifacts/elec_producer_jar/findbugs-annotations-1.3.9-1.jar b/out/artifacts/elec_producer_jar/findbugs-annotations-1.3.9-1.jar new file mode 100644 index 0000000..f8551a2 Binary files /dev/null and b/out/artifacts/elec_producer_jar/findbugs-annotations-1.3.9-1.jar differ diff --git a/out/artifacts/elec_producer_jar/guava-12.0.1.jar b/out/artifacts/elec_producer_jar/guava-12.0.1.jar new file mode 100644 index 0000000..b185ee6 Binary files /dev/null and b/out/artifacts/elec_producer_jar/guava-12.0.1.jar differ diff --git a/out/artifacts/elec_producer_jar/guice-3.0.jar b/out/artifacts/elec_producer_jar/guice-3.0.jar new file mode 100644 index 0000000..f313e2b Binary files /dev/null and b/out/artifacts/elec_producer_jar/guice-3.0.jar differ diff --git a/out/artifacts/elec_producer_jar/guice-servlet-3.0.jar b/out/artifacts/elec_producer_jar/guice-servlet-3.0.jar new file mode 100644 index 0000000..bdc6614 Binary files /dev/null and b/out/artifacts/elec_producer_jar/guice-servlet-3.0.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-annotations-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-annotations-2.5.1.jar new file mode 100644 index 0000000..008eae1 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-annotations-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-auth-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-auth-2.5.1.jar new file mode 100644 index 0000000..21b1071 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-auth-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-client-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-client-2.5.1.jar new file mode 100644 index 0000000..27655d7 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-client-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-common-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-common-2.5.1.jar new file mode 100644 index 0000000..be518bd Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-common-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-hdfs-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-hdfs-2.5.1.jar new file mode 100644 index 0000000..bdb430e Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-hdfs-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-app-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-app-2.5.1.jar new file mode 100644 index 0000000..4f1b83c Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-app-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-common-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-common-2.5.1.jar new file mode 100644 index 0000000..f5623d5 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-common-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-core-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-core-2.5.1.jar new file mode 100644 index 0000000..216c75b Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-core-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-jobclient-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-jobclient-2.5.1.jar new file mode 100644 index 0000000..7c19153 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-jobclient-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-shuffle-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-shuffle-2.5.1.jar new file mode 100644 index 0000000..8d871f9 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-mapreduce-client-shuffle-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-yarn-api-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-yarn-api-2.5.1.jar new file mode 100644 index 0000000..ff5b75f Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-yarn-api-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-yarn-client-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-yarn-client-2.5.1.jar new file mode 100644 index 0000000..fd920f8 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-yarn-client-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-yarn-common-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-yarn-common-2.5.1.jar new file mode 100644 index 0000000..e94415c Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-yarn-common-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hadoop-yarn-server-common-2.5.1.jar b/out/artifacts/elec_producer_jar/hadoop-yarn-server-common-2.5.1.jar new file mode 100644 index 0000000..cd7825d Binary files /dev/null and b/out/artifacts/elec_producer_jar/hadoop-yarn-server-common-2.5.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hamcrest-core-1.3.jar b/out/artifacts/elec_producer_jar/hamcrest-core-1.3.jar new file mode 100644 index 0000000..9d5fe16 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hamcrest-core-1.3.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-annotations-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-annotations-1.3.1.jar new file mode 100644 index 0000000..350ad6b Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-annotations-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-client-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-client-1.3.1.jar new file mode 100644 index 0000000..250f7ee Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-client-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-common-1.3.1-tests.jar b/out/artifacts/elec_producer_jar/hbase-common-1.3.1-tests.jar new file mode 100644 index 0000000..12d2669 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-common-1.3.1-tests.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-common-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-common-1.3.1.jar new file mode 100644 index 0000000..27995a0 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-common-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-hadoop-compat-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-hadoop-compat-1.3.1.jar new file mode 100644 index 0000000..1fac61b Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-hadoop-compat-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-hadoop2-compat-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-hadoop2-compat-1.3.1.jar new file mode 100644 index 0000000..5ca63dd Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-hadoop2-compat-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-prefix-tree-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-prefix-tree-1.3.1.jar new file mode 100644 index 0000000..d3c1d21 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-prefix-tree-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-procedure-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-procedure-1.3.1.jar new file mode 100644 index 0000000..e5a0d09 Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-procedure-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-protocol-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-protocol-1.3.1.jar new file mode 100644 index 0000000..fe53b2f Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-protocol-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/hbase-server-1.3.1.jar b/out/artifacts/elec_producer_jar/hbase-server-1.3.1.jar new file mode 100644 index 0000000..8118d3a Binary files /dev/null and b/out/artifacts/elec_producer_jar/hbase-server-1.3.1.jar differ diff --git a/out/artifacts/elec_producer_jar/htrace-core-3.1.0-incubating.jar b/out/artifacts/elec_producer_jar/htrace-core-3.1.0-incubating.jar new file mode 100644 index 0000000..6f03925 Binary files /dev/null and b/out/artifacts/elec_producer_jar/htrace-core-3.1.0-incubating.jar differ diff --git a/out/artifacts/elec_producer_jar/httpclient-4.2.5.jar b/out/artifacts/elec_producer_jar/httpclient-4.2.5.jar new file mode 100644 index 0000000..84fece4 Binary files /dev/null and b/out/artifacts/elec_producer_jar/httpclient-4.2.5.jar differ diff --git a/out/artifacts/elec_producer_jar/httpcore-4.1.2.jar b/out/artifacts/elec_producer_jar/httpcore-4.1.2.jar new file mode 100644 index 0000000..66ae90b Binary files /dev/null and b/out/artifacts/elec_producer_jar/httpcore-4.1.2.jar differ diff --git a/out/artifacts/elec_producer_jar/jackson-core-asl-1.9.13.jar b/out/artifacts/elec_producer_jar/jackson-core-asl-1.9.13.jar new file mode 100644 index 0000000..bb4fe1d Binary files /dev/null and b/out/artifacts/elec_producer_jar/jackson-core-asl-1.9.13.jar differ diff --git a/out/artifacts/elec_producer_jar/jackson-jaxrs-1.9.13.jar b/out/artifacts/elec_producer_jar/jackson-jaxrs-1.9.13.jar new file mode 100644 index 0000000..b85f45c Binary files /dev/null and b/out/artifacts/elec_producer_jar/jackson-jaxrs-1.9.13.jar differ diff --git a/out/artifacts/elec_producer_jar/jackson-mapper-asl-1.9.13.jar b/out/artifacts/elec_producer_jar/jackson-mapper-asl-1.9.13.jar new file mode 100644 index 0000000..0f2073f Binary files /dev/null and b/out/artifacts/elec_producer_jar/jackson-mapper-asl-1.9.13.jar differ diff --git a/out/artifacts/elec_producer_jar/jackson-xc-1.8.3.jar b/out/artifacts/elec_producer_jar/jackson-xc-1.8.3.jar new file mode 100644 index 0000000..9e168ec Binary files /dev/null and b/out/artifacts/elec_producer_jar/jackson-xc-1.8.3.jar differ diff --git a/out/artifacts/elec_producer_jar/jamon-runtime-2.4.1.jar b/out/artifacts/elec_producer_jar/jamon-runtime-2.4.1.jar new file mode 100644 index 0000000..219f88d Binary files /dev/null and b/out/artifacts/elec_producer_jar/jamon-runtime-2.4.1.jar differ diff --git a/out/artifacts/elec_producer_jar/jasper-compiler-5.5.23.jar b/out/artifacts/elec_producer_jar/jasper-compiler-5.5.23.jar new file mode 100644 index 0000000..170efa0 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jasper-compiler-5.5.23.jar differ diff --git a/out/artifacts/elec_producer_jar/jasper-runtime-5.5.23.jar b/out/artifacts/elec_producer_jar/jasper-runtime-5.5.23.jar new file mode 100644 index 0000000..a3208c9 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jasper-runtime-5.5.23.jar differ diff --git a/out/artifacts/elec_producer_jar/java-xmlbuilder-0.4.jar b/out/artifacts/elec_producer_jar/java-xmlbuilder-0.4.jar new file mode 100644 index 0000000..e5acf92 Binary files /dev/null and b/out/artifacts/elec_producer_jar/java-xmlbuilder-0.4.jar differ diff --git a/out/artifacts/elec_producer_jar/javax.inject-1.jar b/out/artifacts/elec_producer_jar/javax.inject-1.jar new file mode 100644 index 0000000..b2a9d0b Binary files /dev/null and b/out/artifacts/elec_producer_jar/javax.inject-1.jar differ diff --git a/out/artifacts/elec_producer_jar/jaxb-api-2.2.2.jar b/out/artifacts/elec_producer_jar/jaxb-api-2.2.2.jar new file mode 100644 index 0000000..31e5fa0 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jaxb-api-2.2.2.jar differ diff --git a/out/artifacts/elec_producer_jar/jaxb-impl-2.2.3-1.jar b/out/artifacts/elec_producer_jar/jaxb-impl-2.2.3-1.jar new file mode 100644 index 0000000..eeaf660 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jaxb-impl-2.2.3-1.jar differ diff --git a/out/artifacts/elec_producer_jar/jcodings-1.0.8.jar b/out/artifacts/elec_producer_jar/jcodings-1.0.8.jar new file mode 100644 index 0000000..1c377c6 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jcodings-1.0.8.jar differ diff --git a/out/artifacts/elec_producer_jar/jersey-client-1.9.jar b/out/artifacts/elec_producer_jar/jersey-client-1.9.jar new file mode 100644 index 0000000..d811f13 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jersey-client-1.9.jar differ diff --git a/out/artifacts/elec_producer_jar/jersey-core-1.9.jar b/out/artifacts/elec_producer_jar/jersey-core-1.9.jar new file mode 100644 index 0000000..548dd88 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jersey-core-1.9.jar differ diff --git a/out/artifacts/elec_producer_jar/jersey-guice-1.9.jar b/out/artifacts/elec_producer_jar/jersey-guice-1.9.jar new file mode 100644 index 0000000..cb46c94 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jersey-guice-1.9.jar differ diff --git a/out/artifacts/elec_producer_jar/jersey-json-1.9.jar b/out/artifacts/elec_producer_jar/jersey-json-1.9.jar new file mode 100644 index 0000000..b1a4ce5 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jersey-json-1.9.jar differ diff --git a/out/artifacts/elec_producer_jar/jersey-server-1.9.jar b/out/artifacts/elec_producer_jar/jersey-server-1.9.jar new file mode 100644 index 0000000..ae0117c Binary files /dev/null and b/out/artifacts/elec_producer_jar/jersey-server-1.9.jar differ diff --git a/out/artifacts/elec_producer_jar/jets3t-0.9.0.jar b/out/artifacts/elec_producer_jar/jets3t-0.9.0.jar new file mode 100644 index 0000000..6870900 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jets3t-0.9.0.jar differ diff --git a/out/artifacts/elec_producer_jar/jettison-1.1.jar b/out/artifacts/elec_producer_jar/jettison-1.1.jar new file mode 100644 index 0000000..e4e9c8c Binary files /dev/null and b/out/artifacts/elec_producer_jar/jettison-1.1.jar differ diff --git a/out/artifacts/elec_producer_jar/jetty-6.1.26.jar b/out/artifacts/elec_producer_jar/jetty-6.1.26.jar new file mode 100644 index 0000000..2cbe07a Binary files /dev/null and b/out/artifacts/elec_producer_jar/jetty-6.1.26.jar differ diff --git a/out/artifacts/elec_producer_jar/jetty-sslengine-6.1.26.jar b/out/artifacts/elec_producer_jar/jetty-sslengine-6.1.26.jar new file mode 100644 index 0000000..051efb5 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jetty-sslengine-6.1.26.jar differ diff --git a/out/artifacts/elec_producer_jar/jetty-util-6.1.26.jar b/out/artifacts/elec_producer_jar/jetty-util-6.1.26.jar new file mode 100644 index 0000000..cd23752 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jetty-util-6.1.26.jar differ diff --git a/out/artifacts/elec_producer_jar/joni-2.1.2.jar b/out/artifacts/elec_producer_jar/joni-2.1.2.jar new file mode 100644 index 0000000..e953719 Binary files /dev/null and b/out/artifacts/elec_producer_jar/joni-2.1.2.jar differ diff --git a/out/artifacts/elec_producer_jar/jsch-0.1.42.jar b/out/artifacts/elec_producer_jar/jsch-0.1.42.jar new file mode 100644 index 0000000..c65eff0 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jsch-0.1.42.jar differ diff --git a/out/artifacts/elec_producer_jar/jsp-2.1-6.1.14.jar b/out/artifacts/elec_producer_jar/jsp-2.1-6.1.14.jar new file mode 100644 index 0000000..debfe56 Binary files /dev/null and b/out/artifacts/elec_producer_jar/jsp-2.1-6.1.14.jar differ diff --git a/out/artifacts/elec_producer_jar/jsp-api-2.1-6.1.14.jar b/out/artifacts/elec_producer_jar/jsp-api-2.1-6.1.14.jar new file mode 100644 index 0000000..1be50ab Binary files /dev/null and b/out/artifacts/elec_producer_jar/jsp-api-2.1-6.1.14.jar differ diff --git a/out/artifacts/elec_producer_jar/junit-4.12.jar b/out/artifacts/elec_producer_jar/junit-4.12.jar new file mode 100644 index 0000000..3a7fc26 Binary files /dev/null and b/out/artifacts/elec_producer_jar/junit-4.12.jar differ diff --git a/out/artifacts/elec_producer_jar/leveldbjni-all-1.8.jar b/out/artifacts/elec_producer_jar/leveldbjni-all-1.8.jar new file mode 100644 index 0000000..cbda6e4 Binary files /dev/null and b/out/artifacts/elec_producer_jar/leveldbjni-all-1.8.jar differ diff --git a/out/artifacts/elec_producer_jar/log4j-1.2.17.jar b/out/artifacts/elec_producer_jar/log4j-1.2.17.jar new file mode 100644 index 0000000..1d425cf Binary files /dev/null and b/out/artifacts/elec_producer_jar/log4j-1.2.17.jar differ diff --git a/out/artifacts/elec_producer_jar/metrics-core-2.2.0.jar b/out/artifacts/elec_producer_jar/metrics-core-2.2.0.jar new file mode 100644 index 0000000..0f6d1cb Binary files /dev/null and b/out/artifacts/elec_producer_jar/metrics-core-2.2.0.jar differ diff --git a/out/artifacts/elec_producer_jar/netty-all-4.0.23.Final.jar b/out/artifacts/elec_producer_jar/netty-all-4.0.23.Final.jar new file mode 100644 index 0000000..0555a16 Binary files /dev/null and b/out/artifacts/elec_producer_jar/netty-all-4.0.23.Final.jar differ diff --git a/out/artifacts/elec_producer_jar/paranamer-2.3.jar b/out/artifacts/elec_producer_jar/paranamer-2.3.jar new file mode 100644 index 0000000..ad12ae9 Binary files /dev/null and b/out/artifacts/elec_producer_jar/paranamer-2.3.jar differ diff --git a/out/artifacts/elec_producer_jar/protobuf-java-2.5.0.jar b/out/artifacts/elec_producer_jar/protobuf-java-2.5.0.jar new file mode 100644 index 0000000..4c4e686 Binary files /dev/null and b/out/artifacts/elec_producer_jar/protobuf-java-2.5.0.jar differ diff --git a/out/artifacts/elec_producer_jar/servlet-api-2.5-6.1.14.jar b/out/artifacts/elec_producer_jar/servlet-api-2.5-6.1.14.jar new file mode 100644 index 0000000..6d7404f Binary files /dev/null and b/out/artifacts/elec_producer_jar/servlet-api-2.5-6.1.14.jar differ diff --git a/out/artifacts/elec_producer_jar/servlet-api-2.5.jar b/out/artifacts/elec_producer_jar/servlet-api-2.5.jar new file mode 100644 index 0000000..fb52493 Binary files /dev/null and b/out/artifacts/elec_producer_jar/servlet-api-2.5.jar differ diff --git a/out/artifacts/elec_producer_jar/slf4j-api-1.7.2.jar b/out/artifacts/elec_producer_jar/slf4j-api-1.7.2.jar new file mode 100644 index 0000000..1a88708 Binary files /dev/null and b/out/artifacts/elec_producer_jar/slf4j-api-1.7.2.jar differ diff --git a/out/artifacts/elec_producer_jar/slf4j-log4j12-1.6.1.jar b/out/artifacts/elec_producer_jar/slf4j-log4j12-1.6.1.jar new file mode 100644 index 0000000..6411599 Binary files /dev/null and b/out/artifacts/elec_producer_jar/slf4j-log4j12-1.6.1.jar differ diff --git a/out/artifacts/elec_producer_jar/snappy-java-1.0.4.1.jar b/out/artifacts/elec_producer_jar/snappy-java-1.0.4.1.jar new file mode 100644 index 0000000..8198919 Binary files /dev/null and b/out/artifacts/elec_producer_jar/snappy-java-1.0.4.1.jar differ diff --git a/out/artifacts/elec_producer_jar/stax-api-1.0-2.jar b/out/artifacts/elec_producer_jar/stax-api-1.0-2.jar new file mode 100644 index 0000000..015169d Binary files /dev/null and b/out/artifacts/elec_producer_jar/stax-api-1.0-2.jar differ diff --git a/out/artifacts/elec_producer_jar/tools.jar b/out/artifacts/elec_producer_jar/tools.jar new file mode 100644 index 0000000..2d152e1 Binary files /dev/null and b/out/artifacts/elec_producer_jar/tools.jar differ diff --git a/out/artifacts/elec_producer_jar/xmlenc-0.52.jar b/out/artifacts/elec_producer_jar/xmlenc-0.52.jar new file mode 100644 index 0000000..ec568b4 Binary files /dev/null and b/out/artifacts/elec_producer_jar/xmlenc-0.52.jar differ diff --git a/out/artifacts/elec_producer_jar/xz-1.0.jar b/out/artifacts/elec_producer_jar/xz-1.0.jar new file mode 100644 index 0000000..a848f16 Binary files /dev/null and b/out/artifacts/elec_producer_jar/xz-1.0.jar differ diff --git a/out/artifacts/elec_producer_jar/zookeeper-3.4.6.jar b/out/artifacts/elec_producer_jar/zookeeper-3.4.6.jar new file mode 100644 index 0000000..7c340be Binary files /dev/null and b/out/artifacts/elec_producer_jar/zookeeper-3.4.6.jar differ diff --git a/out/artifacts/project_elec_jar/activation-1.1.jar b/out/artifacts/project_elec_jar/activation-1.1.jar new file mode 100644 index 0000000..53f82a1 Binary files /dev/null and b/out/artifacts/project_elec_jar/activation-1.1.jar differ diff --git a/out/artifacts/project_elec_jar/aopalliance-1.0.jar b/out/artifacts/project_elec_jar/aopalliance-1.0.jar new file mode 100644 index 0000000..578b1a0 Binary files /dev/null and b/out/artifacts/project_elec_jar/aopalliance-1.0.jar differ diff --git a/out/artifacts/project_elec_jar/apacheds-i18n-2.0.0-M15.jar b/out/artifacts/project_elec_jar/apacheds-i18n-2.0.0-M15.jar new file mode 100644 index 0000000..11dccb3 Binary files /dev/null and b/out/artifacts/project_elec_jar/apacheds-i18n-2.0.0-M15.jar differ diff --git a/out/artifacts/project_elec_jar/apacheds-kerberos-codec-2.0.0-M15.jar b/out/artifacts/project_elec_jar/apacheds-kerberos-codec-2.0.0-M15.jar new file mode 100644 index 0000000..82e564e Binary files /dev/null and b/out/artifacts/project_elec_jar/apacheds-kerberos-codec-2.0.0-M15.jar differ diff --git a/out/artifacts/project_elec_jar/api-asn1-api-1.0.0-M20.jar b/out/artifacts/project_elec_jar/api-asn1-api-1.0.0-M20.jar new file mode 100644 index 0000000..68dee3a Binary files /dev/null and b/out/artifacts/project_elec_jar/api-asn1-api-1.0.0-M20.jar differ diff --git a/out/artifacts/project_elec_jar/api-util-1.0.0-M20.jar b/out/artifacts/project_elec_jar/api-util-1.0.0-M20.jar new file mode 100644 index 0000000..ff9780e Binary files /dev/null and b/out/artifacts/project_elec_jar/api-util-1.0.0-M20.jar differ diff --git a/out/artifacts/project_elec_jar/asm-3.1.jar b/out/artifacts/project_elec_jar/asm-3.1.jar new file mode 100644 index 0000000..8217cae Binary files /dev/null and b/out/artifacts/project_elec_jar/asm-3.1.jar differ diff --git a/out/artifacts/project_elec_jar/avro-1.7.4.jar b/out/artifacts/project_elec_jar/avro-1.7.4.jar new file mode 100644 index 0000000..69dd87d Binary files /dev/null and b/out/artifacts/project_elec_jar/avro-1.7.4.jar differ diff --git a/out/artifacts/project_elec_jar/commons-beanutils-1.7.0.jar b/out/artifacts/project_elec_jar/commons-beanutils-1.7.0.jar new file mode 100644 index 0000000..b1b89c9 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-beanutils-1.7.0.jar differ diff --git a/out/artifacts/project_elec_jar/commons-beanutils-core-1.8.0.jar b/out/artifacts/project_elec_jar/commons-beanutils-core-1.8.0.jar new file mode 100644 index 0000000..87c15f4 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-beanutils-core-1.8.0.jar differ diff --git a/out/artifacts/project_elec_jar/commons-cli-1.2.jar b/out/artifacts/project_elec_jar/commons-cli-1.2.jar new file mode 100644 index 0000000..ce4b9ff Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-cli-1.2.jar differ diff --git a/out/artifacts/project_elec_jar/commons-codec-1.9.jar b/out/artifacts/project_elec_jar/commons-codec-1.9.jar new file mode 100644 index 0000000..ef35f1c Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-codec-1.9.jar differ diff --git a/out/artifacts/project_elec_jar/commons-collections-3.2.2.jar b/out/artifacts/project_elec_jar/commons-collections-3.2.2.jar new file mode 100644 index 0000000..fa5df82 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-collections-3.2.2.jar differ diff --git a/out/artifacts/project_elec_jar/commons-compress-1.4.1.jar b/out/artifacts/project_elec_jar/commons-compress-1.4.1.jar new file mode 100644 index 0000000..b58761e Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-compress-1.4.1.jar differ diff --git a/out/artifacts/project_elec_jar/commons-configuration-1.6.jar b/out/artifacts/project_elec_jar/commons-configuration-1.6.jar new file mode 100644 index 0000000..2d4689a Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-configuration-1.6.jar differ diff --git a/out/artifacts/project_elec_jar/commons-daemon-1.0.13.jar b/out/artifacts/project_elec_jar/commons-daemon-1.0.13.jar new file mode 100644 index 0000000..ac77321 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-daemon-1.0.13.jar differ diff --git a/out/artifacts/project_elec_jar/commons-digester-1.8.jar b/out/artifacts/project_elec_jar/commons-digester-1.8.jar new file mode 100644 index 0000000..1110f0a Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-digester-1.8.jar differ diff --git a/out/artifacts/project_elec_jar/commons-el-1.0.jar b/out/artifacts/project_elec_jar/commons-el-1.0.jar new file mode 100644 index 0000000..608ed79 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-el-1.0.jar differ diff --git a/out/artifacts/project_elec_jar/commons-httpclient-3.1.jar b/out/artifacts/project_elec_jar/commons-httpclient-3.1.jar new file mode 100644 index 0000000..7c59774 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-httpclient-3.1.jar differ diff --git a/out/artifacts/project_elec_jar/commons-io-2.4.jar b/out/artifacts/project_elec_jar/commons-io-2.4.jar new file mode 100644 index 0000000..90035a4 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-io-2.4.jar differ diff --git a/out/artifacts/project_elec_jar/commons-lang-2.6.jar b/out/artifacts/project_elec_jar/commons-lang-2.6.jar new file mode 100644 index 0000000..98467d3 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-lang-2.6.jar differ diff --git a/out/artifacts/project_elec_jar/commons-logging-1.2.jar b/out/artifacts/project_elec_jar/commons-logging-1.2.jar new file mode 100644 index 0000000..93a3b9f Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-logging-1.2.jar differ diff --git a/out/artifacts/project_elec_jar/commons-math-2.2.jar b/out/artifacts/project_elec_jar/commons-math-2.2.jar new file mode 100644 index 0000000..b29a39c Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-math-2.2.jar differ diff --git a/out/artifacts/project_elec_jar/commons-math3-3.1.1.jar b/out/artifacts/project_elec_jar/commons-math3-3.1.1.jar new file mode 100644 index 0000000..43b5215 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-math3-3.1.1.jar differ diff --git a/out/artifacts/project_elec_jar/commons-net-3.1.jar b/out/artifacts/project_elec_jar/commons-net-3.1.jar new file mode 100644 index 0000000..b75f1a5 Binary files /dev/null and b/out/artifacts/project_elec_jar/commons-net-3.1.jar differ diff --git a/out/artifacts/project_elec_jar/disruptor-3.3.0.jar b/out/artifacts/project_elec_jar/disruptor-3.3.0.jar new file mode 100644 index 0000000..6f88ada Binary files /dev/null and b/out/artifacts/project_elec_jar/disruptor-3.3.0.jar differ diff --git a/out/artifacts/project_elec_jar/findbugs-annotations-1.3.9-1.jar b/out/artifacts/project_elec_jar/findbugs-annotations-1.3.9-1.jar new file mode 100644 index 0000000..f8551a2 Binary files /dev/null and b/out/artifacts/project_elec_jar/findbugs-annotations-1.3.9-1.jar differ diff --git a/out/artifacts/project_elec_jar/guava-12.0.1.jar b/out/artifacts/project_elec_jar/guava-12.0.1.jar new file mode 100644 index 0000000..b185ee6 Binary files /dev/null and b/out/artifacts/project_elec_jar/guava-12.0.1.jar differ diff --git a/out/artifacts/project_elec_jar/guice-3.0.jar b/out/artifacts/project_elec_jar/guice-3.0.jar new file mode 100644 index 0000000..f313e2b Binary files /dev/null and b/out/artifacts/project_elec_jar/guice-3.0.jar differ diff --git a/out/artifacts/project_elec_jar/guice-servlet-3.0.jar b/out/artifacts/project_elec_jar/guice-servlet-3.0.jar new file mode 100644 index 0000000..bdc6614 Binary files /dev/null and b/out/artifacts/project_elec_jar/guice-servlet-3.0.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-annotations-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-annotations-2.5.1.jar new file mode 100644 index 0000000..008eae1 Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-annotations-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-auth-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-auth-2.5.1.jar new file mode 100644 index 0000000..21b1071 Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-auth-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-client-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-client-2.5.1.jar new file mode 100644 index 0000000..27655d7 Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-client-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-common-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-common-2.5.1.jar new file mode 100644 index 0000000..be518bd Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-common-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-hdfs-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-hdfs-2.5.1.jar new file mode 100644 index 0000000..bdb430e Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-hdfs-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-mapreduce-client-app-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-app-2.5.1.jar new file mode 100644 index 0000000..4f1b83c Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-app-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-mapreduce-client-common-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-common-2.5.1.jar new file mode 100644 index 0000000..f5623d5 Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-common-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-mapreduce-client-core-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-core-2.5.1.jar new file mode 100644 index 0000000..216c75b Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-core-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-mapreduce-client-jobclient-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-jobclient-2.5.1.jar new file mode 100644 index 0000000..7c19153 Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-jobclient-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-mapreduce-client-shuffle-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-shuffle-2.5.1.jar new file mode 100644 index 0000000..8d871f9 Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-mapreduce-client-shuffle-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-yarn-api-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-yarn-api-2.5.1.jar new file mode 100644 index 0000000..ff5b75f Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-yarn-api-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-yarn-client-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-yarn-client-2.5.1.jar new file mode 100644 index 0000000..fd920f8 Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-yarn-client-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-yarn-common-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-yarn-common-2.5.1.jar new file mode 100644 index 0000000..e94415c Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-yarn-common-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hadoop-yarn-server-common-2.5.1.jar b/out/artifacts/project_elec_jar/hadoop-yarn-server-common-2.5.1.jar new file mode 100644 index 0000000..cd7825d Binary files /dev/null and b/out/artifacts/project_elec_jar/hadoop-yarn-server-common-2.5.1.jar differ diff --git a/out/artifacts/project_elec_jar/hamcrest-core-1.3.jar b/out/artifacts/project_elec_jar/hamcrest-core-1.3.jar new file mode 100644 index 0000000..9d5fe16 Binary files /dev/null and b/out/artifacts/project_elec_jar/hamcrest-core-1.3.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-annotations-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-annotations-1.3.1.jar new file mode 100644 index 0000000..350ad6b Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-annotations-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-client-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-client-1.3.1.jar new file mode 100644 index 0000000..250f7ee Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-client-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-common-1.3.1-tests.jar b/out/artifacts/project_elec_jar/hbase-common-1.3.1-tests.jar new file mode 100644 index 0000000..12d2669 Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-common-1.3.1-tests.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-common-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-common-1.3.1.jar new file mode 100644 index 0000000..27995a0 Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-common-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-hadoop-compat-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-hadoop-compat-1.3.1.jar new file mode 100644 index 0000000..1fac61b Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-hadoop-compat-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-hadoop2-compat-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-hadoop2-compat-1.3.1.jar new file mode 100644 index 0000000..5ca63dd Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-hadoop2-compat-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-prefix-tree-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-prefix-tree-1.3.1.jar new file mode 100644 index 0000000..d3c1d21 Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-prefix-tree-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-procedure-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-procedure-1.3.1.jar new file mode 100644 index 0000000..e5a0d09 Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-procedure-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-protocol-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-protocol-1.3.1.jar new file mode 100644 index 0000000..fe53b2f Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-protocol-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/hbase-server-1.3.1.jar b/out/artifacts/project_elec_jar/hbase-server-1.3.1.jar new file mode 100644 index 0000000..8118d3a Binary files /dev/null and b/out/artifacts/project_elec_jar/hbase-server-1.3.1.jar differ diff --git a/out/artifacts/project_elec_jar/htrace-core-3.1.0-incubating.jar b/out/artifacts/project_elec_jar/htrace-core-3.1.0-incubating.jar new file mode 100644 index 0000000..6f03925 Binary files /dev/null and b/out/artifacts/project_elec_jar/htrace-core-3.1.0-incubating.jar differ diff --git a/out/artifacts/project_elec_jar/httpclient-4.2.5.jar b/out/artifacts/project_elec_jar/httpclient-4.2.5.jar new file mode 100644 index 0000000..84fece4 Binary files /dev/null and b/out/artifacts/project_elec_jar/httpclient-4.2.5.jar differ diff --git a/out/artifacts/project_elec_jar/httpcore-4.1.2.jar b/out/artifacts/project_elec_jar/httpcore-4.1.2.jar new file mode 100644 index 0000000..66ae90b Binary files /dev/null and b/out/artifacts/project_elec_jar/httpcore-4.1.2.jar differ diff --git a/out/artifacts/project_elec_jar/jackson-core-asl-1.9.13.jar b/out/artifacts/project_elec_jar/jackson-core-asl-1.9.13.jar new file mode 100644 index 0000000..bb4fe1d Binary files /dev/null and b/out/artifacts/project_elec_jar/jackson-core-asl-1.9.13.jar differ diff --git a/out/artifacts/project_elec_jar/jackson-jaxrs-1.9.13.jar b/out/artifacts/project_elec_jar/jackson-jaxrs-1.9.13.jar new file mode 100644 index 0000000..b85f45c Binary files /dev/null and b/out/artifacts/project_elec_jar/jackson-jaxrs-1.9.13.jar differ diff --git a/out/artifacts/project_elec_jar/jackson-mapper-asl-1.9.13.jar b/out/artifacts/project_elec_jar/jackson-mapper-asl-1.9.13.jar new file mode 100644 index 0000000..0f2073f Binary files /dev/null and b/out/artifacts/project_elec_jar/jackson-mapper-asl-1.9.13.jar differ diff --git a/out/artifacts/project_elec_jar/jackson-xc-1.8.3.jar b/out/artifacts/project_elec_jar/jackson-xc-1.8.3.jar new file mode 100644 index 0000000..9e168ec Binary files /dev/null and b/out/artifacts/project_elec_jar/jackson-xc-1.8.3.jar differ diff --git a/out/artifacts/project_elec_jar/jamon-runtime-2.4.1.jar b/out/artifacts/project_elec_jar/jamon-runtime-2.4.1.jar new file mode 100644 index 0000000..219f88d Binary files /dev/null and b/out/artifacts/project_elec_jar/jamon-runtime-2.4.1.jar differ diff --git a/out/artifacts/project_elec_jar/jasper-compiler-5.5.23.jar b/out/artifacts/project_elec_jar/jasper-compiler-5.5.23.jar new file mode 100644 index 0000000..170efa0 Binary files /dev/null and b/out/artifacts/project_elec_jar/jasper-compiler-5.5.23.jar differ diff --git a/out/artifacts/project_elec_jar/jasper-runtime-5.5.23.jar b/out/artifacts/project_elec_jar/jasper-runtime-5.5.23.jar new file mode 100644 index 0000000..a3208c9 Binary files /dev/null and b/out/artifacts/project_elec_jar/jasper-runtime-5.5.23.jar differ diff --git a/out/artifacts/project_elec_jar/java-xmlbuilder-0.4.jar b/out/artifacts/project_elec_jar/java-xmlbuilder-0.4.jar new file mode 100644 index 0000000..e5acf92 Binary files /dev/null and b/out/artifacts/project_elec_jar/java-xmlbuilder-0.4.jar differ diff --git a/out/artifacts/project_elec_jar/javax.inject-1.jar b/out/artifacts/project_elec_jar/javax.inject-1.jar new file mode 100644 index 0000000..b2a9d0b Binary files /dev/null and b/out/artifacts/project_elec_jar/javax.inject-1.jar differ diff --git a/out/artifacts/project_elec_jar/jaxb-api-2.2.2.jar b/out/artifacts/project_elec_jar/jaxb-api-2.2.2.jar new file mode 100644 index 0000000..31e5fa0 Binary files /dev/null and b/out/artifacts/project_elec_jar/jaxb-api-2.2.2.jar differ diff --git a/out/artifacts/project_elec_jar/jaxb-impl-2.2.3-1.jar b/out/artifacts/project_elec_jar/jaxb-impl-2.2.3-1.jar new file mode 100644 index 0000000..eeaf660 Binary files /dev/null and b/out/artifacts/project_elec_jar/jaxb-impl-2.2.3-1.jar differ diff --git a/out/artifacts/project_elec_jar/jcodings-1.0.8.jar b/out/artifacts/project_elec_jar/jcodings-1.0.8.jar new file mode 100644 index 0000000..1c377c6 Binary files /dev/null and b/out/artifacts/project_elec_jar/jcodings-1.0.8.jar differ diff --git a/out/artifacts/project_elec_jar/jersey-client-1.9.jar b/out/artifacts/project_elec_jar/jersey-client-1.9.jar new file mode 100644 index 0000000..d811f13 Binary files /dev/null and b/out/artifacts/project_elec_jar/jersey-client-1.9.jar differ diff --git a/out/artifacts/project_elec_jar/jersey-core-1.9.jar b/out/artifacts/project_elec_jar/jersey-core-1.9.jar new file mode 100644 index 0000000..548dd88 Binary files /dev/null and b/out/artifacts/project_elec_jar/jersey-core-1.9.jar differ diff --git a/out/artifacts/project_elec_jar/jersey-guice-1.9.jar b/out/artifacts/project_elec_jar/jersey-guice-1.9.jar new file mode 100644 index 0000000..cb46c94 Binary files /dev/null and b/out/artifacts/project_elec_jar/jersey-guice-1.9.jar differ diff --git a/out/artifacts/project_elec_jar/jersey-json-1.9.jar b/out/artifacts/project_elec_jar/jersey-json-1.9.jar new file mode 100644 index 0000000..b1a4ce5 Binary files /dev/null and b/out/artifacts/project_elec_jar/jersey-json-1.9.jar differ diff --git a/out/artifacts/project_elec_jar/jersey-server-1.9.jar b/out/artifacts/project_elec_jar/jersey-server-1.9.jar new file mode 100644 index 0000000..ae0117c Binary files /dev/null and b/out/artifacts/project_elec_jar/jersey-server-1.9.jar differ diff --git a/out/artifacts/project_elec_jar/jets3t-0.9.0.jar b/out/artifacts/project_elec_jar/jets3t-0.9.0.jar new file mode 100644 index 0000000..6870900 Binary files /dev/null and b/out/artifacts/project_elec_jar/jets3t-0.9.0.jar differ diff --git a/out/artifacts/project_elec_jar/jettison-1.1.jar b/out/artifacts/project_elec_jar/jettison-1.1.jar new file mode 100644 index 0000000..e4e9c8c Binary files /dev/null and b/out/artifacts/project_elec_jar/jettison-1.1.jar differ diff --git a/out/artifacts/project_elec_jar/jetty-6.1.26.jar b/out/artifacts/project_elec_jar/jetty-6.1.26.jar new file mode 100644 index 0000000..2cbe07a Binary files /dev/null and b/out/artifacts/project_elec_jar/jetty-6.1.26.jar differ diff --git a/out/artifacts/project_elec_jar/jetty-sslengine-6.1.26.jar b/out/artifacts/project_elec_jar/jetty-sslengine-6.1.26.jar new file mode 100644 index 0000000..051efb5 Binary files /dev/null and b/out/artifacts/project_elec_jar/jetty-sslengine-6.1.26.jar differ diff --git a/out/artifacts/project_elec_jar/jetty-util-6.1.26.jar b/out/artifacts/project_elec_jar/jetty-util-6.1.26.jar new file mode 100644 index 0000000..cd23752 Binary files /dev/null and b/out/artifacts/project_elec_jar/jetty-util-6.1.26.jar differ diff --git a/out/artifacts/project_elec_jar/joni-2.1.2.jar b/out/artifacts/project_elec_jar/joni-2.1.2.jar new file mode 100644 index 0000000..e953719 Binary files /dev/null and b/out/artifacts/project_elec_jar/joni-2.1.2.jar differ diff --git a/out/artifacts/project_elec_jar/jopt-simple-5.0.3.jar b/out/artifacts/project_elec_jar/jopt-simple-5.0.3.jar new file mode 100644 index 0000000..39a78d0 Binary files /dev/null and b/out/artifacts/project_elec_jar/jopt-simple-5.0.3.jar differ diff --git a/out/artifacts/project_elec_jar/jsch-0.1.42.jar b/out/artifacts/project_elec_jar/jsch-0.1.42.jar new file mode 100644 index 0000000..c65eff0 Binary files /dev/null and b/out/artifacts/project_elec_jar/jsch-0.1.42.jar differ diff --git a/out/artifacts/project_elec_jar/jsp-2.1-6.1.14.jar b/out/artifacts/project_elec_jar/jsp-2.1-6.1.14.jar new file mode 100644 index 0000000..debfe56 Binary files /dev/null and b/out/artifacts/project_elec_jar/jsp-2.1-6.1.14.jar differ diff --git a/out/artifacts/project_elec_jar/jsp-api-2.1-6.1.14.jar b/out/artifacts/project_elec_jar/jsp-api-2.1-6.1.14.jar new file mode 100644 index 0000000..1be50ab Binary files /dev/null and b/out/artifacts/project_elec_jar/jsp-api-2.1-6.1.14.jar differ diff --git a/out/artifacts/project_elec_jar/junit-4.12.jar b/out/artifacts/project_elec_jar/junit-4.12.jar new file mode 100644 index 0000000..3a7fc26 Binary files /dev/null and b/out/artifacts/project_elec_jar/junit-4.12.jar differ diff --git a/out/artifacts/project_elec_jar/kafka-clients-2.0.0.jar b/out/artifacts/project_elec_jar/kafka-clients-2.0.0.jar new file mode 100644 index 0000000..fb6120f Binary files /dev/null and b/out/artifacts/project_elec_jar/kafka-clients-2.0.0.jar differ diff --git a/out/artifacts/project_elec_jar/kafka_2.12-0.11.0.0.jar b/out/artifacts/project_elec_jar/kafka_2.12-0.11.0.0.jar new file mode 100644 index 0000000..cbed0c7 Binary files /dev/null and b/out/artifacts/project_elec_jar/kafka_2.12-0.11.0.0.jar differ diff --git a/out/artifacts/project_elec_jar/leveldbjni-all-1.8.jar b/out/artifacts/project_elec_jar/leveldbjni-all-1.8.jar new file mode 100644 index 0000000..cbda6e4 Binary files /dev/null and b/out/artifacts/project_elec_jar/leveldbjni-all-1.8.jar differ diff --git a/out/artifacts/project_elec_jar/log4j-1.2.17.jar b/out/artifacts/project_elec_jar/log4j-1.2.17.jar new file mode 100644 index 0000000..1d425cf Binary files /dev/null and b/out/artifacts/project_elec_jar/log4j-1.2.17.jar differ diff --git a/out/artifacts/project_elec_jar/lz4-java-1.4.1.jar b/out/artifacts/project_elec_jar/lz4-java-1.4.1.jar new file mode 100644 index 0000000..90786d9 Binary files /dev/null and b/out/artifacts/project_elec_jar/lz4-java-1.4.1.jar differ diff --git a/out/artifacts/project_elec_jar/metrics-core-2.2.0.jar b/out/artifacts/project_elec_jar/metrics-core-2.2.0.jar new file mode 100644 index 0000000..0f6d1cb Binary files /dev/null and b/out/artifacts/project_elec_jar/metrics-core-2.2.0.jar differ diff --git a/out/artifacts/project_elec_jar/netty-all-4.0.23.Final.jar b/out/artifacts/project_elec_jar/netty-all-4.0.23.Final.jar new file mode 100644 index 0000000..0555a16 Binary files /dev/null and b/out/artifacts/project_elec_jar/netty-all-4.0.23.Final.jar differ diff --git a/out/artifacts/project_elec_jar/paranamer-2.3.jar b/out/artifacts/project_elec_jar/paranamer-2.3.jar new file mode 100644 index 0000000..ad12ae9 Binary files /dev/null and b/out/artifacts/project_elec_jar/paranamer-2.3.jar differ diff --git a/out/artifacts/project_elec_jar/project-elec.jar b/out/artifacts/project_elec_jar/project-elec.jar new file mode 100644 index 0000000..beff96f Binary files /dev/null and b/out/artifacts/project_elec_jar/project-elec.jar differ diff --git a/out/artifacts/project_elec_jar/protobuf-java-2.5.0.jar b/out/artifacts/project_elec_jar/protobuf-java-2.5.0.jar new file mode 100644 index 0000000..4c4e686 Binary files /dev/null and b/out/artifacts/project_elec_jar/protobuf-java-2.5.0.jar differ diff --git a/out/artifacts/project_elec_jar/scala-library-2.12.2.jar b/out/artifacts/project_elec_jar/scala-library-2.12.2.jar new file mode 100644 index 0000000..ca0ed38 Binary files /dev/null and b/out/artifacts/project_elec_jar/scala-library-2.12.2.jar differ diff --git a/out/artifacts/project_elec_jar/scala-parser-combinators_2.12-1.0.4.jar b/out/artifacts/project_elec_jar/scala-parser-combinators_2.12-1.0.4.jar new file mode 100644 index 0000000..56fa393 Binary files /dev/null and b/out/artifacts/project_elec_jar/scala-parser-combinators_2.12-1.0.4.jar differ diff --git a/out/artifacts/project_elec_jar/servlet-api-2.5-6.1.14.jar b/out/artifacts/project_elec_jar/servlet-api-2.5-6.1.14.jar new file mode 100644 index 0000000..6d7404f Binary files /dev/null and b/out/artifacts/project_elec_jar/servlet-api-2.5-6.1.14.jar differ diff --git a/out/artifacts/project_elec_jar/servlet-api-2.5.jar b/out/artifacts/project_elec_jar/servlet-api-2.5.jar new file mode 100644 index 0000000..fb52493 Binary files /dev/null and b/out/artifacts/project_elec_jar/servlet-api-2.5.jar differ diff --git a/out/artifacts/project_elec_jar/slf4j-api-1.7.2.jar b/out/artifacts/project_elec_jar/slf4j-api-1.7.2.jar new file mode 100644 index 0000000..1a88708 Binary files /dev/null and b/out/artifacts/project_elec_jar/slf4j-api-1.7.2.jar differ diff --git a/out/artifacts/project_elec_jar/slf4j-api-1.7.25.jar b/out/artifacts/project_elec_jar/slf4j-api-1.7.25.jar new file mode 100644 index 0000000..0143c09 Binary files /dev/null and b/out/artifacts/project_elec_jar/slf4j-api-1.7.25.jar differ diff --git a/out/artifacts/project_elec_jar/slf4j-log4j12-1.6.1.jar b/out/artifacts/project_elec_jar/slf4j-log4j12-1.6.1.jar new file mode 100644 index 0000000..6411599 Binary files /dev/null and b/out/artifacts/project_elec_jar/slf4j-log4j12-1.6.1.jar differ diff --git a/out/artifacts/project_elec_jar/slf4j-log4j12-1.7.25.jar b/out/artifacts/project_elec_jar/slf4j-log4j12-1.7.25.jar new file mode 100644 index 0000000..7d88a6e Binary files /dev/null and b/out/artifacts/project_elec_jar/slf4j-log4j12-1.7.25.jar differ diff --git a/out/artifacts/project_elec_jar/snappy-java-1.0.4.1.jar b/out/artifacts/project_elec_jar/snappy-java-1.0.4.1.jar new file mode 100644 index 0000000..8198919 Binary files /dev/null and b/out/artifacts/project_elec_jar/snappy-java-1.0.4.1.jar differ diff --git a/out/artifacts/project_elec_jar/snappy-java-1.1.7.1.jar b/out/artifacts/project_elec_jar/snappy-java-1.1.7.1.jar new file mode 100644 index 0000000..e817ab2 Binary files /dev/null and b/out/artifacts/project_elec_jar/snappy-java-1.1.7.1.jar differ diff --git a/out/artifacts/project_elec_jar/stax-api-1.0-2.jar b/out/artifacts/project_elec_jar/stax-api-1.0-2.jar new file mode 100644 index 0000000..015169d Binary files /dev/null and b/out/artifacts/project_elec_jar/stax-api-1.0-2.jar differ diff --git a/out/artifacts/project_elec_jar/tools.jar b/out/artifacts/project_elec_jar/tools.jar new file mode 100644 index 0000000..2d152e1 Binary files /dev/null and b/out/artifacts/project_elec_jar/tools.jar differ diff --git a/out/artifacts/project_elec_jar/xmlenc-0.52.jar b/out/artifacts/project_elec_jar/xmlenc-0.52.jar new file mode 100644 index 0000000..ec568b4 Binary files /dev/null and b/out/artifacts/project_elec_jar/xmlenc-0.52.jar differ diff --git a/out/artifacts/project_elec_jar/xz-1.0.jar b/out/artifacts/project_elec_jar/xz-1.0.jar new file mode 100644 index 0000000..a848f16 Binary files /dev/null and b/out/artifacts/project_elec_jar/xz-1.0.jar differ diff --git a/out/artifacts/project_elec_jar/zkclient-0.10.jar b/out/artifacts/project_elec_jar/zkclient-0.10.jar new file mode 100644 index 0000000..b97c439 Binary files /dev/null and b/out/artifacts/project_elec_jar/zkclient-0.10.jar differ diff --git a/out/artifacts/project_elec_jar/zookeeper-3.4.10.jar b/out/artifacts/project_elec_jar/zookeeper-3.4.10.jar new file mode 100644 index 0000000..0d8b0d3 Binary files /dev/null and b/out/artifacts/project_elec_jar/zookeeper-3.4.10.jar differ diff --git a/out/artifacts/project_elec_jar/zookeeper-3.4.6.jar b/out/artifacts/project_elec_jar/zookeeper-3.4.6.jar new file mode 100644 index 0000000..7c340be Binary files /dev/null and b/out/artifacts/project_elec_jar/zookeeper-3.4.6.jar differ diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..e079ac8 --- /dev/null +++ b/pom.xml @@ -0,0 +1,22 @@ + + + 4.0.0 + + com.educg + project-elec + pom + 1.0-SNAPSHOT + + elec-common + elec-producer + elec-consumer + + + + 8 + 8 + + + \ No newline at end of file