public class ZooKeeperStreamDefinitionRepository extends java.lang.Object implements StreamDefinitionRepository, org.springframework.beans.factory.InitializingBean
コンストラクターと説明 |
---|
ZooKeeperStreamDefinitionRepository(ZooKeeperConnection zkConnection, ModuleDependencyRepository moduleDependencyRepository) |
修飾子と型 | メソッドと説明 |
---|---|
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) ID の範囲が from から to までであるエンティティを返します。 |
StreamDefinition | findOne(java.lang.String id) |
<S extends StreamDefinition> | save(java.lang.Iterable<S> entities) |
<S extends StreamDefinition> | save(S entity) |
@Autowired public ZooKeeperStreamDefinitionRepository(ZooKeeperConnection zkConnection, ModuleDependencyRepository moduleDependencyRepository)
public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception
public java.lang.Iterable<StreamDefinition> findAll(org.springframework.data.domain.Sort sort)
org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>
の findAll
public org.springframework.data.domain.Page<StreamDefinition> findAll(org.springframework.data.domain.Pageable pageable)
org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>
の findAll
public <S extends StreamDefinition> java.lang.Iterable<S> save(java.lang.Iterable<S> entities)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の save
public <S extends StreamDefinition> S save(S entity)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の save
public StreamDefinition findOne(java.lang.String id)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の findOne
public boolean exists(java.lang.String id)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の exists
public java.util.List<StreamDefinition> findAll()
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の findAll
public java.util.List<StreamDefinition> findAll(java.lang.Iterable<java.lang.String> ids)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の findAll
public long count()
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の count
public void delete(java.lang.String id)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の delete
public void delete(StreamDefinition entity)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の delete
public void delete(java.lang.Iterable<? extends StreamDefinition> entities)
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の delete
public void deleteAll()
org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>
の deleteAll
public java.lang.Iterable<StreamDefinition> findAllInRange(java.lang.String from, boolean fromInclusive, java.lang.String to, boolean toInclusive)
RangeCapableRepository
from
から to
までの範囲にあるエンティティを返します。これらの ID とまったく同じエンティティが存在しない可能性があることに注意してください。存在する場合は、2 つのブールパラメーターによって、それらの結果を含めるかどうかを制御します。x
から x
へのクエリは、fromInclusive
と toInclusive
の両方が true でない限り、空の結果を返します。RangeCapableRepository<StreamDefinition,java.lang.String>
の findAllInRange