refine ui

Author: zmyzheng

TweetMapBackend/readMe.txt

@@ -1,5 +1,12 @@
-curl -X PUT "https://search-database-yp7n3mmtmp6fybvuhvst6o6bxa.us-west-2.es.amazonaws.com/twitters/twitterEntities/_mapping" -d '{
-   "twitterEntities" : {
+
+curl -X PUT "https://search-database-yp7n3mmtmp6fybvuhvst6o6bxa.us-west-2.es.amazonaws.com/stream" -d '{
+   "index": {
+ }}'
+
+
+
+curl -X PUT "https://search-database-yp7n3mmtmp6fybvuhvst6o6bxa.us-west-2.es.amazonaws.com/stream/tweets/_mapping" -d '{
+   "tweets" : {
    "properties" : {
        "createdAt" : { "type" : "string" },
        "location" : { "type" : "geo_point"},
@@ -10,27 +17,3 @@ curl -X PUT "https://search-database-yp7n3mmtmp6fybvuhvst6o6bxa.us-west-2.es.ama
        "username":{"type" : "string" }
    }}
 }'
-
-
-curl -X PUT "https://search-database-yp7n3mmtmp6fybvuhvst6o6bxa.us-west-2.es.amazonaws.com/twitters" -d '{
-   "index": {
- }}'
-
-
- -------------------
- curl -X PUT "https://search-daybvuhvst6o6bxa.us-west-2.es.amazonaws.com/twitters" -d '{
- >    "index": {
- >  }}'
- {"acknowledged":true,"shards_acknowledged":true}Zmy-Apple@MingyangdeMacBook-Pro:~$ cybvuhvst6o6bxa.us-west-2.es.amazonaws.com/twitters/twitterEntities/_mapping" -d '{
-    "twitterEntities" : {
-    "properties" : {
-        "createdAt" : { "type" : "string" },
-        "location" : { "type" : "geo_point"},
-        "keyword": { "type" : "string" },
-        "place": {"type" : "string" },
-        "text": {"type" : "string" },
-        "tweetId": { "type": "long" },
-        "username":{"type" : "string" }
-    }}
- }'
- {"acknowledged":true}Zmy-Apple@MingyangdeMacBook-Pro:~$

TweetMapBackend/src/main/java/hello/Application.java

@@ -11,6 +11,7 @@
 public class Application {
     public static void main(String[] args) {
         SpringApplication.run(Application.class, args);
+//
 //        ClassPathXmlApplicationContext context =
 //                new ClassPathXmlApplicationContext("applicationContext.xml");
 //
@@ -19,6 +20,8 @@ public static void main(String[] args) {
 //
 //        twitterStreamHandler.inject();
 
+
+
 //        ElasticSearchService elasticSearchService =
 //                context.getBean("elasticSearchService", ElasticSearchService.class);
 //

TweetMapBackend/src/main/java/hello/ElasticSearchService.java

@@ -28,7 +28,7 @@ public class ElasticSearchService {
 
     private JestClient client = null;
 
-    private static long docId = 2877;
+    private static long docId = System.currentTimeMillis();
 
 
     @Autowired
@@ -43,7 +43,8 @@ public ElasticSearchService(@Value("${es.endpoint}") String endPoint) {
 
     public void indexDocument(TweetEntity tweetEntity) {
         Index index = new Index.Builder(tweetEntity).index(INDEX)
-                .type(TYPE).id(docId + "").build();
+                .type(TYPE)//.id(docId + "")
+                .build();
         try {
 
             client.execute(index);

TweetMapBackend/src/main/java/hello/TwitterStreamHandler.java

@@ -28,7 +28,7 @@ public class TwitterStreamHandler {
     @Value("${key.accessTokenSecret}")
     private String accessTokenSecret;
 
-    private String[] keywords = {"job", "love", "game", "fashion", "trump", "New York","fashion", "food", "lol","hilary", "hello"};
+    private String[] keywords = { "sports", "family", "movie", "google", "apple", "amazon", "fashion", "food","song", "study"};
 
     public void inject()  {
         ConfigurationBuilder cb = new ConfigurationBuilder();
@@ -60,8 +60,11 @@ public void onStatus(Status status) {
                             keyword = keywords[i];
                         }
                     }
-                    TweetEntity tweetEntity = new TweetEntity(keyword, username, place, longitude, latitude, tweetId, text, createdAt);
-                    elasticSearchService.indexDocument(tweetEntity);
+                    if (keyword != null) {
+                        TweetEntity tweetEntity = new TweetEntity(keyword, username, place, longitude, latitude, tweetId, text, createdAt);
+                        elasticSearchService.indexDocument(tweetEntity);
+                    }
+
 
                 }
             }

TweetMapBackend/src/main/resources/application.properties

@@ -4,5 +4,5 @@ key.accessToken=827004953310949377-6ZUtvrRUClLDvUgnaBArSSM71j09AD6
 key.accessTokenSecret=Ni0TPMbYNhh13wC470rzxGE7bhrPhpkv4onueZfjoCvpk
 
 es.endpoint=https://search-database-yp7n3mmtmp6fybvuhvst6o6bxa.us-west-2.es.amazonaws.com
-es.index=twitters
-es.type=twitterEntities
+es.index=stream
+es.type=tweets