@@ -0,0 +1,968 @@
+package org.apache.beam.runners.spark.structuredstreaming.utils;%0A%0Aimport java.util.ArrayList;%0Aimport java.util.List;%0Aimport org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers;%0Aimport org.apache.beam.sdk.coders.VarIntCoder;%0Aimport org.apache.spark.sql.SparkSession;%0Aimport org.junit.Test;%0Aimport org.junit.runner.RunWith;%0Aimport org.junit.runners.JUnit4;%0A%0A@RunWith(JUnit4.class)%0A/**%0A * Test of the wrapping of Beam Coders as Spark ExpressionEncoders.%0A */%0Apublic class EncodersTest %7B%0A%0A  @Test%0A  public void beamCoderToSparkEncoderTest() %7B%0A    SparkSession sparkSession = SparkSession.builder().appName(%22beamCoderToSparkEncoderTest%22)%0A        .master(%22local%5B4%5D%22).getOrCreate();%0A    List%3CInteger%3E data = new ArrayList%3C%3E();%0A    data.add(1);%0A    data.add(2);%0A    data.add(3);%0A//    sparkSession.createDataset(data, EncoderHelpers.fromBeamCoder(VarIntCoder.of()));%0A    sparkSession.createDataset(data, EncoderHelpers.genericEncoder());%0A  %7D%0A%7D%0A

Add a simple spark native test to test Beam coders wrapping into Spark Encoders