@@ -0,0 +1,841 @@
+package io.ddf.spark.etl;%0A%0Aimport java.util.Arrays;%0Aimport io.ddf.DDF;%0Aimport io.ddf.etl.Types.JoinType;%0Aimport io.ddf.exception.DDFException;%0Aimport io.ddf.spark.BaseTest;%0Aimport org.junit.Assert;%0Aimport org.junit.Before;%0Aimport org.junit.Test;%0A%0Apublic class JoinHandlerTest extends BaseTest %7B%0A  private DDF left_ddf, right_ddf;%0A  %0A  @Before%0A  public void setUp() throws Exception %7B%0A    createTableMtcars();%0A    createTableCarOwner();%0A%0A    left_ddf = manager.sql2ddf(%22select * from mtcars%22, %22SparkSQL%22);%0A    right_ddf = manager.sql2ddf(%22select * from carowner%22, %22SparkSQL%22);%0A  %7D%0A  %0A  @Test%0A  public void testInnerJoin() throws DDFException %7B%0A    DDF ddf = left_ddf.join(right_ddf, JoinType.INNER, Arrays.asList(%22cyl%22),null,null);%0A    LOG.info(%22Column names: %22 +ddf.getColumnNames());%0A    Assert.assertEquals(25, ddf.getNumRows());%0A  %7D%0A  %0A%7D%0A

test passed