spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractJavaEsSparkStructuredStreamingTest.java [200:222]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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)
                .stream();

        test.run(
                dataset.writeStream()
                        .option("checkpointLocation", checkpoint(target))
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



spark/sql-30/src/itest/scala/org/elasticsearch/spark/integration/AbstractJavaEsSparkStructuredStreamingTest.java [237:259]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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)
                .stream();

        test.run(
                dataset.writeStream()
                        .option("checkpointLocation", checkpoint(target))
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -