spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractJavaEsSparkStructuredStreamingTest.java [165:182]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        JavaStreamingQueryTestHarness<RecordBean> test = new JavaStreamingQueryTestHarness<>(spark, Encoders.bean(RecordBean.class));

        RecordBean doc1 = new RecordBean();
        doc1.setId(1);
        doc1.setName("Spark");

        RecordBean doc2 = new RecordBean();
        doc2.setId(2);
        doc2.setName("Hadoop");

        RecordBean doc3 = new RecordBean();
        doc3.setId(3);
        doc3.setName("YARN");

        Dataset<RecordBean> dataset = test
                .withInput(doc1)
                .withInput(doc2)
                .withInput(doc3)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractJavaEsSparkStructuredStreamingTest.java [319:336]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        JavaStreamingQueryTestHarness<RecordBean> test = new JavaStreamingQueryTestHarness<>(spark, Encoders.bean(RecordBean.class));

        RecordBean doc1 = new RecordBean();
        doc1.setId(1);
        doc1.setName("Spark");

        RecordBean doc2 = new RecordBean();
        doc2.setId(2);
        doc2.setName("Hadoop");

        RecordBean doc3 = new RecordBean();
        doc3.setId(3);
        doc3.setName("YARN");

        Dataset<RecordBean> dataset = test
                .withInput(doc1)
                .withInput(doc2)
                .withInput(doc3)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -