SourceRecordDequeBuilder (connect-utils 1.0.3 API)

public class SourceRecordDequeBuilder
extends Object

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`int`	`batchSize()`
`SourceRecordDequeBuilder`	`batchSize(int batchSize)`
`SourceRecordDeque`	`build()`
`int`	`emptyWaitMs()`
`SourceRecordDequeBuilder`	`emptyWaitMs(int emptyWaitMs)`
`int`	`maximumCapacity()`
`SourceRecordDequeBuilder`	`maximumCapacity(int maximumCapacity)`
`int`	`maximumCapacityTimeoutMs()`
`SourceRecordDequeBuilder`	`maximumCapacityTimeoutMs(int maximumCapacityTimeoutMs)`
`int`	`maximumCapacityWaitMs()`
`SourceRecordDequeBuilder`	`maximumCapacityWaitMs(int maximumCapacityWaitMs)`
`static SourceRecordDequeBuilder`	`of()`
`com.google.common.util.concurrent.RateLimiter`	`writeRateLimiter()`
`SourceRecordDequeBuilder`	`writeRateLimiter(com.google.common.util.concurrent.RateLimiter writeRateLimiter)`

public SourceRecordDequeBuilder maximumCapacity(int maximumCapacity)

public SourceRecordDequeBuilder batchSize(int batchSize)

public SourceRecordDequeBuilder emptyWaitMs(int emptyWaitMs)

public SourceRecordDequeBuilder maximumCapacityWaitMs(int maximumCapacityWaitMs)

public SourceRecordDequeBuilder maximumCapacityTimeoutMs(int maximumCapacityTimeoutMs)

public com.google.common.util.concurrent.RateLimiter writeRateLimiter()

public SourceRecordDequeBuilder writeRateLimiter(com.google.common.util.concurrent.RateLimiter writeRateLimiter)

public static final SourceRecordDequeBuilder of()

Class SourceRecordDequeBuilder