hive/src/itest/java/org/elasticsearch/hadoop/integration/hive/AbstractHiveSaveJsonTest.java [92:116]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void testExternalSerDe() throws Exception {
        String localTable = "CREATE TABLE jsonexternalserde ("
                + "data       STRING) "
                + "ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.RegexSerDe' "
                + "WITH SERDEPROPERTIES ('input.regex'='(.*)') "
                + "LOCATION '/tmp/hive/warehouse/jsonexternalserde/' ";

        String load = loadData("jsonexternalserde");

        // create external table
        String ddl =
                "CREATE EXTERNAL TABLE jsonexternalserdetest ("
                        + "data     STRING) "
                        + tableProps(resource("json-hive-externalserde", "data", targetVersion));

        String insert =
                "INSERT OVERWRITE TABLE jsonexternalserdetest "
                        + "SELECT s.data FROM jsonexternalserde s";

        System.out.println(ddl);
        System.out.println(server.execute(ddl));
        System.out.println(server.execute(localTable));
        System.out.println(server.execute(load));
        System.out.println(server.execute(insert));
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



hive/src/itest/java/org/elasticsearch/hadoop/integration/hive/AbstractHiveSaveTest.java [338:362]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void testExternalSerDe() throws Exception {
        String localTable = "CREATE TABLE externalserde ("
                + "data       STRING) "
                + "ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.RegexSerDe' "
                + "WITH SERDEPROPERTIES ('input.regex'='(.*)') "
                + "LOCATION '/tmp/hive/warehouse/externalserde/' ";

        String load = loadData("externalserde");

        // create external table
        String ddl =
                "CREATE EXTERNAL TABLE externalserdetest ("
                        + "data     STRING)"
                        + tableProps(resource("hive-externalserde", "data", targetVersion));

        String insert =
                "INSERT OVERWRITE TABLE externalserdetest "
                        + "SELECT s.data FROM externalserde s";

        System.out.println(ddl);
        System.out.println(server.execute(ddl));
        System.out.println(server.execute(localTable));
        System.out.println(server.execute(load));
        System.out.println(server.execute(insert));
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -