org.apache.flink.mesos.scheduler

Interface TaskSchedulerBuilder

public interface TaskSchedulerBuilder

A builder for the Fenzo task scheduler.

Note that the Fenzo-provided TaskScheduler.Builder cannot be mocked, which motivates this interface.

Method Summary

Modifier and Type	Method and Description
com.netflix.fenzo.TaskScheduler	build() Build a Fenzo task scheduler.
TaskSchedulerBuilder	withLeaseOfferExpirySecs(long leaseOfferExpirySecs) Specify the expiration time for unused resource offers.
TaskSchedulerBuilder	withLeaseRejectAction(com.netflix.fenzo.functions.Action1<com.netflix.fenzo.VirtualMachineLease> action) Set the callback action for rejecting a lease.
TaskSchedulerBuilder	withRejectAllExpiredOffers() Set up TaskScheduler to reject all offers on expiry.

Method Detail

withLeaseRejectAction

TaskSchedulerBuilder withLeaseRejectAction(com.netflix.fenzo.functions.Action1<com.netflix.fenzo.VirtualMachineLease> action)

Set the callback action for rejecting a lease.

withRejectAllExpiredOffers

TaskSchedulerBuilder withRejectAllExpiredOffers()

Set up TaskScheduler to reject all offers on expiry.

withLeaseOfferExpirySecs

TaskSchedulerBuilder withLeaseOfferExpirySecs(long leaseOfferExpirySecs)

Specify the expiration time for unused resource offers.

build

com.netflix.fenzo.TaskScheduler build()

Build a Fenzo task scheduler.