SpringCloud/spring-cloud-dataflow-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updating code to use auto-configuration

Browse Source 
* Removing .idea directory
This commit is contained in:
Vinicius Carvalho
2018-01-23 20:47:47 -05:00
committed by Mark Pollack
parent 3194eac395
commit 46c5564c03
86 changed files with 69 additions and 1627 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/asciidoc/javadsl/main.adoc
View File

@@ -14,10 +14,22 @@ With no command line options, the application will deploy the stream `http --ser
There is also a command line option `--style` whose value can be either `definition` or `fluent`.
This options picks which JavaDSL style will execute.
Both are identical in terms of behavior.
The `spring-cloud-dataflow-rest-client` project provides instances of `DataFlowOperations` and `StreamBuilder`
[source,java,options="nowrap"]
----
@Autowired
private DataFlowOperations dataFlowOperations;
@Autowired
private StreamBuilder builder;
----
You can use those beans to build streams as well as work directly with `DataFlowOperations" REST client.
The `definition` style has code of the style
[source,java,options="nowrap"]
----
Stream woodchuck = Stream.builder(dataFlowOperations)
Stream woodchuck = builder
.name("woodchuck")
.definition("http --server.port=9900 | splitter --expression=payload.split(' ') | log")
.create()
@@ -26,7 +38,7 @@ Stream woodchuck = Stream.builder(dataFlowOperations)
while the `fluent` style has code of the style
[source,java]
----
Stream woodchuck = Stream.builder(dataFlowOperations).name("woodchuck")
Stream woodchuck = builder.name("woodchuck")
.source(source)
.processor(processor)
.sink(sink)
@@ -41,6 +53,18 @@ public StreamApplication source() {
return new StreamApplication("http").addProperty("server.port", 9900);
}
----
Another useful class is the `DeploymentPropertiesBuilder` which aids in the creation of the Map of properties required to deploy stream applications.
[source,java]
----
private Map<String, String> createDeploymentProperties() {
DeploymentPropertiesBuilder propertiesBuilder = new DeploymentPropertiesBuilder();
propertiesBuilder.memory("log", 512);
propertiesBuilder.count("log",2);
propertiesBuilder.put("app.splitter.producer.partitionKeyExpression", "payload");
return propertiesBuilder.build();
}
----
2) Run a local Data Flow Server and run the sample application.
This sample demonstrates the use of the local Data Flow Server, but you can pass in the option `--uri` to point to another Data Flow server instance that is running elsewhere.
[source,bash]