diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index e65eb74..b1bb51c 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -2,12 +2,13 @@
 <project version="4">
   <component name="ChangeListManager">
     <list default="true" id="4fbb4744-8af8-4772-9c4a-f908e21548f3" name="Default" comment="">
-      <change afterPath="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/test.sql" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/.idea/scala_compiler.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/scala_compiler.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/balance_stats.sql" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/gender_group_by_sql.sql" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/gender_stats_sql.sql" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/show_all_sql.sql" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/es/SparkToES.scala" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/SparkSQL/pom.xml" beforeDir="false" afterPath="$PROJECT_DIR$/SparkSQL/pom.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/utils/SparkSqlUtils.scala" beforeDir="false" afterPath="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/utils/SparkSqlUtils.scala" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala" beforeDir="false" afterPath="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala" afterDir="false" />
     </list>
     <ignored path="$PROJECT_DIR$/Hbase/target/" />
     <ignored path="$PROJECT_DIR$/Kafka/target/" />
@@ -48,11 +49,11 @@
   </component>
   <component name="FileEditorManager">
     <leaf SIDE_TABS_SIZE_LIMIT_KEY="300">
-      <file leaf-file-name="Spark_SQL_3.scala" pinned="false" current-in-tab="true">
+      <file leaf-file-name="Spark_SQL_3.scala" pinned="false" current-in-tab="false">
         <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala">
           <provider selected="true" editor-type-id="text-editor">
-            <state relative-caret-position="339">
-              <caret line="44" column="98" selection-start-line="44" selection-start-column="98" selection-end-line="44" selection-end-column="98" />
+            <state relative-caret-position="541">
+              <caret line="52" column="18" selection-start-line="52" selection-start-column="8" selection-end-line="52" selection-end-column="18" />
               <folding>
                 <element signature="e#28#63#0" expanded="true" />
               </folding>
@@ -60,6 +61,36 @@
           </provider>
         </entry>
       </file>
+      <file leaf-file-name="SparkToES.scala" pinned="false" current-in-tab="true">
+        <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/es/SparkToES.scala">
+          <provider selected="true" editor-type-id="text-editor">
+            <state relative-caret-position="440">
+              <caret line="52" column="66" selection-start-line="52" selection-start-column="66" selection-end-line="52" selection-end-column="66" />
+              <folding>
+                <element signature="e#21#56#0" expanded="true" />
+              </folding>
+            </state>
+          </provider>
+        </entry>
+      </file>
+      <file leaf-file-name="package.class" pinned="false" current-in-tab="false">
+        <entry file="jar://$PROJECT_DIR$/../../../E_lib/local_repository/org/elasticsearch/elasticsearch-spark-20_2.11/5.5.2/elasticsearch-spark-20_2.11-5.5.2.jar!/org/elasticsearch/spark/sql/package.class">
+          <provider selected="true" editor-type-id="text-editor">
+            <state relative-caret-position="221">
+              <caret line="13" column="8" selection-start-line="13" selection-start-column="8" selection-end-line="13" selection-end-column="8" />
+            </state>
+          </provider>
+        </entry>
+      </file>
+      <file leaf-file-name="gender_group_by_sql.sql" pinned="false" current-in-tab="false">
+        <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/sql/gender_group_by_sql.sql">
+          <provider selected="true" editor-type-id="text-editor">
+            <state relative-caret-position="83">
+              <caret line="5" column="4" lean-forward="true" selection-start-line="5" selection-start-column="4" selection-end-line="5" selection-end-column="4" />
+            </state>
+          </provider>
+        </entry>
+      </file>
     </leaf>
   </component>
   <component name="FileTemplateManagerImpl">
@@ -89,12 +120,6 @@
   <component name="IdeDocumentHistory">
     <option name="CHANGED_PATHS">
       <list>
-        <option value="$PROJECT_DIR$/MapReduce/src/main/java/com/c503/mr/job/MapReduce_Multi_Job.java" />
-        <option value="$PROJECT_DIR$/MapReduce/src/main/java/com/c503/mr/job/MapReduce_Parameter_Job.java" />
-        <option value="$PROJECT_DIR$/MapReduce/src/main/java/com/c503/mr/job/MapReduce_Sort_Job.java" />
-        <option value="$PROJECT_DIR$/MapReduce/src/main/java/com/c503/mr/job/MapReduce_Split_Job.java" />
-        <option value="$PROJECT_DIR$/SparkStreaming/pom.xml" />
-        <option value="$PROJECT_DIR$/SparkStreaming/src/main/java/com/scriptFile.scala" />
         <option value="$PROJECT_DIR$/SparkStreaming/src/main/java/com/utils/CreateFiles.scala" />
         <option value="$PROJECT_DIR$/SparkStreaming/src/main/java/com/utils/StreamConf.scala" />
         <option value="$PROJECT_DIR$/SparkStreaming/src/main/java/com/utils/ConfManager.scala" />
