io.pravega.client.stream

Class ScalingPolicy

java.lang.Object

io.pravega.client.stream.ScalingPolicy

All Implemented Interfaces:

Serializable

public class ScalingPolicy
extends Object
implements Serializable

A policy that specifies how the number of segments in a stream should scale over time.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ScalingPolicy.Type

Constructor Summary

Constructors

Constructor and Description
ScalingPolicy()

Method Summary

Modifier and Type	Method and Description
static ScalingPolicy	byDataRate(int targetKBps, int scaleFactor, int minNumSegments)
static ScalingPolicy	byEventRate(int targetRate, int scaleFactor, int minNumSegments)
static ScalingPolicy	fixed(int numSegments)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ScalingPolicy

public ScalingPolicy()

Method Detail

fixed

public static ScalingPolicy fixed(int numSegments)

byEventRate

public static ScalingPolicy byEventRate(int targetRate,
                                        int scaleFactor,
                                        int minNumSegments)

byDataRate

public static ScalingPolicy byDataRate(int targetKBps,
                                       int scaleFactor,
                                       int minNumSegments)