Package com.asakusafw.windgate.core

Examples of com.asakusafw.windgate.core.DriverScript

142
143
144
145
146
147
148
149
150
     * Contains null column.
     */
    @Test(expected = IllegalStateException.class)
    public void has_null_column() {
        Mock mock = new Mock(String.class, "testing", StringSupport.class, "TESTING", null, "VALUE", null);
        DriverScript script = mock.getDriverScript();
        assertThat(script.getResourceName(), is(Constants.JDBC_RESOURCE_NAME));
        script.getConfiguration();
    }
View Full Code Here
153
154
155
156
157
158
159
160
161
     * JDBC Support not specified.
     */
    @Test(expected = IllegalStateException.class)
    public void no_support() {
        Mock mock = new Mock(String.class, "testing", null, "TESTING", null, "VALUE");
        DriverScript script = mock.getDriverScript();
        assertThat(script.getResourceName(), is(Constants.JDBC_RESOURCE_NAME));
        script.getConfiguration();
    }
View Full Code Here
164
165
166
167
168
169
170
171
172
     * Inconsistent JDBC support.
     */
    @Test(expected = IllegalStateException.class)
    public void invalid_type_support() {
        Mock mock = new Mock(String.class, "testing", VoidSupport.class, "TESTING", null, "VALUE");
        DriverScript script = mock.getDriverScript();
        assertThat(script.getResourceName(), is(Constants.JDBC_RESOURCE_NAME));
        script.getConfiguration();
    }
View Full Code Here
175
176
177
178
179
180
181
182
183
     * Columns are not supported.
     */
    @Test(expected = IllegalStateException.class)
    public void invalid_columns() {
        Mock mock = new Mock(String.class, "testing", NullSupport.class, "TESTING", null, "VALUE");
        DriverScript script = mock.getDriverScript();
        assertThat(script.getResourceName(), is(Constants.JDBC_RESOURCE_NAME));
        script.getConfiguration();
    }
View Full Code Here
186
187
188
189
190
191
192
193
194
     * Inconsistent JDBC support.
     */
    @Test(expected = IllegalStateException.class)
    public void invalid_support_class() {
        Mock mock = new Mock(String.class, "testing", InvalidSupport.class, "TESTING", null, "VALUE");
        DriverScript script = mock.getDriverScript();
        assertThat(script.getResourceName(), is(Constants.JDBC_RESOURCE_NAME));
        script.getConfiguration();
    }
View Full Code Here
154
155
156
157
158
159
160
161
    private ProcessScript<String> script(File source, File drain) {
        return new ProcessScript<String>(
                "example",
                "plain",
                String.class,
                new DriverScript("fs", Collections.singletonMap(FileProcess.FILE.key(), source.getPath())),
                new DriverScript("fs", Collections.singletonMap(FileProcess.FILE.key(), drain.getPath())));
    }
View Full Code Here
303
304
305
306
307
308
309
310
311
312
313
    private ProcessScript<?> toProcessScript(Input input) {
        assert input != null;
        WindGateImporterDescription desc = extract(input.getDescription());
        String location = getInputLocation(input.getDescription()).toPath('/');
        DriverScript drain = new DriverScript(
                Constants.HADOOP_FILE_RESOURCE_NAME,
                Collections.singletonMap(FileProcess.FILE.key(), location));
        return createProcessScript(
                input.getDescription().getName(),
                desc.getModelType(),
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
    private ProcessScript<?> toProcessScript(Output output) {
        assert output != null;
        WindGateExporterDescription desc = extract(output.getDescription());
        String location = getOutputLocation(output.getDescription()).toPath('/');
        DriverScript source = new DriverScript(
                Constants.HADOOP_FILE_RESOURCE_NAME,
                Collections.singletonMap(FileProcess.FILE.key(), location));
        return createProcessScript(
                output.getDescription().getName(),
                desc.getModelType(),
View Full Code Here
381
382
383
384
385
386
387
        }
        return null;
    }

    private DriverScript dummy() {
        return new DriverScript("example", Collections.<String, String>emptyMap());
    }
View Full Code Here
197
198
199
200
201
202
203
204
205
206
            return "testing";
        }

        @Override
        public DriverScript getDriverScript() {
            DriverScript driver = new DriverScript(
                    "file",
                    Collections.singletonMap(FileProcess.FILE.key(), file.getAbsolutePath()));
            return driver;
        }
View Full Code Here
TOP

Related Classes of com.asakusafw.windgate.core.DriverScript

  • com.asakusafw.compiler.windgate.WindGateIoProcessor
  • com.asakusafw.compiler.windgate.WindGateIoProcessorRunTest
  • com.asakusafw.compiler.windgate.WindGateIoProcessorTest
  • com.asakusafw.testdriver.windgate.WindGateExporterRetrieverTest
  • com.asakusafw.testdriver.windgate.WindGateImporterPreparatorTest
  • com.asakusafw.testdriver.windgate.WindGateSourceProviderTest$MockExporter
  • com.asakusafw.testdriver.windgate.WindGateSourceProviderTest$MockImporter
  • com.asakusafw.testdriver.windgate.WindGateTestHelper
  • com.asakusafw.testdriver.windgate.WindGateTestHelperTest
  • com.asakusafw.vocabulary.windgate.FsExporterDescription
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.