test_class.declarator: PARTITIONER = "org.apache.cassandra.dht.RandomPartitioner"
test_class.modifier: private static final
test_class.original_string: private static final String PARTITIONER = "org.apache.cassandra.dht.RandomPartitioner";
test_class.type: String
test_class.var_name: PARTITIONER
test_class.declarator: SEED_HOST = "127.0.0.1"
test_class.modifier: private static final
test_class.original_string: private static final String SEED_HOST = "127.0.0.1";
test_class.type: String
test_class.var_name: SEED_HOST
test_class.declarator: INCREMENTAL = false
test_class.modifier: private static final
test_class.original_string: private static final Boolean INCREMENTAL = false;
test_class.type: Boolean
test_class.var_name: INCREMENTAL
test_class.declarator: TABLES = Sets.newHashSet("testTable")
test_class.modifier: private static final
test_class.original_string: private static final Set<String> TABLES = Sets.newHashSet("testTable");
test_class.type: Set<String>
test_class.var_name: TABLES
test_class.declarator: NODES = Collections.emptySet()
test_class.modifier: private static final
test_class.original_string: private static final Set<String> NODES = Collections.emptySet();
test_class.type: Set<String>
test_class.var_name: NODES
test_class.declarator: DATACENTERS = Collections.emptySet()
test_class.modifier: private static final
test_class.original_string: private static final Set<String> DATACENTERS = Collections.emptySet();
test_class.type: Set<String>
test_class.var_name: DATACENTERS
test_class.declarator: NODES_MAP = Maps.newHashMap("node1", "127.0.0.1")
test_class.modifier: private static final
test_class.original_string: private static final Map<String, String> NODES_MAP = Maps.newHashMap("node1", "127.0.0.1");
test_class.type: Map<String, String>
test_class.var_name: NODES_MAP
test_class.declarator: BLACKLISTED_TABLES = Collections.emptySet()
test_class.modifier: private static final
test_class.original_string: private static final Set<String> BLACKLISTED_TABLES = Collections.emptySet();
test_class.type: Set<String>
test_class.var_name: BLACKLISTED_TABLES
test_class.declarator: REPAIR_THREAD_COUNT = 2
test_class.modifier: private static final
test_class.original_string: private static final int REPAIR_THREAD_COUNT = 2;
test_class.type: int
test_class.var_name: REPAIR_THREAD_COUNT
test_class.declarator: OWNER = "test"
test_class.modifier: private static final
test_class.original_string: private static final String OWNER = "test";
test_class.type: String
test_class.var_name: OWNER
test_class.declarator: THREAD_CNT = 1
test_class.modifier: private static final
test_class.original_string: private static final int THREAD_CNT = 1;
test_class.type: int
test_class.var_name: THREAD_CNT
test_class.declarator: REPAIR_TIMEOUT_S = 60
test_class.modifier: private static final
test_class.original_string: private static final int REPAIR_TIMEOUT_S = 60;
test_class.type: int
test_class.var_name: REPAIR_TIMEOUT_S
test_class.declarator: RETRY_DELAY_S = 10
test_class.modifier: private static final
test_class.original_string: private static final int RETRY_DELAY_S = 10;
test_class.type: int
test_class.var_name: RETRY_DELAY_S
test_class.declarator: TIME_CREATE = 42L
test_class.modifier: private static final
test_class.original_string: private static final long TIME_CREATE = 42L;
test_class.type: long
test_class.var_name: TIME_CREATE
test_class.declarator: TIME_START = 43L
test_class.modifier: private static final
test_class.original_string: private static final long TIME_START = 43L;
test_class.type: long
test_class.var_name: TIME_START
test_class.declarator: SAMPLE_URI = URI.create("http://reaper_host/repair_run/")
test_class.modifier: private static final
test_class.original_string: private static final URI SAMPLE_URI = URI.create("http://reaper_host/repair_run/");
test_class.type: URI
test_class.var_name: SAMPLE_URI
test_class.declarator: SEGMENT_CNT = 6
test_class.modifier: private static final
test_class.original_string: private static final int SEGMENT_CNT = 6;
test_class.type: int
test_class.var_name: SEGMENT_CNT
test_class.declarator: REPAIR_INTENSITY = 0.5f
test_class.modifier: private static final
test_class.original_string: private static final double REPAIR_INTENSITY = 0.5f;
test_class.type: double
test_class.var_name: REPAIR_INTENSITY
test_class.declarator: REPAIR_PARALLELISM = RepairParallelism.SEQUENTIAL
test_class.modifier: private static final
test_class.original_string: private static final RepairParallelism REPAIR_PARALLELISM = RepairParallelism.SEQUENTIAL;
test_class.type: RepairParallelism
test_class.var_name: REPAIR_PARALLELISM
test_class.declarator: STCS = "SizeTieredCompactionStrategy"
test_class.modifier: private static final
test_class.original_string: private static final String STCS = "SizeTieredCompactionStrategy";
test_class.type: String
test_class.var_name: STCS
test_class.declarator: TOKENS = Lists.newArrayList(
        BigInteger.valueOf(0L),
        BigInteger.valueOf(100L),
        BigInteger.valueOf(200L))