@@ -133,13 +158,19 @@
         <option value="$PROJECT_DIR$/.gitignore" />
         <option value="$PROJECT_DIR$/SparkCore/pom.xml" />
         <option value="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_2.scala" />
-        <option value="$PROJECT_DIR$/SparkSQL/src/main/resources/person.json" />
         <option value="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_1.scala" />
         <option value="$PROJECT_DIR$/SparkSQL/pom.xml" />
         <option value="$PROJECT_DIR$/SparkSQL/src/main/resources/person.txt" />
         <option value="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/utils/SparkSqlUtils.scala" />
         <option value="$PROJECT_DIR$/SparkSQL/src/main/resources/warehouse/test.sql" />
+        <option value="$PROJECT_DIR$/SparkSQL/src/main/resources/person.json" />
         <option value="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala" />
+        <option value="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/show_all_sql.sql" />
+        <option value="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/es/gender_stats_sql.sql" />
+        <option value="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/balance_stats.sql" />
+        <option value="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/es/city_stats_sql.sql" />
+        <option value="$PROJECT_DIR$/SparkSQL/src/main/resources/sql/gender_group_by_sql.sql" />
+        <option value="$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/es/SparkToES.scala" />
       </list>
     </option>
   </component>
@@ -221,23 +252,6 @@
               <item name="src" type="462c0819:PsiDirectoryNode" />
               <item name="main" type="462c0819:PsiDirectoryNode" />
             </path>
-            <path>
-              <item name="Hadoop-Learning" type="b2602c69:ProjectViewProjectNode" />
-              <item name="HadoopLearning" type="462c0819:PsiDirectoryNode" />
-              <item name="SparkSQL" type="462c0819:PsiDirectoryNode" />
-              <item name="src" type="462c0819:PsiDirectoryNode" />
-              <item name="main" type="462c0819:PsiDirectoryNode" />
-              <item name="resources" type="462c0819:PsiDirectoryNode" />
-            </path>
-            <path>
-              <item name="Hadoop-Learning" type="b2602c69:ProjectViewProjectNode" />
-              <item name="HadoopLearning" type="462c0819:PsiDirectoryNode" />
-              <item name="SparkSQL" type="462c0819:PsiDirectoryNode" />
-              <item name="src" type="462c0819:PsiDirectoryNode" />
-              <item name="main" type="462c0819:PsiDirectoryNode" />
-              <item name="resources" type="462c0819:PsiDirectoryNode" />
-              <item name="sql" type="462c0819:PsiDirectoryNode" />
-            </path>
             <path>
               <item name="Hadoop-Learning" type="b2602c69:ProjectViewProjectNode" />
               <item name="HadoopLearning" type="462c0819:PsiDirectoryNode" />
@@ -263,7 +277,7 @@
               <item name="main" type="462c0819:PsiDirectoryNode" />
               <item name="scala" type="462c0819:PsiDirectoryNode" />
               <item name="c503" type="462c0819:PsiDirectoryNode" />
-              <item name="sparksql" type="462c0819:PsiDirectoryNode" />
+              <item name="es" type="462c0819:PsiDirectoryNode" />
             </path>
             <path>
               <item name="Hadoop-Learning" type="b2602c69:ProjectViewProjectNode" />
@@ -273,7 +287,7 @@
               <item name="main" type="462c0819:PsiDirectoryNode" />
               <item name="scala" type="462c0819:PsiDirectoryNode" />
               <item name="c503" type="462c0819:PsiDirectoryNode" />
-              <item name="utils" type="462c0819:PsiDirectoryNode" />
+              <item name="sparksql" type="462c0819:PsiDirectoryNode" />
             </path>
           </expand>
           <select />
