src/test/java/org/embulk/input/s3/TestS3FileInputPlugin.java in embulk-input-s3-0.2.7 vs src/test/java/org/embulk/input/s3/TestS3FileInputPlugin.java in embulk-input-s3-0.2.8
- old
+ new
@@ -21,10 +21,11 @@
import java.util.ArrayList;
import java.util.List;
import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNull;
import static org.junit.Assume.assumeNotNull;
public class TestS3FileInputPlugin
{
@@ -87,9 +88,18 @@
ConfigSource config = this.config.deepCopy().set("last_path", EMBULK_S3_TEST_PATH_PREFIX + "/sample_01.csv");
ConfigDiff configDiff = runner.transaction(config, new Control(runner, output));
assertEquals(EMBULK_S3_TEST_PATH_PREFIX + "/sample_01.csv", configDiff.get(String.class, "last_path"));
assertEquals(0, getRecords(config, output).size());
+ }
+
+ @Test
+ public void useIncremental()
+ {
+ ConfigSource config = this.config.deepCopy().set("incremental", false);
+ ConfigDiff configDiff = runner.transaction(config, new Control(runner, output));
+
+ assertFalse(configDiff.has("last_path"));
}
@Test
public void emptyFilesWithLastPath()
throws Exception