org.springframework.cloud.dataflow.server.repository

Class RdbmsStreamDeploymentRepository

java.lang.Object

org.springframework.cloud.dataflow.server.repository.RdbmsStreamDeploymentRepository

All Implemented Interfaces:

StreamDeploymentRepository

public class RdbmsStreamDeploymentRepository
extends Object
implements StreamDeploymentRepository

RDBMS implementation of StreamDeploymentRepository.

Author:

Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
RdbmsStreamDeploymentRepository(DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
void	delete(String streamName) Delete a Stream deployment identified by the given stream name.
Iterable<StreamDeployment>	findAll() Get all Stream deployment entries
StreamDeployment	findOne(String streamName) Find a specific StreamDeployment by stream name.
StreamDeployment	save(StreamDeployment streamDeployment) Store Stream deployment entry.

Methods inherited from class java.lang.Object

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

Constructor Detail

RdbmsStreamDeploymentRepository

public RdbmsStreamDeploymentRepository(DataSource dataSource)

Method Detail

save

public StreamDeployment save(StreamDeployment streamDeployment)

Description copied from interface: StreamDeploymentRepository

Store Stream deployment entry.

Specified by:

save in interface StreamDeploymentRepository

Parameters:

streamDeployment - the stream deployment to save

Returns:

the streamDeployment that is saved

findOne

public StreamDeployment findOne(String streamName)

Description copied from interface: StreamDeploymentRepository

Find a specific StreamDeployment by stream name.

Specified by:

findOne in interface StreamDeploymentRepository

Parameters:

streamName - the stream name corresponding to the stream deployment

Returns:

the stream deployment

findAll

public Iterable<StreamDeployment> findAll()

Description copied from interface: StreamDeploymentRepository

Get all Stream deployment entries

Specified by:

findAll in interface StreamDeploymentRepository

Returns:

the iterable StreamDeployment entries

delete

public void delete(String streamName)

Description copied from interface: StreamDeploymentRepository

Delete a Stream deployment identified by the given stream name.

Specified by:

delete in interface StreamDeploymentRepository

Parameters:

streamName - the stream name corresponding to the stream deployment