@@ -285,6 +299,7 @@
     <property name="SearchEverywhereHistoryKey" value="person&#9;FILE&#9;file:///Users/liuxm/A_study/idea_ws/HadoopLearning/SparkSQL/src/main/resources/person.json&#10;saveAsAPIHadoop&#9;null&#9;null&#10;log4j-de&#9;FILE&#9;jar:///Users/liuxm/E_lib/local_repository/org/apache/spark/spark-core_2.11/2.0.0/spark-core_2.11-2.0.0.jar!/org/apache/spark/log4j-defaults.properties" />
     <property name="WebServerToolWindowFactoryState" value="false" />
     <property name="aspect.path.notification.shown" value="true" />
+    <property name="com.intellij.database.dataSource.DataSourceTemplate" value="MySQL" />
     <property name="jdk.selected.JAVA_MODULE" value="1.8" />
     <property name="last_opened_file_path" value="$PROJECT_DIR$/pom.xml" />
     <property name="nodejs_interpreter_path.stuck_in_default_project" value="undefined stuck path" />
@@ -329,25 +344,25 @@
       </list>
     </option>
   </component>
-  <component name="RunManager" selected="Application.Spark_SQL_3">
-    <configuration name="SparkCore_5_Accumulator" type="Application" factoryName="Application" temporary="true">
-      <option name="MAIN_CLASS_NAME" value="com.liumm.transform.SparkCore_5_Accumulator" />
-      <module name="SparkCore" />
+  <component name="RunManager" selected="Application.SparkToES">
+    <configuration name="SparkSqlUtils" type="Application" factoryName="Application" temporary="true">
+      <option name="MAIN_CLASS_NAME" value="com.c503.utils.SparkSqlUtils" />
+      <module name="SparkSQL" />
       <option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
       <extension name="coverage">
         <pattern>
-          <option name="PATTERN" value="com.liumm.transform.*" />
+          <option name="PATTERN" value="com.c503.utils.*" />
           <option name="ENABLED" value="true" />
         </pattern>
       </extension>
     </configuration>
-    <configuration name="SparkSqlUtils" type="Application" factoryName="Application" temporary="true">
-      <option name="MAIN_CLASS_NAME" value="com.c503.utils.SparkSqlUtils" />
+    <configuration name="SparkToES" type="Application" factoryName="Application">
+      <option name="MAIN_CLASS_NAME" value="com.c503.es.SparkToES" />
       <module name="SparkSQL" />
       <option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
       <extension name="coverage">
         <pattern>
-          <option name="PATTERN" value="com.c503.utils.*" />
+          <option name="PATTERN" value="com.c503.es.*" />
           <option name="ENABLED" value="true" />
         </pattern>
       </extension>
@@ -427,11 +442,11 @@
       <listeners />
     </configuration>
     <list>
-      <item itemvalue="Application.SparkCore_5_Accumulator" />
+      <item itemvalue="Application.SparkToES" />
+      <item itemvalue="Application.SparkSqlUtils" />
       <item itemvalue="Application.spark_sql_1" />
       <item itemvalue="Application.Spark_SQL_2" />
       <item itemvalue="Application.Spark_SQL_3" />
-      <item itemvalue="Application.SparkSqlUtils" />
     </list>
     <recent_temporary>
       <list>
@@ -439,7 +454,6 @@
         <item itemvalue="Application.SparkSqlUtils" />
         <item itemvalue="Application.spark_sql_1" />
         <item itemvalue="Application.Spark_SQL_2" />
-        <item itemvalue="Application.SparkCore_5_Accumulator" />
       </list>
     </recent_temporary>
   </component>
@@ -469,12 +483,12 @@
       <workItem from="1537286390439" duration="3000" />
       <workItem from="1537365192981" duration="3642000" />
       <workItem from="1537595604046" duration="3241000" />
-      <workItem from="1537599147132" duration="3975000" />
+      <workItem from="1537599147132" duration="7846000" />
     </task>
     <servers />
   </component>
   <component name="TimeTrackingManager">
-    <option name="totallyTimeSpent" value="97635000" />
+    <option name="totallyTimeSpent" value="101506000" />
   </component>
   <component name="TodoView">
     <todo-panel id="selected-file">
@@ -489,42 +503,42 @@
     <frame x="0" y="0" width="1280" height="800" extended-state="0" />
     <editor active="true" />
     <layout>
