Package com.asakusafw.testdriver.core

Examples of com.asakusafw.testdriver.core.SpiImporterPreparator


    public void spi() throws Exception {
        profile.add("root", HadoopDataSource.class, "/");
        profile.add("root", HadoopDataSourceProfile.KEY_PATH, folder.getRoot().toURI().toURL().toString());
        profile.put();

        SpiImporterPreparator testee = new SpiImporterPreparator(getClass().getClassLoader());
        ModelOutput<Text> output = testee.createOutput(
                new MockTextDefinition(),
                new MockInputDescription("base", "input.txt", format),
                profile.getTextContext());
        put(output, "Hello, world!");
        assertThat(get("base/input.txt"), is(Arrays.asList("Hello, world!")));
View Full Code Here

TOP

Related Classes of com.asakusafw.testdriver.core.SpiImporterPreparator

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.