Constructor. @param conf the conf for the client. @param host the host the client is to talk to. @param port the port the client is to talk to. @param

Initialize for the default implementation node sorting. @param cluster for which nodes will be sorted. @param topologyDetails the topology to sort fo

Create an instance of this from a list of values. The metrics will be computed from the values. @param values the values to compute metrics from.

Create a new normalized resource offer. @param resources the resources to be normalized.

Create an empty NormalizedResources.

Constructor. @param path the path to the resource @param fileName the filename of the resource @param size the size of the resource @param timestamp t

Creates a new OffsetManager. @param tp The TopicPartition @param initialFetchOffset The initial fetch offset for the given TopicPartition

Create a new stream with stats. @param id the id of the stream @param rate the rate of tuples being emitted on this stream @param areKeysSkewed true i

Create an engine that can simulate the given stats. @param stats the stats to follow

Constructs a new pair of values. @param first the first value @param second the second value

Constructs a new {@link PairValueMapper} that constructs a pair from a tuple based on the key and value index. @param keyIndex the key index @param

Creates filter based on a Pattern. Only topic names matching the Pattern are passed by the filter. @param pattern The Pattern to use.

For plain, using constants for a pair of user name and password.