org.springframework.cloud.dataflow.rest.client.dsl

Class Stream

java.lang.Object

org.springframework.cloud.dataflow.rest.client.dsl.Stream

public class Stream
extends Object

Represents a Stream deployed on DataFlow server. Instances of this class are created using a fluent style builder Builder. for instance

     
     Stream stream = Stream.builder(dataflowOperations).definition("time | log").create().deploy();
     
 

A fluent style can also be used via

     
     Stream stream = Stream.builder(dataflowOperations).source("time").sink("log").create().deploy();
     
 

Author:

Vinicius Carvalho

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Stream.ProcessorBuilder
static class	Stream.SinkBuilder
static class	Stream.SourceBuilder
static class	Stream.StreamDefinitionBuilder
static class	Stream.StreamNameBuilder

Method Summary

Modifier and Type	Method and Description
static StreamBuilder	builder(DataFlowOperations client) Fluent API method to create a StreamBuilder.
void	destroy() Destroy the stream from the server.
String	getStatus()
StreamDefinition	undeploy() Undeploy the current Stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

builder

public static StreamBuilder builder(DataFlowOperations client)

Fluent API method to create a StreamBuilder.

Parameters:

client - DataFlowOperations client instance

Returns:

A fluent style builder to create streams

undeploy

public StreamDefinition undeploy()

Undeploy the current Stream. This method invokes the remote server

Returns:

A reference the the StreamDefinition so one can invoke other builder operations such as StreamDefinition.deploy()

destroy

public void destroy()

Destroy the stream from the server. This method invokes the remote server

getStatus

public String getStatus()

Returns:

Status of the deployed stream