pil3aoekg
/
javac
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

统计session比率功能完成

Browse Source 
统计session比率并持久化数据库功能完成
main
oeljeklaus-you 7 years ago
parent 46490e6d66
commit fb0c0947c7
7 changed files with 562 additions and 105 deletions
Show Stats Download Patch File Download Diff File

428
.idea/workspace.xml
Unescape View File

@ -2,52 +2,13 @@
<project version="4">
<component name="ChangeListManager">
<list default="true" id="a7505764-040b-48e2-b2fc-8c5b579e595f" name="Default" comment="">
<change beforePath="" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__net_sf_py4j_py4j_0_8_2_1.xml" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/constant/Constants.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/TaskDao.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/TaskDaoImpl.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/demo/Singleton.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/domain/Task.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/jdbc/JDBCHelper.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/mockData/MockData.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/session/SessionAggrStatAccumulator.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/session/UserVisitAnalyze.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/test/java/cn/edu/hust/dao/TaskDaoTest.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/test/java/cn/edu/hust/jdbc/JDBCHelperTest.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/test/java/cn/edu/hust/json/FastJsonTest.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/test/java/cn/edu/hust/utils/ParamUtilsTest.java" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__joda_time_joda_time_2_9.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__joda_time_joda_time_2_5.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__net_razorvine_pyrolite_4_9.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__net_razorvine_pyrolite_4_4.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__net_sf_py4j_py4j_0_9.xml" afterPath="" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_curator_curator_client_2_6_0.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_curator_curator_client_2_1_0_incubating.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_catalyst_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_launcher_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_core_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_hive_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_hive_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_core_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_launcher_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_catalyst_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_network_common_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_network_common_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_network_shuffle_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_network_shuffle_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_sql_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_sql_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_streaming_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_streaming_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_unsafe_2_10_1_6_1.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_spark_spark_unsafe_2_10_1_5_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_apache_xbean_xbean_asm5_shaded_4_4.xml" afterPath="" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_roaringbitmap_RoaringBitmap_0_5_11.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_roaringbitmap_RoaringBitmap_0_4_5.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_scala_lang_scala_library_2_10_5.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_scala_lang_scala_library_2_10_4.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_spark_project_hive_hive_cli_1_2_1_spark.xml" afterPath="" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_tachyonproject_tachyon_client_0_8_2.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_tachyonproject_tachyon_client_0_7_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_tachyonproject_tachyon_underfs_hdfs_0_8_2.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_tachyonproject_tachyon_underfs_hdfs_0_7_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_tachyonproject_tachyon_underfs_local_0_8_2.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_tachyonproject_tachyon_underfs_local_0_7_1.xml" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_tachyonproject_tachyon_underfs_s3_0_8_2.xml" afterPath="" />
<change beforePath="$PROJECT_DIR$/.idea/libraries/Maven__org_xerial_snappy_snappy_java_1_1_2.xml" afterPath="$PROJECT_DIR$/.idea/libraries/Maven__org_xerial_snappy_snappy_java_1_1_1_7.xml" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/SessionAggrStatDao.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionAggrStatDaoImpl.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/domain/SessionAggrStat.java" />
<change beforePath="" afterPath="$PROJECT_DIR$/src/test/java/cn/edu/hust/dao/SessionAggrDao.java" />
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" afterPath="$PROJECT_DIR$/.idea/workspace.xml" />
<change beforePath="$PROJECT_DIR$/README.md" afterPath="$PROJECT_DIR$/README.md" />
<change beforePath="$PROJECT_DIR$/UserActionAnalyzePlatform.iml" afterPath="$PROJECT_DIR$/UserActionAnalyzePlatform.iml" />
<change beforePath="$PROJECT_DIR$/pom.xml" afterPath="$PROJECT_DIR$/pom.xml" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/conf/ConfigurationManager.java" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/conf/ConfigurationManager.java" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/util/DateUtils.java" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/util/DateUtils.java" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/util/StringUtils.java" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/util/StringUtils.java" />
<change beforePath="$PROJECT_DIR$/src/main/resources/conf.properties" afterPath="$PROJECT_DIR$/src/main/resources/conf.properties" />
<change beforePath="$PROJECT_DIR$/target/classes/conf.properties" afterPath="$PROJECT_DIR$/target/classes/conf.properties" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java" />
<change beforePath="$PROJECT_DIR$/src/main/java/cn/edu/hust/session/UserVisitAnalyze.java" afterPath="$PROJECT_DIR$/src/main/java/cn/edu/hust/session/UserVisitAnalyze.java" />
</list>
<ignored path="$PROJECT_DIR$/out/" />
<ignored path="$PROJECT_DIR$/target/" />
@ -63,18 +24,115 @@
<file leaf-file-name="UserVisitAnalyze.java" pinned="false" current-in-tab="true">
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/session/UserVisitAnalyze.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="400">
<caret line="304" column="26" lean-forward="false" selection-start-line="304" selection-start-column="26" selection-end-line="304" selection-end-column="26" />
<state relative-caret-position="4652">
<caret line="357" column="0" lean-forward="false" selection-start-line="357" selection-start-column="0" selection-end-line="357" selection-end-column="0" />
<folding>
<element signature="imports" expanded="true" />
<element signature="e#4629#4854#0" expanded="true" />
<element signature="e#4853#4854#0" expanded="true" />
<element signature="e#5084#7825#0" expanded="true" />
<element signature="e#7824#7825#0" expanded="true" />
<element signature="e#8045#8268#0" expanded="true" />
<element signature="e#8267#8268#0" expanded="true" />
<element signature="e#8521#9535#0" expanded="true" />
<element signature="e#9534#9535#0" expanded="true" />
</folding>
</state>
</provider>
</entry>
</file>
<file leaf-file-name="SessionAggrStat.java" pinned="false" current-in-tab="false">
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/domain/SessionAggrStat.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="58">
<caret line="114" column="27" lean-forward="false" selection-start-line="114" selection-start-column="27" selection-end-line="114" selection-end-column="27" />
<folding>
<element signature="e#2125#2126#0" expanded="true" />
<element signature="e#2154#2155#0" expanded="true" />
<element signature="e#2196#2197#0" expanded="true" />
<element signature="e#2232#2233#0" expanded="true" />
<element signature="e#2269#2270#0" expanded="true" />
<element signature="e#2304#2305#0" expanded="true" />
<element signature="e#2358#2359#0" expanded="true" />
<element signature="e#2401#2402#0" expanded="true" />
<element signature="e#2446#2447#0" expanded="true" />
<element signature="e#2487#2488#0" expanded="true" />
<element signature="e#2555#2556#0" expanded="true" />
<element signature="e#2615#2616#0" expanded="true" />
<element signature="e#2660#2661#0" expanded="true" />
<element signature="e#2701#2702#0" expanded="true" />
<element signature="e#2769#2770#0" expanded="true" />
<element signature="e#2829#2830#0" expanded="true" />
<element signature="e#2874#2875#0" expanded="true" />
<element signature="e#2915#2916#0" expanded="true" />
<element signature="e#2983#2984#0" expanded="true" />
<element signature="e#3043#3044#0" expanded="true" />
<element signature="e#3090#3091#0" expanded="true" />
<element signature="e#3133#3134#0" expanded="true" />
<element signature="e#3316#3317#0" expanded="true" />
<element signature="e#3359#3360#0" expanded="true" />
<element signature="e#3540#3541#0" expanded="true" />
<element signature="e#3581#3582#0" expanded="true" />
<element signature="e#3649#3650#0" expanded="true" />
<element signature="e#3709#3710#0" expanded="true" />
<element signature="e#3755#3756#0" expanded="true" />
<element signature="e#3797#3798#0" expanded="true" />
<element signature="e#3865#3866#0" expanded="true" />
<element signature="e#3926#3927#0" expanded="true" />
<element signature="e#3973#3974#0" expanded="true" />
<element signature="e#4016#4017#0" expanded="true" />
<element signature="e#4195#4196#0" expanded="true" />
<element signature="e#4234#4235#0" expanded="true" />
<element signature="e#4298#4299#0" expanded="true" />
<element signature="e#4354#4355#0" expanded="true" />
<element signature="e#4396#4397#0" expanded="true" />
<element signature="e#4434#4435#0" expanded="true" />
<element signature="e#4496#4497#0" expanded="true" />
<element signature="e#4550#4551#0" expanded="true" />
<element signature="e#4592#4593#0" expanded="true" />
<element signature="e#4630#4631#0" expanded="true" />
<element signature="e#4692#4693#0" expanded="true" />
<element signature="e#4746#4747#0" expanded="true" />
<element signature="e#4788#4789#0" expanded="true" />
<element signature="e#4826#4827#0" expanded="true" />
<element signature="e#4888#4889#0" expanded="true" />
<element signature="e#4942#4943#0" expanded="true" />
<element signature="e#4986#4987#0" expanded="true" />
<element signature="e#5026#5027#0" expanded="true" />
<element signature="e#5092#5093#0" expanded="true" />
<element signature="e#5150#5151#0" expanded="true" />
<element signature="e#5194#5195#0" expanded="true" />
<element signature="e#5234#5235#0" expanded="true" />
<element signature="e#5300#5301#0" expanded="true" />
<element signature="e#5358#5359#0" expanded="true" />
<element signature="e#5399#5400#0" expanded="true" />
<element signature="e#5436#5437#0" expanded="true" />
<element signature="e#5496#5497#0" expanded="true" />
<element signature="e#5548#5549#0" expanded="true" />
</folding>
</state>
</provider>
</entry>
</file>
<file leaf-file-name="SessionAggrStatDaoImpl.java" pinned="false" current-in-tab="false">
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionAggrStatDaoImpl.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="342">
<caret line="18" column="58" lean-forward="false" selection-start-line="18" selection-start-column="58" selection-end-line="18" selection-end-column="58" />
<folding>
<element signature="imports" expanded="true" />
</folding>
</state>
</provider>
</entry>
</file>
<file leaf-file-name="SessionAggrDao.java" pinned="false" current-in-tab="false">
<entry file="file://$PROJECT_DIR$/src/test/java/cn/edu/hust/dao/SessionAggrDao.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="152">
<caret line="8" column="18" lean-forward="true" selection-start-line="8" selection-start-column="16" selection-end-line="8" selection-end-column="20" />
<folding>
<element signature="imports" expanded="true" />
<element signature="e#4523#4748#0" expanded="true" />
<element signature="e#4747#4748#0" expanded="true" />
<element signature="e#4978#7719#0" expanded="true" />
<element signature="e#7718#7719#0" expanded="true" />
<element signature="e#7939#8162#0" expanded="true" />
<element signature="e#8161#8162#0" expanded="true" />
<element signature="e#8415#9429#0" expanded="true" />
<element signature="e#9428#9429#0" expanded="true" />
</folding>
</state>
</provider>
@ -129,7 +187,6 @@
<option value="$PROJECT_DIR$/src/test/java/cn/edu/hust/jdbc/JDBCHelperTest.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/TaskDao.java" />
<option value="$PROJECT_DIR$/src/test/java/cn/edu/hust/dao/dao.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java" />
<option value="$PROJECT_DIR$/src/test/java/cn/edu/hust/json/FastJsonTest.java" />
<option value="$PROJECT_DIR$/src/main/resources/conf.properties" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/conf/ConfigurationManager.java" />
@ -146,6 +203,11 @@
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/util/DateUtils.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/constant/Constants.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/session/UserVisitAnalyze.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/SessionAggrStatDao.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/domain/SessionAggrStat.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionAggrStatDaoImpl.java" />
<option value="$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java" />
<option value="$PROJECT_DIR$/src/test/java/cn/edu/hust/dao/SessionAggrDao.java" />
</list>
</option>
</component>
@ -257,7 +319,35 @@
<item name="main" type="462c0819:PsiDirectoryNode" />
<item name="java" type="462c0819:PsiDirectoryNode" />
<item name="hust" type="462c0819:PsiDirectoryNode" />
<item name="constant" type="462c0819:PsiDirectoryNode" />
<item name="dao" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
<item name="UserActionAnalyzePlatform" type="462c0819:PsiDirectoryNode" />
<item name="src" type="462c0819:PsiDirectoryNode" />
<item name="main" type="462c0819:PsiDirectoryNode" />
<item name="java" type="462c0819:PsiDirectoryNode" />
<item name="hust" type="462c0819:PsiDirectoryNode" />
<item name="dao" type="462c0819:PsiDirectoryNode" />
<item name="factory" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
<item name="UserActionAnalyzePlatform" type="462c0819:PsiDirectoryNode" />
<item name="src" type="462c0819:PsiDirectoryNode" />
<item name="main" type="462c0819:PsiDirectoryNode" />
<item name="java" type="462c0819:PsiDirectoryNode" />
<item name="hust" type="462c0819:PsiDirectoryNode" />
<item name="domain" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
<item name="UserActionAnalyzePlatform" type="462c0819:PsiDirectoryNode" />
<item name="src" type="462c0819:PsiDirectoryNode" />
<item name="main" type="462c0819:PsiDirectoryNode" />
<item name="java" type="462c0819:PsiDirectoryNode" />
<item name="hust" type="462c0819:PsiDirectoryNode" />
<item name="jdbc" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
@ -277,6 +367,36 @@
<item name="hust" type="462c0819:PsiDirectoryNode" />
<item name="util" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
<item name="UserActionAnalyzePlatform" type="462c0819:PsiDirectoryNode" />
<item name="src" type="462c0819:PsiDirectoryNode" />
<item name="test" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
<item name="UserActionAnalyzePlatform" type="462c0819:PsiDirectoryNode" />
<item name="src" type="462c0819:PsiDirectoryNode" />
<item name="test" type="462c0819:PsiDirectoryNode" />
<item name="java" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
<item name="UserActionAnalyzePlatform" type="462c0819:PsiDirectoryNode" />
<item name="src" type="462c0819:PsiDirectoryNode" />
<item name="test" type="462c0819:PsiDirectoryNode" />
<item name="java" type="462c0819:PsiDirectoryNode" />
<item name="hust" type="462c0819:PsiDirectoryNode" />
</path>
<path>
<item name="UserActionAnalyzePlatform" type="b2602c69:ProjectViewProjectNode" />
<item name="UserActionAnalyzePlatform" type="462c0819:PsiDirectoryNode" />
<item name="src" type="462c0819:PsiDirectoryNode" />
<item name="test" type="462c0819:PsiDirectoryNode" />
<item name="java" type="462c0819:PsiDirectoryNode" />
<item name="hust" type="462c0819:PsiDirectoryNode" />
<item name="dao" type="462c0819:PsiDirectoryNode" />
</path>
</expand>
<select />
</subPane>
@ -319,7 +439,7 @@
</list>
</option>
</component>
<component name="RunManager" selected="Application.UserVisitAnalyze">
<component name="RunManager" selected="JUnit.SessionAggrDao.test">
<configuration default="true" type="Applet" factoryName="Applet">
<option name="HTML_USED" value="false" />
<option name="WIDTH" value="400" />
@ -385,19 +505,19 @@
<envs />
<patterns />
</configuration>
<configuration name="JDBCHelperTest.testBatch" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<configuration name="ParamUtilsTest.test2" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<extension name="coverage" enabled="false" merge="false" sample_coverage="true" runner="idea">
<pattern>
<option name="PATTERN" value="cn.edu.hust.jdbc.*" />
<option name="PATTERN" value="cn.edu.hust.utils.*" />
<option name="ENABLED" value="true" />
</pattern>
</extension>
<module name="UserActionAnalyzePlatform" />
<option name="ALTERNATIVE_JRE_PATH_ENABLED" value="false" />
<option name="ALTERNATIVE_JRE_PATH" />
<option name="PACKAGE_NAME" value="cn.edu.hust.jdbc" />
<option name="MAIN_CLASS_NAME" value="cn.edu.hust.jdbc.JDBCHelperTest" />
<option name="METHOD_NAME" value="testBatch" />
<option name="PACKAGE_NAME" value="cn.edu.hust.utils" />
<option name="MAIN_CLASS_NAME" value="cn.edu.hust.utils.ParamUtilsTest" />
<option name="METHOD_NAME" value="test2" />
<option name="TEST_OBJECT" value="method" />
<option name="VM_PARAMETERS" value="-ea" />
<option name="PARAMETERS" />
@ -410,19 +530,19 @@
<envs />
<patterns />
</configuration>
<configuration name="ParamUtilsTest.test2" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<configuration name="SessionAggrDao.test" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
<extension name="coverage" enabled="false" merge="false" sample_coverage="true" runner="idea">
<pattern>
<option name="PATTERN" value="cn.edu.hust.utils.*" />
<option name="PATTERN" value="cn.edu.hust.dao.*" />
<option name="ENABLED" value="true" />
</pattern>
</extension>
<module name="UserActionAnalyzePlatform" />
<option name="ALTERNATIVE_JRE_PATH_ENABLED" value="false" />
<option name="ALTERNATIVE_JRE_PATH" />
<option name="PACKAGE_NAME" value="cn.edu.hust.utils" />
<option name="MAIN_CLASS_NAME" value="cn.edu.hust.utils.ParamUtilsTest" />
<option name="METHOD_NAME" value="test2" />
<option name="PACKAGE_NAME" value="cn.edu.hust.dao" />
<option name="MAIN_CLASS_NAME" value="cn.edu.hust.dao.SessionAggrDao" />
<option name="METHOD_NAME" value="test" />
<option name="TEST_OBJECT" value="method" />
<option name="VM_PARAMETERS" value="-ea" />
<option name="PARAMETERS" />
@ -521,19 +641,19 @@
<predefined_log_file id="idea.log" enabled="true" />
</configuration>
<list size="5">
<item index="0" class="java.lang.String" itemvalue="JUnit.JDBCHelperTest.testBatch" />
<item index="1" class="java.lang.String" itemvalue="JUnit.TaskDaoTest.testDao" />
<item index="2" class="java.lang.String" itemvalue="JUnit.FastJsonTest.test1" />
<item index="3" class="java.lang.String" itemvalue="Application.UserVisitAnalyze" />
<item index="4" class="java.lang.String" itemvalue="JUnit.ParamUtilsTest.test2" />
<item index="0" class="java.lang.String" itemvalue="JUnit.TaskDaoTest.testDao" />
<item index="1" class="java.lang.String" itemvalue="JUnit.FastJsonTest.test1" />
<item index="2" class="java.lang.String" itemvalue="Application.UserVisitAnalyze" />
<item index="3" class="java.lang.String" itemvalue="JUnit.ParamUtilsTest.test2" />
<item index="4" class="java.lang.String" itemvalue="JUnit.SessionAggrDao.test" />
</list>
<recent_temporary>
<list size="5">
<item index="0" class="java.lang.String" itemvalue="Application.UserVisitAnalyze" />
<item index="1" class="java.lang.String" itemvalue="JUnit.ParamUtilsTest.test2" />
<item index="2" class="java.lang.String" itemvalue="JUnit.TaskDaoTest.testDao" />
<item index="3" class="java.lang.String" itemvalue="JUnit.FastJsonTest.test1" />
<item index="4" class="java.lang.String" itemvalue="JUnit.JDBCHelperTest.testBatch" />
<item index="0" class="java.lang.String" itemvalue="JUnit.SessionAggrDao.test" />
<item index="1" class="java.lang.String" itemvalue="Application.UserVisitAnalyze" />
<item index="2" class="java.lang.String" itemvalue="JUnit.ParamUtilsTest.test2" />
<item index="3" class="java.lang.String" itemvalue="JUnit.TaskDaoTest.testDao" />
<item index="4" class="java.lang.String" itemvalue="JUnit.FastJsonTest.test1" />
</list>
</recent_temporary>
</component>
@ -553,7 +673,7 @@
<workItem from="1529588426161" duration="1034000" />
<workItem from="1529590333052" duration="2564000" />
<workItem from="1529630336674" duration="15098000" />
<workItem from="1529666057370" duration="10578000" />
<workItem from="1529666057370" duration="13151000" />
</task>
<task id="LOCAL-00001" summary="1.环境搭建完成&#10;2.相关的工具类编写完成&#10;3.配置文件管理类编写完成">
<created>1529592741848</created>
@ -573,9 +693,6 @@
<servers />
</component>
<component name="TestHistory">
<history-entry file="JDBCHelperTest_testQuery - 2018.06.22 at 11h 40m 05s.xml">
<configuration name="JDBCHelperTest.testQuery" configurationId="JUnit" />
</history-entry>
<history-entry file="ParamUtilsTest_test2 - 2018.06.22 at 20h 22m 02s.xml">
<configuration name="ParamUtilsTest.test2" configurationId="JUnit" />
</history-entry>
@ -588,6 +705,9 @@
<history-entry file="ParamUtilsTest_test2 - 2018.06.22 at 20h 27m 46s.xml">
<configuration name="ParamUtilsTest.test2" configurationId="JUnit" />
</history-entry>
<history-entry file="SessionAggrDao_test - 2018.06.22 at 23h 11m 57s.xml">
<configuration name="SessionAggrDao.test" configurationId="JUnit" />
</history-entry>
<history-entry file="TaskDaoTest_testDao - 2018.06.22 at 14h 48m 43s.xml">
<configuration name="TaskDaoTest.testDao" configurationId="JUnit" />
</history-entry>
@ -605,7 +725,7 @@
</history-entry>
</component>
<component name="TimeTrackingManager">
<option name="totallyTimeSpent" value="29274000" />
<option name="totallyTimeSpent" value="31847000" />
</component>
<component name="ToolWindowManager">
<frame x="0" y="0" width="1440" height="900" extended-state="0" />
@ -894,18 +1014,6 @@
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="133">
<caret line="7" column="13" lean-forward="false" selection-start-line="7" selection-start-column="13" selection-end-line="7" selection-end-column="13" />
<folding>
<element signature="imports" expanded="false" />
<element signature="e#222#223#0" expanded="false" />
<element signature="e#262#263#0" expanded="false" />
</folding>
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/test/java/cn/edu/hust/json/FastJsonTest.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="133">
@ -1089,20 +1197,130 @@
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/SessionAggrStatDao.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="95">
<caret line="5" column="47" lean-forward="false" selection-start-line="5" selection-start-column="47" selection-end-line="5" selection-end-column="47" />
<folding />
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/domain/SessionAggrStat.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="58">
<caret line="114" column="27" lean-forward="false" selection-start-line="114" selection-start-column="27" selection-end-line="114" selection-end-column="27" />
<folding>
<element signature="e#2125#2126#0" expanded="true" />
<element signature="e#2154#2155#0" expanded="true" />
<element signature="e#2196#2197#0" expanded="true" />
<element signature="e#2232#2233#0" expanded="true" />
<element signature="e#2269#2270#0" expanded="true" />
<element signature="e#2304#2305#0" expanded="true" />
<element signature="e#2358#2359#0" expanded="true" />
<element signature="e#2401#2402#0" expanded="true" />
<element signature="e#2446#2447#0" expanded="true" />
<element signature="e#2487#2488#0" expanded="true" />
<element signature="e#2555#2556#0" expanded="true" />
<element signature="e#2615#2616#0" expanded="true" />
<element signature="e#2660#2661#0" expanded="true" />
<element signature="e#2701#2702#0" expanded="true" />
<element signature="e#2769#2770#0" expanded="true" />
<element signature="e#2829#2830#0" expanded="true" />
<element signature="e#2874#2875#0" expanded="true" />
<element signature="e#2915#2916#0" expanded="true" />
<element signature="e#2983#2984#0" expanded="true" />
<element signature="e#3043#3044#0" expanded="true" />
<element signature="e#3090#3091#0" expanded="true" />
<element signature="e#3133#3134#0" expanded="true" />
<element signature="e#3316#3317#0" expanded="true" />
<element signature="e#3359#3360#0" expanded="true" />
<element signature="e#3540#3541#0" expanded="true" />
<element signature="e#3581#3582#0" expanded="true" />
<element signature="e#3649#3650#0" expanded="true" />
<element signature="e#3709#3710#0" expanded="true" />
<element signature="e#3755#3756#0" expanded="true" />
<element signature="e#3797#3798#0" expanded="true" />
<element signature="e#3865#3866#0" expanded="true" />
<element signature="e#3926#3927#0" expanded="true" />
<element signature="e#3973#3974#0" expanded="true" />
<element signature="e#4016#4017#0" expanded="true" />
<element signature="e#4195#4196#0" expanded="true" />
<element signature="e#4234#4235#0" expanded="true" />
<element signature="e#4298#4299#0" expanded="true" />
<element signature="e#4354#4355#0" expanded="true" />
<element signature="e#4396#4397#0" expanded="true" />
<element signature="e#4434#4435#0" expanded="true" />
<element signature="e#4496#4497#0" expanded="true" />
<element signature="e#4550#4551#0" expanded="true" />
<element signature="e#4592#4593#0" expanded="true" />
<element signature="e#4630#4631#0" expanded="true" />
<element signature="e#4692#4693#0" expanded="true" />
<element signature="e#4746#4747#0" expanded="true" />
<element signature="e#4788#4789#0" expanded="true" />
<element signature="e#4826#4827#0" expanded="true" />
<element signature="e#4888#4889#0" expanded="true" />
<element signature="e#4942#4943#0" expanded="true" />
<element signature="e#4986#4987#0" expanded="true" />
<element signature="e#5026#5027#0" expanded="true" />
<element signature="e#5092#5093#0" expanded="true" />
<element signature="e#5150#5151#0" expanded="true" />
<element signature="e#5194#5195#0" expanded="true" />
<element signature="e#5234#5235#0" expanded="true" />
<element signature="e#5300#5301#0" expanded="true" />
<element signature="e#5358#5359#0" expanded="true" />
<element signature="e#5399#5400#0" expanded="true" />
<element signature="e#5436#5437#0" expanded="true" />
<element signature="e#5496#5497#0" expanded="true" />
<element signature="e#5548#5549#0" expanded="true" />
</folding>
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/impl/SessionAggrStatDaoImpl.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="342">
<caret line="18" column="58" lean-forward="false" selection-start-line="18" selection-start-column="58" selection-end-line="18" selection-end-column="58" />
<folding>
<element signature="imports" expanded="true" />
</folding>
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/dao/factory/DaoFactory.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="247">
<caret line="19" column="44" lean-forward="false" selection-start-line="19" selection-start-column="44" selection-end-line="19" selection-end-column="44" />
<folding>
<element signature="e#425#426#0" expanded="true" />
<element signature="e#476#477#0" expanded="true" />
</folding>
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/test/java/cn/edu/hust/dao/SessionAggrDao.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="152">
<caret line="8" column="18" lean-forward="true" selection-start-line="8" selection-start-column="16" selection-end-line="8" selection-end-column="20" />
<folding>
<element signature="imports" expanded="true" />
</folding>
</state>
</provider>
</entry>
<entry file="file://$PROJECT_DIR$/src/main/java/cn/edu/hust/session/UserVisitAnalyze.java">
<provider selected="true" editor-type-id="text-editor">
<state relative-caret-position="400">
<caret line="304" column="26" lean-forward="false" selection-start-line="304" selection-start-column="26" selection-end-line="304" selection-end-column="26" />
<state relative-caret-position="4652">
<caret line="357" column="0" lean-forward="false" selection-start-line="357" selection-start-column="0" selection-end-line="357" selection-end-column="0" />
<folding>
<element signature="imports" expanded="true" />
<element signature="e#4523#4748#0" expanded="true" />
<element signature="e#4747#4748#0" expanded="true" />
<element signature="e#4978#7719#0" expanded="true" />
<element signature="e#7718#7719#0" expanded="true" />
<element signature="e#7939#8162#0" expanded="true" />
<element signature="e#8161#8162#0" expanded="true" />
<element signature="e#8415#9429#0" expanded="true" />
<element signature="e#9428#9429#0" expanded="true" />
<element signature="e#4629#4854#0" expanded="true" />
<element signature="e#4853#4854#0" expanded="true" />
<element signature="e#5084#7825#0" expanded="true" />
<element signature="e#7824#7825#0" expanded="true" />
<element signature="e#8045#8268#0" expanded="true" />
<element signature="e#8267#8268#0" expanded="true" />
<element signature="e#8521#9535#0" expanded="true" />
<element signature="e#9534#9535#0" expanded="true" />
</folding>
</state>
</provider>