test_class.modifier: private static final
test_class.original_string: private static final List<BigInteger> TOKENS = Lists.newArrayList(
        BigInteger.valueOf(0L),
        BigInteger.valueOf(100L),
        BigInteger.valueOf(200L));
test_class.type: List<BigInteger>
test_class.var_name: TOKENS
test_class.declarator: clustername = "testcluster_" + RandomStringUtils.randomAlphabetic(6)
test_class.modifier: private final
test_class.original_string: private final String clustername = "testcluster_" + RandomStringUtils.randomAlphabetic(6);
test_class.type: String
test_class.var_name: clustername
test_class.declarator: keyspace = "testkeyspace_" + RandomStringUtils.randomAlphabetic(6)
test_class.modifier: private final
test_class.original_string: private final String keyspace = "testkeyspace_" + RandomStringUtils.randomAlphabetic(6);
test_class.type: String
test_class.var_name: keyspace
test_class.declarator: context
test_class.modifier: private
test_class.original_string: private AppContext context;
test_class.type: AppContext
test_class.var_name: context
test_class.declarator: uriInfo
test_class.modifier: private
test_class.original_string: private UriInfo uriInfo;
test_class.type: UriInfo
test_class.var_name: uriInfo
test_class.declarator: proxy
test_class.modifier: private
test_class.original_string: private JmxProxy proxy;
test_class.type: JmxProxy
test_class.var_name: proxy
test_class.file: src/server/src/test/java/io/cassandrareaper/resources/RepairRunResourceTest.java
test_class.identifier: RepairRunResourceTest
test_case.body: @Test
    public void testSplitStateParam() {
      Optional<String> stateParam = Optional.of("RUNNING");
      assertEquals(Sets.newHashSet("RUNNING"), RepairRunResource.splitStateParam(stateParam));
      stateParam = Optional.of("PAUSED,RUNNING");
      assertEquals(Sets.newHashSet("RUNNING", "PAUSED"), RepairRunResource.splitStateParam(stateParam));
      stateParam = Optional.of("NOT_EXISTING");
      assertEquals(null, RepairRunResource.splitStateParam(stateParam));
      stateParam = Optional.of("NOT_EXISTING,RUNNING");
      assertEquals(null, RepairRunResource.splitStateParam(stateParam));
      stateParam = Optional.of("RUNNING,PAUSED,");
      assertEquals(Sets.newHashSet("RUNNING", "PAUSED"), RepairRunResource.splitStateParam(stateParam));
      stateParam = Optional.of(",RUNNING,PAUSED,");
      assertEquals(Sets.newHashSet("RUNNING", "PAUSED"), RepairRunResource.splitStateParam(stateParam));
      stateParam = Optional.of("PAUSED ,RUNNING");
      assertEquals(Sets.newHashSet("RUNNING", "PAUSED"), RepairRunResource.splitStateParam(stateParam));
    }