-      <window_info anchor="right" id="Palette" order="9" />
+      <window_info anchor="right" id="Palette" order="10" />
       <window_info anchor="bottom" id="Event Log" order="8" sideWeight="0.503231" side_tool="true" weight="0.48965517" />
-      <window_info anchor="right" id="Maven Projects" order="5" weight="0.4418417" />
+      <window_info anchor="right" id="Maven Projects" order="6" weight="0.4418417" />
       <window_info anchor="bottom" id="Database Changes" order="10" show_stripe_button="false" />
       <window_info id="Capture Tool" order="5" />
       <window_info id="Designer" order="2" />
-      <window_info anchor="right" id="Database" order="6" />
+      <window_info anchor="right" id="Database" order="7" weight="0.32956383" />
       <window_info id="Structure" order="1" side_tool="true" weight="0.25" />
-      <window_info anchor="right" id="Ant Build" order="2" weight="0.24959612" />
+      <window_info anchor="right" id="Ant Build" order="3" weight="0.24959612" />
       <window_info id="UI Designer" order="3" />
       <window_info anchor="bottom" id="Debug" order="3" sideWeight="0.49919224" weight="0.4" />
       <window_info anchor="bottom" id="TODO" order="6" weight="0.32965517" />
       <window_info anchor="bottom" id="Messages" order="12" sideWeight="0.49832216" weight="0.36689654" />
-      <window_info anchor="right" id="Palette&#9;" order="7" />
+      <window_info anchor="right" id="Palette&#9;" order="8" />
       <window_info id="Image Layers" order="6" />
       <window_info anchor="bottom" id="Java Enterprise" order="9" weight="0.32965517" />
-      <window_info anchor="right" id="Capture Analysis" order="4" />
-      <window_info anchor="bottom" id="Run" order="2" sideWeight="0.49919224" weight="0.41655174" />
+      <window_info anchor="right" id="Capture Analysis" order="5" />
+      <window_info anchor="bottom" id="Run" order="2" sideWeight="0.49919224" weight="1.0" />
       <window_info anchor="bottom" id="Version Control" order="11" weight="0.32965517" />
-      <window_info anchor="right" id="Coverage" side_tool="true" weight="0.32956383" />
+      <window_info anchor="right" id="Coverage" order="0" side_tool="true" weight="0.32956383" />
       <window_info anchor="bottom" id="Terminal" order="7" sideWeight="0.49676898" weight="0.30068967" />
-      <window_info active="true" content_ui="combo" id="Project" order="0" visible="true" weight="0.24717286" />
-      <window_info anchor="right" id="Bean Validation" order="0" />
-      <window_info anchor="right" id="Theme Preview" order="8" />
+      <window_info content_ui="combo" id="Project" order="0" weight="0.24717286" />
+      <window_info anchor="right" id="Bean Validation" order="1" />
+      <window_info anchor="right" id="Theme Preview" order="9" />
       <window_info id="Favorites" order="4" side_tool="true" />
       <window_info anchor="bottom" id="Inspection" order="5" weight="0.4" />
-      <window_info anchor="right" id="Commander" internal_type="SLIDING" order="1" type="SLIDING" weight="0.4" />
+      <window_info anchor="right" id="Commander" internal_type="SLIDING" order="2" type="SLIDING" weight="0.4" />
       <window_info anchor="bottom" id="Cvs" order="4" weight="0.25" />
       <window_info anchor="bottom" id="Message" order="0" />
-      <window_info anchor="right" content_ui="combo" id="Hierarchy" order="3" weight="0.25" />
+      <window_info anchor="right" content_ui="combo" id="Hierarchy" order="4" weight="0.25" />
       <window_info anchor="bottom" id="Find" order="1" />
     </layout>
     <layout-to-restore>
       <window_info id="Designer" order="2" />
       <window_info anchor="right" id="Palette" order="10" />
-      <window_info anchor="bottom" id="Run" order="2" sideWeight="0.49919224" weight="0.33655173" />
+      <window_info anchor="bottom" id="Run" order="2" sideWeight="0.49919224" visible="true" weight="0.38344827" />
       <window_info id="Image Layers" order="6" />
       <window_info anchor="right" id="Commander" internal_type="SLIDING" order="2" type="SLIDING" weight="0.4" />
       <window_info anchor="bottom" id="Cvs" order="4" weight="0.25" />
@@ -609,62 +623,6 @@
     <option name="FILTER_TARGETS" value="false" />
   </component>
   <component name="editorHistoryManager">
