org.springframework.xd.dirt.stream.zookeeper

Class ZooKeeperStreamDefinitionRepository

java.lang.Object

org.springframework.xd.dirt.stream.zookeeper.ZooKeeperStreamDefinitionRepository

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>, org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>, org.springframework.data.repository.Repository<StreamDefinition,java.lang.String>, StreamDefinitionRepository, DomainRepository<StreamDefinition,java.lang.String>, RangeCapableRepository<StreamDefinition,java.lang.String>

public class ZooKeeperStreamDefinitionRepository
extends java.lang.Object
implements StreamDefinitionRepository, org.springframework.beans.factory.InitializingBean

Author:

Mark Fisher

Constructor Summary

Constructors

Constructor and Description
ZooKeeperStreamDefinitionRepository(ZooKeeperConnection zkConnection, ModuleDependencyRepository moduleDependencyRepository)

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
long	count()
void	delete(java.lang.Iterable<? extends StreamDefinition> entities)
void	delete(StreamDefinition entity)
void	delete(java.lang.String id)
void	deleteAll()
boolean	exists(java.lang.String id)
java.util.List<StreamDefinition>	findAll()
java.util.List<StreamDefinition>	findAll(java.lang.Iterable<java.lang.String> ids)
org.springframework.data.domain.Page<StreamDefinition>	findAll(org.springframework.data.domain.Pageable pageable)
java.lang.Iterable<StreamDefinition>	findAll(org.springframework.data.domain.Sort sort)
java.lang.Iterable<StreamDefinition>	findAllInRange(java.lang.String from, boolean fromInclusive, java.lang.String to, boolean toInclusive) Return entities whose ids range between from and to.
StreamDefinition	findOne(java.lang.String id)
<S extends StreamDefinition> java.lang.Iterable<S>	save(java.lang.Iterable<S> entities)
<S extends StreamDefinition> S	save(S entity)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZooKeeperStreamDefinitionRepository

@Autowired
public ZooKeeperStreamDefinitionRepository(ZooKeeperConnection zkConnection,
                                             ModuleDependencyRepository moduleDependencyRepository)

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

findAll

public java.lang.Iterable<StreamDefinition> findAll(org.springframework.data.domain.Sort sort)

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>

findAll

public org.springframework.data.domain.Page<StreamDefinition> findAll(org.springframework.data.domain.Pageable pageable)

Specified by:

findAll in interface org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>

save

public <S extends StreamDefinition> java.lang.Iterable<S> save(java.lang.Iterable<S> entities)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

save

public <S extends StreamDefinition> S save(S entity)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

findOne

public StreamDefinition findOne(java.lang.String id)

Specified by:

findOne in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

exists

public boolean exists(java.lang.String id)

Specified by:

exists in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

findAll

public java.util.List<StreamDefinition> findAll()

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

findAll

public java.util.List<StreamDefinition> findAll(java.lang.Iterable<java.lang.String> ids)

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

count

public long count()

Specified by:

count in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

delete

public void delete(java.lang.String id)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

delete

public void delete(StreamDefinition entity)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

delete

public void delete(java.lang.Iterable<? extends StreamDefinition> entities)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

findAllInRange

public java.lang.Iterable<StreamDefinition> findAllInRange(java.lang.String from,
                                                  boolean fromInclusive,
                                                  java.lang.String to,
                                                  boolean toInclusive)

Description copied from interface: RangeCapableRepository

Return entities whose ids range between from and to. Note that it is possible that entities with those exact ids do not exist. If they do exist, the two boolean parameters control whether to include those results or not. A query from x to x returns an empty result, unless both fromInclusive and toInclusive are true.

Specified by:

findAllInRange in interface RangeCapableRepository<StreamDefinition,java.lang.String>