test_case.class_method_signature: RepairRunResourceTest.testSplitStateParam()
test_case.full_signature: @Test public void testSplitStateParam()
test_case.identifier: testSplitStateParam
test_case.invocations: of assertEquals newHashSet splitStateParam of assertEquals newHashSet splitStateParam of assertEquals splitStateParam of assertEquals splitStateParam of assertEquals newHashSet splitStateParam of assertEquals newHashSet splitStateParam of assertEquals newHashSet splitStateParam
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSplitStateParam()
focal_class.declarator: LOG = LoggerFactory.getLogger(RepairRunResource.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(RepairRunResource.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: context
focal_class.modifier: private final
focal_class.original_string: private final AppContext context;
focal_class.type: AppContext
focal_class.var_name: context
focal_class.declarator: repairUnitService
focal_class.modifier: private final
focal_class.original_string: private final RepairUnitService repairUnitService;
focal_class.type: RepairUnitService
focal_class.var_name: repairUnitService
focal_class.declarator: repairRunService
focal_class.modifier: private final
focal_class.original_string: private final RepairRunService repairRunService;
focal_class.type: RepairRunService
focal_class.var_name: repairRunService
focal_class.file: src/server/src/main/java/io/cassandrareaper/resources/RepairRunResource.java
focal_class.identifier: RepairRunResource
focal_class.class_method_signature: RepairRunResource.RepairRunResource(AppContext context)
focal_class.full_signature: public  RepairRunResource(AppContext context)
focal_class.identifier: RepairRunResource
focal_class.modifiers: public
focal_class.parameters: (AppContext context)
focal_class.signature:  RepairRunResource(AppContext context)
focal_class.class_method_signature: RepairRunResource.addRepairRun(
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.full_signature: @POST public Response addRepairRun(
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.identifier: addRepairRun
focal_class.modifiers: @POST public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.return: Response
focal_class.signature: Response addRepairRun(
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.class_method_signature: RepairRunResource.checkRequestForAddRepair(
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.full_signature: @Nullable static Response checkRequestForAddRepair(
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.identifier: checkRequestForAddRepair
focal_class.modifiers: @Nullable static
focal_class.parameters: (
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.return: Response
focal_class.signature: Response checkRequestForAddRepair(
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.class_method_signature: RepairRunResource.modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.full_signature: @PUT @Path("/{id}/state/{state}") public Response modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.identifier: modifyRunState
focal_class.modifiers: @PUT @Path("/{id}/state/{state}") public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.return: Response
focal_class.signature: Response modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.class_method_signature: RepairRunResource.modifyRunIntensity(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.full_signature: @PUT @Path("/{id}/intensity/{intensity}") public Response modifyRunIntensity(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.identifier: modifyRunIntensity
focal_class.modifiers: @PUT @Path("/{id}/intensity/{intensity}") public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.return: Response
focal_class.signature: Response modifyRunIntensity(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.class_method_signature: RepairRunResource.oldModifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.full_signature: @PUT @Path("/{id}") @Deprecated public Response oldModifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.identifier: oldModifyRunState
focal_class.modifiers: @PUT @Path("/{id}") @Deprecated public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.return: Response
focal_class.signature: Response oldModifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.class_method_signature: RepairRunResource.isStarting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isStarting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isStarting
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isStarting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isPausing(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isPausing(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isPausing
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isPausing(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isResuming(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isResuming(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isResuming
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isResuming(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isRetrying(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isRetrying(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isRetrying
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isRetrying(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isAborting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isAborting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isAborting
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isAborting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isUnitAlreadyRepairing(RepairRun repairRun)
focal_class.full_signature: private boolean isUnitAlreadyRepairing(RepairRun repairRun)
focal_class.identifier: isUnitAlreadyRepairing
focal_class.modifiers: private
focal_class.parameters: (RepairRun repairRun)
focal_class.return: boolean
focal_class.signature: boolean isUnitAlreadyRepairing(RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.getSegmentAmountForRepairRun(UUID repairRunId)
focal_class.full_signature: private int getSegmentAmountForRepairRun(UUID repairRunId)
focal_class.identifier: getSegmentAmountForRepairRun
focal_class.modifiers: private
focal_class.parameters: (UUID repairRunId)
focal_class.return: int
focal_class.signature: int getSegmentAmountForRepairRun(UUID repairRunId)
focal_class.class_method_signature: RepairRunResource.startRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response startRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: startRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response startRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.pauseRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response pauseRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: pauseRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response pauseRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.resumeRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response resumeRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: resumeRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response resumeRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.abortRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response abortRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: abortRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response abortRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.updateRunIntensity(UriInfo uriInfo, RepairRun run, double intensity)
focal_class.full_signature: private Response updateRunIntensity(UriInfo uriInfo, RepairRun run, double intensity)
focal_class.identifier: updateRunIntensity
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun run, double intensity)
focal_class.return: Response
focal_class.signature: Response updateRunIntensity(UriInfo uriInfo, RepairRun run, double intensity)
focal_class.class_method_signature: RepairRunResource.getRepairRun(
        @PathParam("id") UUID repairRunId)
focal_class.full_signature: @GET @Path("/{id}") public Response getRepairRun(
        @PathParam("id") UUID repairRunId)
focal_class.identifier: getRepairRun
focal_class.modifiers: @GET @Path("/{id}") public
focal_class.parameters: (
        @PathParam("id") UUID repairRunId)
focal_class.return: Response
focal_class.signature: Response getRepairRun(
        @PathParam("id") UUID repairRunId)
focal_class.class_method_signature: RepairRunResource.getRepairRunSegments(@PathParam("id") UUID repairRunId)
focal_class.full_signature: @GET @Path("/{id}/segments") public Response getRepairRunSegments(@PathParam("id") UUID repairRunId)
focal_class.identifier: getRepairRunSegments
focal_class.modifiers: @GET @Path("/{id}/segments") public
focal_class.parameters: (@PathParam("id") UUID repairRunId)
focal_class.return: Response
focal_class.signature: Response getRepairRunSegments(@PathParam("id") UUID repairRunId)
focal_class.class_method_signature: RepairRunResource.abortRepairRunSegment(@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.full_signature: @POST @Path("/{id}/segments/abort/{segment_id}") public Response abortRepairRunSegment(@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.identifier: abortRepairRunSegment
focal_class.modifiers: @POST @Path("/{id}/segments/abort/{segment_id}") public
focal_class.parameters: (@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.return: Response
focal_class.signature: Response abortRepairRunSegment(@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.class_method_signature: RepairRunResource.getRepairRunsForCluster(
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.full_signature: @GET @Path("/cluster/{cluster_name}") public Response getRepairRunsForCluster(
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.identifier: getRepairRunsForCluster
focal_class.modifiers: @GET @Path("/cluster/{cluster_name}") public
focal_class.parameters: (
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.return: Response
focal_class.signature: Response getRepairRunsForCluster(
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.class_method_signature: RepairRunResource.getRepairRunStatus(RepairRun repairRun)
focal_class.full_signature: private RepairRunStatus getRepairRunStatus(RepairRun repairRun)
focal_class.identifier: getRepairRunStatus
focal_class.modifiers: private
focal_class.parameters: (RepairRun repairRun)
focal_class.return: RepairRunStatus
focal_class.signature: RepairRunStatus getRepairRunStatus(RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.buildRepairRunUri(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private static URI buildRepairRunUri(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: buildRepairRunUri
focal_class.modifiers: private static
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: URI
focal_class.signature: URI buildRepairRunUri(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.listRepairRuns(
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.full_signature: @GET public Response listRepairRuns(
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.identifier: listRepairRuns
focal_class.modifiers: @GET public
focal_class.parameters: (
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.return: Response
focal_class.signature: Response listRepairRuns(
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.class_method_signature: RepairRunResource.getRunStatuses(Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.full_signature: private List<RepairRunStatus> getRunStatuses(Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.identifier: getRunStatuses
focal_class.modifiers: private
focal_class.parameters: (Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.return: List<RepairRunStatus>
focal_class.signature: List<RepairRunStatus> getRunStatuses(Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.class_method_signature: RepairRunResource.splitStateParam(Optional<String> state)
focal_class.full_signature: static Set splitStateParam(Optional<String> state)
focal_class.identifier: splitStateParam
focal_class.modifiers: static
focal_class.parameters: (Optional<String> state)
focal_class.return: Set
focal_class.signature: Set splitStateParam(Optional<String> state)
focal_class.class_method_signature: RepairRunResource.deleteRepairRun(
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.full_signature: @DELETE @Path("/{id}") public Response deleteRepairRun(
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.identifier: deleteRepairRun
focal_class.modifiers: @DELETE @Path("/{id}") public
focal_class.parameters: (
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.return: Response
focal_class.signature: Response deleteRepairRun(
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.class_method_signature: RepairRunResource.purgeRepairRuns()
focal_class.full_signature: @POST @Path("/purge") public Response purgeRepairRuns()
focal_class.identifier: purgeRepairRuns
focal_class.modifiers: @POST @Path("/purge") public
focal_class.parameters: ()
focal_class.return: Response
focal_class.signature: Response purgeRepairRuns()
focal_class.class_method_signature: RepairRunResource.checkRepairParallelismString(String repairParallelism)
focal_class.full_signature: private static void checkRepairParallelismString(String repairParallelism)
focal_class.identifier: checkRepairParallelismString
focal_class.modifiers: private static
focal_class.parameters: (String repairParallelism)
focal_class.return: void
focal_class.signature: void checkRepairParallelismString(String repairParallelism)
focal_class.class_method_signature: RepairRunResource.createMissingArgumentResponse(String argumentName)
focal_class.full_signature: private static Response createMissingArgumentResponse(String argumentName)
focal_class.identifier: createMissingArgumentResponse
focal_class.modifiers: private static
focal_class.parameters: (String argumentName)
focal_class.return: Response
focal_class.signature: Response createMissingArgumentResponse(String argumentName)
focal_class.class_method_signature: RepairRunResource.parseRunState(String input)
focal_class.full_signature: private static RunState parseRunState(String input)
focal_class.identifier: parseRunState
focal_class.modifiers: private static
focal_class.parameters: (String input)
focal_class.return: RunState
focal_class.signature: RunState parseRunState(String input)
focal_class.class_method_signature: RepairRunResource.parseIntensity(String input)
focal_class.full_signature: private static double parseIntensity(String input)
focal_class.identifier: parseIntensity
focal_class.modifiers: private static
focal_class.parameters: (String input)
focal_class.return: double
focal_class.signature: double parseIntensity(String input)
focal_method.body: static Set splitStateParam(Optional<String> state) {
      if (state.isPresent()) {
        final Iterable<String> chunks = RepairRunService.COMMA_SEPARATED_LIST_SPLITTER.split(state.get());
        for (final String chunk : chunks) {
          try {
            RepairRun.RunState.valueOf(chunk.toUpperCase());
          } catch (IllegalArgumentException e) {
            LOG.warn("Listing repair runs called with erroneous states: {}", state.get(), e);
            return null;
          }
        }
        return Sets.newHashSet(chunks);
      } else {
        return Sets.newHashSet();
      }
    }
focal_method.class_method_signature: RepairRunResource.splitStateParam(Optional<String> state)
focal_method.full_signature: static Set splitStateParam(Optional<String> state)
focal_method.identifier: splitStateParam
focal_method.invocations: isPresent split get valueOf toUpperCase warn get newHashSet newHashSet
focal_method.modifiers: static
focal_method.parameters: (Optional<String> state)
focal_method.return: Set
focal_method.signature: Set splitStateParam(Optional<String> state)