-    <entry file="file://$PROJECT_DIR$/SparkStreaming/src/main/java/com/c503/streaming/SparkStreaming_3_Socket_SparkIsClient.scala">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="170">
-          <caret line="11" column="7" selection-start-line="11" selection-start-column="7" selection-end-line="11" selection-end-column="7" />
-        </state>
-      </provider>
-    </entry>
-    <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_2_From_MakeRdd.scala">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="45">
-          <caret line="11" column="43" selection-start-line="11" selection-start-column="7" selection-end-line="11" selection-end-column="43" />
-        </state>
-      </provider>
-    </entry>
-    <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_3_From_OtherRdd.scala">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="170">
-          <caret line="10" column="44" selection-start-line="10" selection-start-column="7" selection-end-line="10" selection-end-column="44" />
-        </state>
-      </provider>
-    </entry>
-    <entry file="jar:///Library/Java/JavaVirtualMachines/jdk1.8.0_151.jdk/Contents/Home/src.zip!/java/net/URL.java">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="233">
-          <caret line="745" column="18" selection-start-line="745" selection-start-column="18" selection-end-line="745" selection-end-column="18" />
-        </state>
-      </provider>
-    </entry>
-    <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_4_From_ByFile_1_Text.scala">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="459">
-          <caret line="27" column="1" lean-forward="true" selection-start-line="27" selection-start-column="1" selection-end-line="27" selection-end-column="1" />
-        </state>
-      </provider>
-    </entry>
-    <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_4_From_ByFile_2_Json.scala">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="306">
-          <caret line="18" column="83" lean-forward="true" selection-start-line="18" selection-start-column="57" selection-end-line="18" selection-end-column="83" />
-        </state>
-      </provider>
-    </entry>
-    <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_4_From_ByFile_4_log.scala">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="170">
-          <caret line="10" column="48" selection-start-line="10" selection-start-column="7" selection-end-line="10" selection-end-column="48" />
-        </state>
-      </provider>
-    </entry>
-    <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_4_From_ByFile_3_cvs.scala">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="306">
-          <caret line="18" column="82" selection-start-line="18" selection-start-column="82" selection-end-line="18" selection-end-column="82" />
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_5_From_ByDir.scala">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="168">
@@ -861,13 +819,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="jar://$PROJECT_DIR$/../../../E_lib/local_repository/org/apache/spark/spark-sql_2.11/2.0.0/spark-sql_2.11-2.0.0.jar!/org/apache/spark/sql/DataFrameReader.class">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="235">
-          <caret line="32" column="6" selection-start-line="32" selection-start-column="6" selection-end-line="32" selection-end-column="6" />
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/SparkCore/src/main/scala/com/liumm/sparkcore/SparkCore_1_CreateRdd_1_From_Parallelize.scala">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="288">
@@ -903,13 +854,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/person.json">
-      <provider selected="true" editor-type-id="text-editor">
-        <state>
-          <caret column="32" selection-start-column="29" selection-end-column="32" />
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_2.scala">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="545">
@@ -931,13 +875,6 @@
         </state>
       </provider>
     </entry>
-    <entry file="file://$PROJECT_DIR$/SparkSQL/pom.xml">
-      <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="332">
-          <caret line="20" selection-start-line="20" selection-end-line="20" />
-        </state>
-      </provider>
-    </entry>
     <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/utils/SparkSqlUtils.scala">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="358">
@@ -955,6 +892,56 @@
         </state>
       </provider>
     </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/person.json">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="85">
+          <caret line="5" lean-forward="true" selection-start-line="5" selection-end-line="5" />
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/pom.xml">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="271">
+          <caret line="20" selection-start-line="20" selection-end-line="20" />
+        </state>
+      </provider>
+    </entry>
+    <entry file="jar://$PROJECT_DIR$/../../../E_lib/local_repository/org/apache/spark/spark-sql_2.11/2.0.0/spark-sql_2.11-2.0.0.jar!/org/apache/spark/sql/DataFrameReader.class">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="187">
+          <caret line="11" column="6" selection-start-line="11" selection-start-column="6" selection-end-line="11" selection-end-column="6" />
+        </state>
+      </provider>
+    </entry>
+    <entry file="jar://$PROJECT_DIR$/../../../E_lib/local_repository/org/apache/spark/spark-sql_2.11/2.0.0/spark-sql_2.11-2.0.0-sources.jar!/org/apache/spark/sql/DataFrameReader.scala">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="-13" />
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/sql/show_all_sql.sql">
+      <provider selected="true" editor-type-id="text-editor">
+        <state>
+          <caret column="7" lean-forward="true" selection-start-column="7" selection-end-column="7" />
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/sql/gender_stats_sql.sql">
+      <provider selected="true" editor-type-id="text-editor">
+        <state>
+          <caret selection-end-line="7" selection-end-column="14" />
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/sql/balance_stats.sql">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="85">
+          <caret line="5" column="7" selection-end-line="11" selection-end-column="18" />
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/sql/state_stats_sql.sql">
+      <provider selected="true" editor-type-id="text-editor" />
+    </entry>
     <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/sql/test.sql">
       <provider selected="true" editor-type-id="text-editor">
         <state relative-caret-position="85">