7
src/main/java/cn/edu/hust/dao/SessionAggrStatDao.java
Unescape View File

@ -0,0 +1,7 @@
package cn.edu.hust.dao;
import cn.edu.hust.domain.SessionAggrStat;
public interface SessionAggrStatDao {
void insert(SessionAggrStat sessionAggrStat);
}

7
src/main/java/cn/edu/hust/dao/factory/DaoFactory.java
Unescape View File

@ -1,6 +1,8 @@
package cn.edu.hust.dao.factory;
import cn.edu.hust.dao.SessionAggrStatDao;
import cn.edu.hust.dao.TaskDao;
import cn.edu.hust.dao.impl.SessionAggrStatDaoImpl;
import cn.edu.hust.dao.impl.TaskDaoImpl;
public class DaoFactory {
@ -12,4 +14,9 @@ public class DaoFactory {
{
return new TaskDaoImpl();
}
public static SessionAggrStatDao getSessionAggrStatDao()
{
return new SessionAggrStatDaoImpl();
}
}

21
src/main/java/cn/edu/hust/dao/impl/SessionAggrStatDaoImpl.java
Unescape View File

@ -0,0 +1,21 @@
package cn.edu.hust.dao.impl;
import cn.edu.hust.dao.SessionAggrStatDao;
import cn.edu.hust.domain.SessionAggrStat;
import cn.edu.hust.jdbc.JDBCHelper;
public class SessionAggrStatDaoImpl implements SessionAggrStatDao{
@Override
public void insert(SessionAggrStat sessionAggrStat) {
String sql="insert into session_aggr_stat values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
Object[] params={sessionAggrStat.getTaskId(),sessionAggrStat.getSessionCount(),sessionAggrStat.getVisit_Length_1s_3s(),
sessionAggrStat.getVisit_Length_4s_6s(),sessionAggrStat.getVisit_Length_7s_9s(),
sessionAggrStat.getVisit_Length_10s_30s(),sessionAggrStat.getVisit_Length_30s_60s(),
sessionAggrStat.getVisit_Length_1m_3m(),sessionAggrStat.getVisit_Length_3m_10m()
,sessionAggrStat.getVisit_Length_10m_30m(),sessionAggrStat.getVisit_Length_30m(),
sessionAggrStat.getStep_Length_1_3(),sessionAggrStat.getStep_Length_4_6(),sessionAggrStat.getStep_Length_7_9(),
sessionAggrStat.getStep_Length_7_9(),sessionAggrStat.getStep_Length_10_30(),
sessionAggrStat.getStep_Length_30_60()};
JDBCHelper.getInstance().excuteUpdate(sql,params);
}
}

182
src/main/java/cn/edu/hust/domain/SessionAggrStat.java
Unescape View File

@ -0,0 +1,182 @@
package cn.edu.hust.domain;
import java.io.Serializable;
public class SessionAggrStat implements Serializable {
private Long taskId;
private Long SessionCount;
private double visit_Length_1s_3s;
private double visit_Length_4s_6s;
private double visit_Length_7s_9s;
private double visit_Length_10s_30s;
private double visit_Length_30s_60s;
private double visit_Length_1m_3m;
private double visit_Length_3m_10m;
private double visit_Length_10m_30m;
private double visit_Length_30m;
private double step_Length_1_3;
private double step_Length_4_6;
private double step_Length_7_9;
private double step_Length_10_30;
private double step_Length_30_60;
private double step_Length_60;
public SessionAggrStat() {
}
public void set(Long taskId, Long sessionCount, double visit_Length_1s_3s, double visit_Length_4s_6s, double visit_Length_7s_9s, double visit_Length_10s_30s, double visit_Length_30s_60s, double visit_Length_1m_3m, double visit_Length_3m_10m, double visit_Length_10m_30m, double visit_Length_30m, double step_Length_1_3, double step_Length_4_6, double step_Length_7_9, double step_Length_10_30, double step_Length_30_60, double step_Length_60) {
this.taskId = taskId;
SessionCount = sessionCount;
this.visit_Length_1s_3s = visit_Length_1s_3s;
this.visit_Length_4s_6s = visit_Length_4s_6s;
this.visit_Length_7s_9s = visit_Length_7s_9s;
this.visit_Length_10s_30s = visit_Length_10s_30s;
this.visit_Length_30s_60s = visit_Length_30s_60s;
this.visit_Length_1m_3m = visit_Length_1m_3m;
this.visit_Length_3m_10m = visit_Length_3m_10m;
this.visit_Length_10m_30m = visit_Length_10m_30m;
this.visit_Length_30m = visit_Length_30m;
this.step_Length_1_3 = step_Length_1_3;
this.step_Length_4_6 = step_Length_4_6;
this.step_Length_7_9 = step_Length_7_9;
this.step_Length_10_30 = step_Length_10_30;
this.step_Length_30_60 = step_Length_30_60;
this.step_Length_60 = step_Length_60;
}
public Long getTaskId() {
return taskId;
}
public void setTaskId(Long taskId) {
this.taskId = taskId;
}
public Long getSessionCount() {
return SessionCount;
}
public void setSessionCount(Long sessionCount) {
SessionCount = sessionCount;
}
public double getVisit_Length_1s_3s() {
return visit_Length_1s_3s;
}
public void setVisit_Length_1s_3s(double visit_Length_1s_3s) {
this.visit_Length_1s_3s = visit_Length_1s_3s;
}
public double getVisit_Length_4s_6s() {
return visit_Length_4s_6s;
}
public void setVisit_Length_4s_6s(double visit_Length_4s_6s) {
this.visit_Length_4s_6s = visit_Length_4s_6s;
}
public double getVisit_Length_7s_9s() {
return visit_Length_7s_9s;
}
public void setVisit_Length_7s_9s(double visit_Length_7s_9s) {
this.visit_Length_7s_9s = visit_Length_7s_9s;
}
public double getVisit_Length_10s_30s() {
return visit_Length_10s_30s;
}
public void setVisit_Length_10s_30s(double visit_Length_10s_30s) {
this.visit_Length_10s_30s = visit_Length_10s_30s;
}
public double getVisit_Length_30s_60s() {
return visit_Length_30s_60s;
}
public void setVisit_Length_30s_60s(double visit_Length_30s_60s) {
this.visit_Length_30s_60s = visit_Length_30s_60s;
}
public double getVisit_Length_1m_3m() {
return visit_Length_1m_3m;
}
public void setVisit_Length_1m_3m(double visit_Length_1m_3m) {
this.visit_Length_1m_3m = visit_Length_1m_3m;
}
public double getVisit_Length_3m_10m() {
return visit_Length_3m_10m;
}
public void setVisit_Legth_3m_10m(double visit_Legth_3m_10m) {
this.visit_Length_3m_10m = visit_Legth_3m_10m;
}
public double getVisit_Length_10m_30m() {
return visit_Length_10m_30m;
}
public void setVisit_Length_10m_30m(double visit_Length_10m_30m) {
this.visit_Length_10m_30m = visit_Length_10m_30m;
}
public double getVisit_Length_30m() {
return visit_Length_30m;
}
public void setVisit_Length_30m(double visit_Length_30m) {
this.visit_Length_30m = visit_Length_30m;
}
public double getStep_Length_1_3() {
return step_Length_1_3;
}
public void setStep_Length_1_3(double step_Length_1_3) {
this.step_Length_1_3 = step_Length_1_3;
}
public double getStep_Length_4_6() {
return step_Length_4_6;
}
public void setStep_Length_4_6(double step_Length_4_6) {
this.step_Length_4_6 = step_Length_4_6;
}
public double getStep_Length_7_9() {
return step_Length_7_9;
}
public void setStep_Length_7_9(double step_Length_7_9) {
this.step_Length_7_9 = step_Length_7_9;
}
public double getStep_Length_10_30() {
return step_Length_10_30;
}
public void setStep_Length_10_30(double step_Length_10_30) {
this.step_Length_10_30 = step_Length_10_30;
}
public double getStep_Length_30_60() {
return step_Length_30_60;
}
public void setStep_Length_30_60(double step_Length_30_60) {
this.step_Length_30_60 = step_Length_30_60;
}
public double getStep_Length_60() {
return step_Length_60;
}
public void setStep_Length_60(double step_Length_60) {
this.step_Length_60 = step_Length_60;
}
}

7
src/main/java/cn/edu/hust/session/UserVisitAnalyze.java
Unescape View File

@ -89,12 +89,15 @@ public class UserVisitAnalyze {
* 一场灾难。
*/
//计算各个session占比,并写入MySQL
calculateAndPersist(sessionAggrStatAccumulator.value(),taskId);
//关闭spark上下文
context.close();
}
/**
* 用于判断是否是生产环境
* @param sc
@ -349,4 +352,8 @@ public class UserVisitAnalyze {
});
return filteredSessionRDD;
}
private static void calculateAndPersist(String value,Long taskId) {
}
}

15
src/test/java/cn/edu/hust/dao/SessionAggrDao.java
Unescape View File

@ -0,0 +1,15 @@
package cn.edu.hust.dao;
import cn.edu.hust.dao.factory.DaoFactory;
import cn.edu.hust.domain.SessionAggrStat;
import org.junit.Test;
public class SessionAggrDao {
@Test
public void test()
{
SessionAggrStat sessionAggrStat=new SessionAggrStat();
sessionAggrStat.set(1L,100L,1,2,3,4,5,6,7,8,9,0,10,11,12,13,14);
DaoFactory.getSessionAggrStatDao().insert(sessionAggrStat);
}
}
Write Preview
Loading…
Cancel
Save