com.netflix.genie.web.data.repositories.jpa

Interface JpaClusterRepository

All Superinterfaces:

CriteriaResolutionRepository, JpaBaseRepository<ClusterEntity>

public interface JpaClusterRepository
extends JpaBaseRepository<ClusterEntity>, CriteriaResolutionRepository

Cluster repository.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	FIND_TERMINATED_CLUSTERS_SQL The SQL to find all clusters in a TERMINATED state that aren't attached to any jobs still in the database.

Method Summary

Modifier and Type	Method and Description
java.lang.Long	deleteByIdIn(java.util.Set<java.lang.Long> ids) Delete all clusters whose ids are contained in the given set of ids.
java.util.Set<java.lang.Number>	findTerminatedUnusedClusters() Find the ids of all clusters that are in a terminated state and aren't attached to any jobs.

Methods inherited from interface com.netflix.genie.web.data.repositories.jpa.JpaBaseRepository

existsByUniqueId, findByUniqueId, findByUniqueId

Methods inherited from interface org.springframework.data.jpa.repository.JpaRepository

deleteAllInBatch, deleteInBatch, findAll, findAll, findAll, findAll, findAllById, flush, getOne, saveAll, saveAndFlush

Methods inherited from interface org.springframework.data.repository.PagingAndSortingRepository

findAll

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, deleteAll, deleteAll, deleteById, existsById, findById, save

Methods inherited from interface org.springframework.data.repository.query.QueryByExampleExecutor

count, exists, findAll, findOne

Methods inherited from interface org.springframework.data.jpa.repository.JpaSpecificationExecutor

count, findAll, findAll, findAll, findOne

Methods inherited from interface com.netflix.genie.web.data.repositories.jpa.CriteriaResolutionRepository

resolveClustersAndCommands

Field Detail

FIND_TERMINATED_CLUSTERS_SQL

static final java.lang.String FIND_TERMINATED_CLUSTERS_SQL

The SQL to find all clusters in a TERMINATED state that aren't attached to any jobs still in the database.

See Also:

Constant Field Values

Method Detail

findTerminatedUnusedClusters

@Query(value="SELECT id FROM clusters WHERE id NOT IN (SELECT DISTINCT(cluster_id) FROM jobs WHERE cluster_id IS NOT NULL) AND status = \'TERMINATED\' FOR UPDATE;",
       nativeQuery=true)
java.util.Set<java.lang.Number> findTerminatedUnusedClusters()

Find the ids of all clusters that are in a terminated state and aren't attached to any jobs.

Returns:

The IDs of matching clusters

deleteByIdIn

@Modifying
java.lang.Long deleteByIdIn(java.util.Set<java.lang.Long> ids)

Delete all clusters whose ids are contained in the given set of ids.

Parameters:

ids - The ids of the clusters to delete

Returns:

The number of deleted clusters