protected static class RSSConnector.ThrottleSpec extends Object implements IThrottleSpec
Modifier and Type | Field and Description |
---|---|
protected int |
maxOpenConnectionsPerServer |
protected double |
minimumMillisecondsPerBytePerServer |
protected long |
minimumMillisecondsPerFetchPerServer |
_rcsid
Constructor and Description |
---|
RSSConnector.ThrottleSpec(int maxOpenConnectionsPerServer,
long minimumMillisecondsPerFetchPerServer,
double minimumMillisecondsPerBytePerServer) |
Modifier and Type | Method and Description |
---|---|
int |
getMaxOpenConnections(String binName)
Given a bin name, find the max open connections to use for that bin.
|
double |
getMinimumMillisecondsPerByte(String binName)
Look up minimum milliseconds per byte for a bin.
|
long |
getMinimumMillisecondsPerFetch(String binName)
Look up minimum milliseconds for a fetch for a bin.
|
protected final int maxOpenConnectionsPerServer
protected final long minimumMillisecondsPerFetchPerServer
protected final double minimumMillisecondsPerBytePerServer
public RSSConnector.ThrottleSpec(int maxOpenConnectionsPerServer, long minimumMillisecondsPerFetchPerServer, double minimumMillisecondsPerBytePerServer)
public int getMaxOpenConnections(String binName)
getMaxOpenConnections
in interface IThrottleSpec
public double getMinimumMillisecondsPerByte(String binName)
getMinimumMillisecondsPerByte
in interface IThrottleSpec
public long getMinimumMillisecondsPerFetch(String binName)
getMinimumMillisecondsPerFetch
in interface IThrottleSpec