public class DruidCoordinatorCleanupPendingSegments extends Object implements DruidCoordinatorHelper
Constructor and Description |
---|
DruidCoordinatorCleanupPendingSegments(IndexingServiceClient indexingServiceClient) |
Modifier and Type | Method and Description |
---|---|
DruidCoordinatorRuntimeParams |
run(DruidCoordinatorRuntimeParams params)
Implementations of this method run various activities performed by the coordinator.
|
@Inject public DruidCoordinatorCleanupPendingSegments(IndexingServiceClient indexingServiceClient)
public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params)
DruidCoordinatorHelper
run
in interface DruidCoordinatorHelper
Copyright © 2011–2018. All rights reserved.