spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/AbstractJavaEsSparkStreamingTest.java [142:155]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        Map<String, Object> doc1 = new HashMap<>();
        doc1.put("one", null);
        Set<String> values = new HashSet<>();
        values.add("2");
        doc1.put("two", values);
        doc1.put("three", ".");

        Map<String, Object> doc2 = new HashMap<>();
        doc2.put("OTP", "Otopeni");
        doc2.put("SFO", "San Fran");

        List<Map<String, Object>> docs = new ArrayList<>();
        docs.add(doc1);
        docs.add(doc2);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



spark/sql-30/src/itest/java/org/elasticsearch/spark/integration/AbstractJavaEsSparkStreamingTest.java [178:191]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        Map<String, Object> doc1 = new HashMap<>();
        doc1.put("one", null);
        Set<String> values = new HashSet<>();
        values.add("2");
        doc1.put("two", values);
        doc1.put("three", ".");

        Map<String, Object> doc2 = new HashMap<>();
        doc2.put("OTP", "Otopeni");
        doc2.put("SFO", "San Fran");

        List<Map<String, Object>> docs = new ArrayList<>();
        docs.add(doc1);
        docs.add(doc2);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -