org.springframework.xd.dirt.stream.zookeeper

Class ZooKeeperJobDefinitionRepository

java.lang.Object

org.springframework.xd.dirt.stream.zookeeper.ZooKeeperJobDefinitionRepository

All Implemented Interfaces:

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

public class ZooKeeperJobDefinitionRepository
extends java.lang.Object
implements JobDefinitionRepository, org.springframework.beans.factory.InitializingBean

A Zookeeper backed repository for persisting JobDefinitions.

Author:

Mark Fisher, David Turanski

Constructor Summary

Constructors

Constructor and Description
ZooKeeperJobDefinitionRepository(ZooKeeperConnection zkConnection)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ZooKeeperJobDefinitionRepository

@Autowired
public ZooKeeperJobDefinitionRepository(ZooKeeperConnection zkConnection)

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<JobDefinition> findAll(org.springframework.data.domain.Sort sort)

Specified by:

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

findAll

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

Specified by:

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

save

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

Specified by:

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

save

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

Specified by:

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

findOne

public JobDefinition findOne(java.lang.String id)

Specified by:

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

exists

public boolean exists(java.lang.String id)

Specified by:

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

findAll

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

Specified by:

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

findAll

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

Specified by:

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

count

public long count()

Specified by:

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

delete

public void delete(java.lang.String id)

Specified by:

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

delete

public void delete(JobDefinition entity)

Specified by:

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

delete

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

Specified by:

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

deleteAll

public void deleteAll()

Specified by:

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

findAllInRange

public java.lang.Iterable<JobDefinition> 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<JobDefinition,java.lang.String>