Examples of toDSL()

Examples of org.springframework.xd.test.fixtures.FileJdbcJob.toDSL()

121
122
123
124
125
126
127
128
129
130
131
        FileJdbcJob.DEFAULT_TABLE_NAME, FileJdbcJob.DEFAULT_NAMES);
    String jobName = "tjduf" + UUID.randomUUID().toString();
    logger.info("Testing Job Deploy Undeploy Flow for: " + jobName);

    job(jobName, job.toDSL(),true);
    checkJob(jobName, job.toDSL(), true);
    undeployJob(jobName);
    checkJob(jobName, job.toDSL(), false);
    deployJob(jobName);
    checkJob(jobName, job.toDSL(), true);
    undeployJob(jobName);
View Full Code Here

Examples of org.springframework.xd.test.fixtures.FileJdbcJob.toDSL()

123
124
125
126
127
128
129
130
131
132
133
    logger.info("Testing Job Deploy Undeploy Flow for: " + jobName);

    job(jobName, job.toDSL(),true);
    checkJob(jobName, job.toDSL(), true);
    undeployJob(jobName);
    checkJob(jobName, job.toDSL(), false);
    deployJob(jobName);
    checkJob(jobName, job.toDSL(), true);
    undeployJob(jobName);
  }
View Full Code Here

Examples of org.springframework.xd.test.fixtures.FileJdbcJob.toDSL()

125
126
127
128
129
130
131
132
133
134
135
    job(jobName, job.toDSL(),true);
    checkJob(jobName, job.toDSL(), true);
    undeployJob(jobName);
    checkJob(jobName, job.toDSL(), false);
    deployJob(jobName);
    checkJob(jobName, job.toDSL(), true);
    undeployJob(jobName);
  }

  @Test
  public void testInvalidJobDescriptor() throws InterruptedException {
View Full Code Here

Examples of org.springframework.xd.test.fixtures.FileJdbcJob.toDSL()

158
159
160
161
162
163
164
165
166
167
168
    // Create a stream that writes to a file. This file will be used by the job.
    stream("dataSender", sources.http() + XD_DELIMITER
        + sinks.file(FileJdbcJob.DEFAULT_DIRECTORY, DEFAULT_FILE_NAME).toDSL());
    sources.http(getContainerHostForSource("dataSender")).postData(data);
    job(jobName, job.toDSL(),true);
    jobLaunch(jobName);
    String query = String.format("SELECT data FROM %s", tableName);

    waitForTablePopulation(query, jdbcSink.getJdbcTemplate(), 1);
View Full Code Here

Examples of org.springframework.xd.test.fixtures.FileJdbcJob.toDSL()

71
72
73
74
75
76
77
78
79
80
81
      stream("dataSender" + i, sources.http("foobar", 9000 + i) + XD_DELIMITER
          + sinks.file(FileJdbcJob.DEFAULT_DIRECTORY, DEFAULT_FILE_NAME + "partition" + i).toDSL());
      sources.http(getContainerHostForSource("dataSender" + i), 9000 + i).postData(data);
    }
    waitForXD();
    job(job.toDSL());
    waitForXD();
    jobLaunch();

    String query = String.format("SELECT data FROM %s", tableName);
    waitForTablePopulation(query, jdbcSink.getJdbcTemplate(), 5);
View Full Code Here

Examples of org.springframework.xd.test.fixtures.FileJdbcJob.toDSL()

102
103
104
105
106
107
108
109
110
111
112
    // Create a stream that writes to a file. This file will be used by the job.
    stream("dataSender", sources.http() + XD_DELIMITER
        + sinks.file(FileJdbcJob.DEFAULT_DIRECTORY, DEFAULT_FILE_NAME).toDSL());
    sources.http(getContainerHostForSource("dataSender")).postData(data);
    job(job.toDSL());
    waitForXD();
    jobLaunch();
    String query = String.format("SELECT data FROM %s", tableName);

    waitForTablePopulation(query, jdbcSink.getJdbcTemplate(), 1);
View Full Code Here

Examples of org.springframework.xd.test.fixtures.HdfsJdbcJob.toDSL()

64
65
66
67
68
69
70
71
72
73
74
    job.fileName(HdfsJdbcJob.DEFAULT_FILE_NAME + "-0.txt");
    // Create a stream that writes to a hdfs file. This file will be used by the job.
    stream("dataSender", sources.http() + XD_DELIMITER + sinks.hdfs()
        .directoryName(HdfsJdbcJob.DEFAULT_DIRECTORY).fileName(DEFAULT_FILE_NAME).toDSL());
    sources.http(getContainerHostForSource("dataSender")).postData(data);
    job(job.toDSL());
    waitForXD();
    //Undeploy the dataSender stream to force XD to close the file.
    undeployStream("dataSender");
    waitForXD();
    jobLaunch();
View Full Code Here

Examples of org.springframework.xd.test.fixtures.JdbcHdfsJob.toDSL()

75
76
77
78
79
80
81
82
83
84
85
    // Use a trigger to send data to JDBC
    stream("dataSender", sources.http() + XD_DELIMITER
        + jdbcSink);
    sources.http(getContainerHostForSource("dataSender")).postData(data);

    job(job.toDSL());
    waitForXD();
    jobLaunch();
    waitForXD(2000);
    // Evaluate the results of the test.
    String path = JdbcHdfsJob.DEFAULT_DIRECTORY + "/" + JdbcHdfsJob.DEFAULT_FILE_NAME + "-0.csv";
View Full Code Here

Examples of org.springframework.xd.test.fixtures.PartitionedJdbcHdfsJob.toDSL()

111
112
113
114
115
116
117
118
119
120
121
        + jdbcSink);
    sources.http(getContainerHostForSource("dataSender")).postData(data0);
    sources.http(getContainerHostForSource("dataSender")).postData(data1);
    sources.http(getContainerHostForSource("dataSender")).postData(data2);

    job(job.toDSL());
    waitForXD();
    jobLaunch();
    waitForXD(2000);
    // Evaluate the results of the test.
    String dir = JdbcHdfsJob.DEFAULT_DIRECTORY + "/";
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.