public void streamingTest() {

    List<BinarySample> trainingBatch = Arrays.asList(

      new BinarySample(true, 1.0),

      new BinarySample(false, 2.0));

    JavaDStream<BinarySample> training =

      attachTestInputStream(ssc, Arrays.asList(trainingBatch, trainingBatch), 2);

    int numBatches = 2;

    StreamingTest model = new StreamingTest()

      .setWindowSize(0)

      .setPeacePeriod(0)

      .setTestMethod("welch");

    model.registerStream(training);

    attachTestOutputStream(training);

    runStreams(ssc, numBatches, numBatches);

  }