@@ -962,16 +949,40 @@
         </state>
       </provider>
     </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/resources/sql/gender_group_by_sql.sql">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="83">
+          <caret line="5" column="4" lean-forward="true" selection-start-line="5" selection-start-column="4" selection-end-line="5" selection-end-column="4" />
+        </state>
+      </provider>
+    </entry>
     <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala">
       <provider selected="true" editor-type-id="text-editor">
-        <state relative-caret-position="339">
-          <caret line="44" column="98" selection-start-line="44" selection-start-column="98" selection-end-line="44" selection-end-column="98" />
+        <state relative-caret-position="541">
+          <caret line="52" column="18" selection-start-line="52" selection-start-column="8" selection-end-line="52" selection-end-column="18" />
           <folding>
             <element signature="e#28#63#0" expanded="true" />
           </folding>
         </state>
       </provider>
     </entry>
+    <entry file="jar://$PROJECT_DIR$/../../../E_lib/local_repository/org/elasticsearch/elasticsearch-spark-20_2.11/5.5.2/elasticsearch-spark-20_2.11-5.5.2.jar!/org/elasticsearch/spark/sql/package.class">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="221">
+          <caret line="13" column="8" selection-start-line="13" selection-start-column="8" selection-end-line="13" selection-end-column="8" />
+        </state>
+      </provider>
+    </entry>
+    <entry file="file://$PROJECT_DIR$/SparkSQL/src/main/scala/com/c503/es/SparkToES.scala">
+      <provider selected="true" editor-type-id="text-editor">
+        <state relative-caret-position="440">
+          <caret line="52" column="66" selection-start-line="52" selection-start-column="66" selection-end-line="52" selection-end-column="66" />
+          <folding>
+            <element signature="e#21#56#0" expanded="true" />
+          </folding>
+        </state>
+      </provider>
+    </entry>
   </component>
   <component name="masterDetails">
     <states>
