Spark_Kafka_Elastic-源码

[{"title":"（ 80 个子文件 63KB ） Spark_Kafka_Elastic-源码","children":[{"title":"Spark_Kafka_Elastic-master","children":[{"title":"pom.xml <span style='color:#111;'> 634B </span>","children":null,"spread":false},{"title":"ElasticSearch","children":[{"title":"pom.xml <span style='color:#111;'> 1.09KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"elasticsearch","children":[{"title":"practice","children":[{"title":"model","children":[{"title":"Employee.java <span style='color:#111;'> 694B </span>","children":null,"spread":false},{"title":"EmployeeName.java <span style='color:#111;'> 498B </span>","children":null,"spread":false}],"spread":true},{"title":"main","children":[{"title":"ElasticSearchJsonTest.java <span style='color:#111;'> 1.07KB </span>","children":null,"spread":false},{"title":"ElasticSearchSample.java <span style='color:#111;'> 1.74KB </span>","children":null,"spread":false},{"title":"AggregationPractice.java <span style='color:#111;'> 2.02KB </span>","children":null,"spread":false}],"spread":true},{"title":"util","children":[{"title":"ElasticSearchUtil.java <span style='color:#111;'> 4.59KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"readme.md <span style='color:#111;'> 2.68KB </span>","children":null,"spread":false},{"title":"ActivityStreamProcessor","children":[{"title":"pom.xml <span style='color:#111;'> 2.38KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"useractivity","children":[{"title":"spark","children":[{"title":"streaming","children":[{"title":"StreamProcessor.java <span style='color:#111;'> 3.08KB </span>","children":null,"spread":false},{"title":"QuadrantCreator.java <span style='color:#111;'> 1.23KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"model","children":[{"title":"Quadrant.java <span style='color:#111;'> 1.04KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"UserActivityMonitor","children":[{"title":"pom.xml <span style='color:#111;'> 3.23KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"webapp","children":[{"title":"WEB-INF","children":[{"title":"mvc-dispatcher-servlet.xml <span style='color:#111;'> 1.05KB </span>","children":null,"spread":false},{"title":"web.xml <span style='color:#111;'> 860B </span>","children":null,"spread":false},{"title":"jsp","children":[{"title":"welcome.jsp <span style='color:#111;'> 859B </span>","children":null,"spread":false},{"title":"activityview.jsp <span style='color:#111;'> 1013B </span>","children":null,"spread":false},{"title":"index.jsp <span style='color:#111;'> 52B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"resources","children":[{"title":"js","children":[{"title":"activityview.js <span style='color:#111;'> 527B </span>","children":null,"spread":false},{"title":"welcome.js <span style='color:#111;'> 580B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"useractivity","children":[{"title":"elasticsearch","children":[{"title":"service","children":[{"title":"QuadrantService.java <span style='color:#111;'> 3.93KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"kafka","children":[{"title":"producer","children":[{"title":"UserActivityProducer.java <span style='color:#111;'> 2.90KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"controller","children":[{"title":"UserActivityController.java <span style='color:#111;'> 2.24KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".idea","children":[{"title":"uiDesigner.xml <span style='color:#111;'> 8.59KB </span>","children":null,"spread":false},{"title":"misc.xml <span style='color:#111;'> 1.03KB </span>","children":null,"spread":false},{"title":"vcs.xml <span style='color:#111;'> 164B </span>","children":null,"spread":false},{"title":".name <span style='color:#111;'> 19B </span>","children":null,"spread":false},{"title":"copyright","children":[{"title":"profiles_settings.xml <span style='color:#111;'> 74B </span>","children":null,"spread":false}],"spread":true},{"title":"modules.xml <span style='color:#111;'> 278B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 1.29KB </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 53.50KB </span>","children":null,"spread":false},{"title":"libraries","children":[{"title":"Maven__org_springframework_spring_webmvc_3_2_3_RELEASE.xml <span style='color:#111;'> 618B </span>","children":null,"spread":false},{"title":"Maven__org_xerial_snappy_snappy_java_1_1_1_6.xml <span style='color:#111;'> 554B </span>","children":null,"spread":false},{"title":"Maven__aopalliance_aopalliance_1_0.xml <span style='color:#111;'> 502B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_join_4_10_4.xml <span style='color:#111;'> 547B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_beans_3_2_3_RELEASE.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__org_apache_kafka_kafka_clients_0_8_2_1.xml <span style='color:#111;'> 564B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_slf4j_api_1_7_2.xml <span style='color:#111;'> 494B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_context_3_2_3_RELEASE.xml <span style='color:#111;'> 625B </span>","children":null,"spread":false},{"title":"Maven__junit_junit_3_8_1.xml <span style='color:#111;'> 450B </span>","children":null,"spread":false},{"title":"Maven__com_yammer_metrics_metrics_core_2_2_0.xml <span style='color:#111;'> 551B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_queryparser_4_10_4.xml <span style='color:#111;'> 596B </span>","children":null,"spread":false},{"title":"Maven__org_apache_kafka_kafka_2_10_0_8_2_1.xml <span style='color:#111;'> 543B </span>","children":null,"spread":false},{"title":"Maven__org_elasticsearch_elasticsearch_1_5_1.xml <span style='color:#111;'> 554B </span>","children":null,"spread":false},{"title":"Maven__org_scala_lang_scala_library_2_10_4.xml <span style='color:#111;'> 549B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_web_3_2_3_RELEASE.xml <span style='color:#111;'> 597B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_misc_4_10_4.xml <span style='color:#111;'> 547B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_expression_3_2_3_RELEASE.xml <span style='color:#111;'> 646B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_annotations_2_1_4.xml <span style='color:#111;'> 632B </span>","children":null,"spread":false},{"title":"Maven__org_ow2_asm_asm_4_1.xml <span style='color:#111;'> 446B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_suggest_4_10_4.xml <span style='color:#111;'> 568B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_spatial_4_10_4.xml <span style='color:#111;'> 568B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_core_3_2_3_RELEASE.xml <span style='color:#111;'> 604B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_queries_4_10_4.xml <span style='color:#111;'> 568B </span>","children":null,"spread":false},{"title":"Maven__org_antlr_antlr_runtime_3_5.xml <span style='color:#111;'> 508B </span>","children":null,"spread":false},{"title":"Maven__com_101tec_zkclient_0_3.xml <span style='color:#111;'> 477B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_analyzers_common_4_10_4.xml <span style='color:#111;'> 631B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_grouping_4_10_4.xml <span style='color:#111;'> 575B </span>","children":null,"spread":false},{"title":"Maven__commons_logging_commons_logging_1_1_1.xml <span style='color:#111;'> 560B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_databind_2_1_4.xml <span style='color:#111;'> 611B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_core_4_10_4.xml <span style='color:#111;'> 547B </span>","children":null,"spread":false},{"title":"Maven__org_codehaus_jackson_jackson_core_asl_1_9_13.xml <span style='color:#111;'> 594B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_highlighter_4_10_4.xml <span style='color:#111;'> 596B </span>","children":null,"spread":false},{"title":"Maven__net_jpountz_lz4_lz4_1_2_0.xml <span style='color:#111;'> 476B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_sandbox_4_10_4.xml <span style='color:#111;'> 568B </span>","children":null,"spread":false},{"title":"Maven__org_apache_zookeeper_zookeeper_3_4_6.xml <span style='color:#111;'> 538B </span>","children":null,"spread":false},{"title":"Maven__com_fasterxml_jackson_core_jackson_core_2_3_3.xml <span style='color:#111;'> 583B </span>","children":null,"spread":false},{"title":"Maven__org_apache_lucene_lucene_memory_4_10_4.xml <span style='color:#111;'> 561B </span>","children":null,"spread":false},{"title":"Maven__org_codehaus_jackson_jackson_mapper_asl_1_9_13.xml <span style='color:#111;'> 608B </span>","children":null,"spread":false},{"title":"Maven__com_spatial4j_spatial4j_0_4_1.xml <span style='color:#111;'> 510B </span>","children":null,"spread":false},{"title":"Maven__org_slf4j_slf4j_log4j12_1_6_1.xml <span style='color:#111;'> 522B </span>","children":null,"spread":false},{"title":"Maven__jline_jline_0_9_94.xml <span style='color:#111;'> 457B </span>","children":null,"spread":false},{"title":"Maven__log4j_log4j_1_2_16.xml <span style='color:#111;'> 457B </span>","children":null,"spread":false},{"title":"Maven__io_netty_netty_3_7_0_Final.xml <span style='color:#111;'> 504B </span>","children":null,"spread":false},{"title":"Maven__com_clairvoyantsoft_elasticsearchpractice_1_0_SNAPSHOT.xml <span style='color:#111;'> 667B </span>","children":null,"spread":false},{"title":"Maven__net_sf_jopt_simple_jopt_simple_3_2.xml <span style='color:#111;'> 530B </span>","children":null,"spread":false},{"title":"Maven__javax_servlet_jstl_1_2.xml <span style='color:#111;'> 461B </span>","children":null,"spread":false},{"title":"Maven__org_ow2_asm_asm_commons_4_1.xml <span style='color:#111;'> 502B </span>","children":null,"spread":false},{"title":"Maven__org_springframework_spring_aop_3_2_3_RELEASE.xml <span style='color:#111;'> 597B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}]