diff --git a/SparkSQL/src/main/resources/sql/balance_stats.sql b/SparkSQL/src/main/resources/sql/balance_stats.sql
new file mode 100644
index 0000000..2bc8ece
--- /dev/null
+++ b/SparkSQL/src/main/resources/sql/balance_stats.sql
@@ -0,0 +1,12 @@
+select
+  firstname,
+  lastname,
+  address,
+  employer,
+  state
+from
+  bank_table
+where
+  gender = "M"
+AND
+  balance >= 30000
\ No newline at end of file
diff --git a/SparkSQL/src/main/resources/sql/gender_group_by_sql.sql b/SparkSQL/src/main/resources/sql/gender_group_by_sql.sql
new file mode 100644
index 0000000..b7f9a53
--- /dev/null
+++ b/SparkSQL/src/main/resources/sql/gender_group_by_sql.sql
@@ -0,0 +1,41 @@
+select
+  a1.gender,
+  a1.all_count as all_count,
+  a2.age_count_28 as age_count_28,
+  a3.age_count_38 as age_count_38
+from
+(
+  select
+    gender,
+    count(1) as all_count
+  from
+    bank_table
+  group by
+    gender
+) as a1
+left join
+(
+  select
+    gender,
+    count(1) as age_count_28
+  from
+    bank_table
+  where
+    age >= 28
+  group by
+    gender
+) as a2
+on a1.gender = a2.gender
+left join
+(
+  select
+    gender,
+    count(1) as age_count_38
+  from
+    bank_table
+  where
+    age >= 38
+  group by
+    gender
+) as a3
+on a1.gender = a3.gender
diff --git a/SparkSQL/src/main/resources/sql/gender_stats_sql.sql b/SparkSQL/src/main/resources/sql/gender_stats_sql.sql
new file mode 100644
index 0000000..4066a04
--- /dev/null
+++ b/SparkSQL/src/main/resources/sql/gender_stats_sql.sql
@@ -0,0 +1,8 @@
+select
+  firstname,
+  lastname,
+  address
+from
+  bank_table
+where
+  gender = "M"
\ No newline at end of file
diff --git a/SparkSQL/src/main/resources/sql/show_all_sql.sql b/SparkSQL/src/main/resources/sql/show_all_sql.sql
new file mode 100644
index 0000000..e8dc23f
--- /dev/null
+++ b/SparkSQL/src/main/resources/sql/show_all_sql.sql
@@ -0,0 +1 @@
+select * from bank_table
\ No newline at end of file
diff --git a/SparkSQL/src/main/scala/com/c503/es/SparkToES.scala b/SparkSQL/src/main/scala/com/c503/es/SparkToES.scala
new file mode 100644
index 0000000..c8691c2
--- /dev/null
+++ b/SparkSQL/src/main/scala/com/c503/es/SparkToES.scala
@@ -0,0 +1,60 @@
+package com.c503.es
+
+import com.c503.utils.SparkSqlUtils
+import org.elasticsearch.spark.sql.sparkDataFrameFunctions
+
+/**
+  * 描述 简单描述方法的作用
+  *
+  * @author liumm
+  * @since 2018-09-22 18:12
+  */
+object SparkToES {
+
+  def main(args: Array[String]): Unit = {
+
+    SparkSqlUtils.offLogger()
+
+    val sqlContext = SparkSqlUtils.newSparkSession("SparkToES")
+
+    //参数
+    val options = Map(
+      "pushdown" -> "true",
+      "es.nodes" -> "192.168.56.100",
+      "es.port" -> "9200",
+      "es.nodes.wan.only" -> "true",
+      "es.query" -> "?q=*",
+      "es.http.timeout" -> "10s",
+      "es.scroll.size" -> "5000",
+      "es.read.field.as.array.include" -> "",
+      "es.mapping.date.rich" -> "false"
+    )
+
+    val df = sqlContext.read.format("es").options(options).load("bank")
+
+    df.createOrReplaceTempView("bank_table")
+
+    //SQL脚本
+    val show_all_sql = SparkSqlUtils.readSqlByPath("sql/show_all_sql.sql")
+    val gender_stats_sql = SparkSqlUtils.readSqlByPath("sql/gender_stats_sql.sql")
+    val balance_stats_sql = SparkSqlUtils.readSqlByPath("sql/balance_stats.sql")
+    val gender_group_by_sql = SparkSqlUtils.readSqlByPath("sql/gender_group_by_sql.sql")
+
+    //sql查询
+    val result_all = sqlContext.sql(show_all_sql)
+    val result_gender = sqlContext.sql(gender_stats_sql)
+    val result_balance = sqlContext.sql(balance_stats_sql)
+    val result_gender_stats = sqlContext.sql(gender_group_by_sql)
+
+    //统计分析数据存入ES中
+    result_all.saveToEs("i57_stats/all", options)
+    result_gender.saveToEs("i57_stats/gender", options)
+    result_balance.saveToEs("i57_stats/balance", options)
+    result_gender_stats.saveToEs("i57_stats/gender_stats", options)
+
+    //关闭回话
+    sqlContext.stop()
+
+  }
+
+}
diff --git a/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala b/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala
index 9aec07b..ab7503d 100644
--- a/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala
+++ b/SparkSQL/src/main/scala/com/c503/sparksql/Spark_SQL_3.scala
@@ -38,11 +38,12 @@ object Spark_SQL_3 {
       "es.http.timeout" -> "10s",
       "es.scroll.size" -> "5000",
       "es.read.field.as.array.include" -> "",
-      "es.mapping.date.rich" -> "false"
+      "es.mapping.date.rich" -> "false",
+      "es.index.auto.create" -> "true"
     )
 
     //构建df
-    val df = sqlContext.read.format("org.elasticsearch.spark.sql").options(options).load("spark_es")
+    val df = sqlContext.read.format("es").options(options).load("spark_es")
 
     //df.select("name", "age").collect().foreach(println(_))
     //临时表