Package redis.clients.jedis.timeseries

Class TSMRangeParams

java.lang.Object

redis.clients.jedis.timeseries.TSMRangeParams

All Implemented Interfaces:

IParams

public class TSMRangeParams
extends Object
implements IParams

Represents optional arguments of TS.MRANGE and TS.MREVRANGE commands.

Field Summary

Fields

Modifier and Type	Field	Description
private AggregationType	aggregationType
private byte[]	align
private long	bucketDuration
private byte[]	bucketTimestamp
private Integer	count
private boolean	empty
private long[]	filterByTimestamps
private double[]	filterByValues
private String[]	filters
private Long	fromTimestamp
private String	groupByLabel
private String	groupByReduce
private boolean	latest
private String[]	selectedLabels
private Long	toTimestamp
private boolean	withLabels

Constructor Summary

Constructors

Constructor	Description
TSMRangeParams()
TSMRangeParams(long fromTimestamp, long toTimestamp)

Method Summary

Modifier and Type	Method	Description
void	addParams(CommandArguments args)
TSMRangeParams	aggregation(AggregationType aggregationType, long bucketDuration)
private TSMRangeParams	align(byte[] raw)
TSMRangeParams	align(long timestamp)	This requires AGGREGATION.
TSMRangeParams	alignEnd()	This requires AGGREGATION.
TSMRangeParams	alignStart()	This requires AGGREGATION.
TSMRangeParams	bucketTimestamp(String bucketTimestamp)	This requires AGGREGATION.
TSMRangeParams	bucketTimestampHigh()	This requires AGGREGATION.
TSMRangeParams	bucketTimestampLow()	This requires AGGREGATION.
TSMRangeParams	bucketTimestampMid()	This requires AGGREGATION.
TSMRangeParams	count(int count)
TSMRangeParams	empty()	This requires AGGREGATION.
TSMRangeParams	filter(String... filters)
TSMRangeParams	filterByTS(long... timestamps)
TSMRangeParams	filterByValues(double min, double max)
TSMRangeParams	fromTimestamp(long fromTimestamp)
TSMRangeParams	groupBy(String label, String reduce)
TSMRangeParams	latest()
static TSMRangeParams	multiRangeParams()
static TSMRangeParams	multiRangeParams(long fromTimestamp, long toTimestamp)
TSMRangeParams	selectedLabels(String... labels)
TSMRangeParams	toTimestamp(long toTimestamp)
TSMRangeParams	withLabels()
TSMRangeParams	withLabels(boolean withLabels)

Methods inherited from class java.lang.Object

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

Field Details

fromTimestamp

private Long fromTimestamp

toTimestamp

private Long toTimestamp

latest

private boolean latest

filterByTimestamps

private long[] filterByTimestamps

filterByValues

private double[] filterByValues

withLabels

private boolean withLabels

selectedLabels

private String[] selectedLabels

count

private Integer count

align

private byte[] align

aggregationType

private AggregationType aggregationType

bucketDuration

private long bucketDuration

bucketTimestamp

private byte[] bucketTimestamp

empty

private boolean empty

filters

private String[] filters

groupByLabel

private String groupByLabel

groupByReduce

private String groupByReduce

Constructor Details

TSMRangeParams

public TSMRangeParams(long fromTimestamp,
 long toTimestamp)

TSMRangeParams

public TSMRangeParams()

Method Details

multiRangeParams

public static TSMRangeParams multiRangeParams(long fromTimestamp,
 long toTimestamp)

multiRangeParams

public static TSMRangeParams multiRangeParams()

fromTimestamp

public TSMRangeParams fromTimestamp(long fromTimestamp)

toTimestamp

public TSMRangeParams toTimestamp(long toTimestamp)

latest

public TSMRangeParams latest()

filterByTS

public TSMRangeParams filterByTS(long... timestamps)

filterByValues

public TSMRangeParams filterByValues(double min,
 double max)

withLabels

public TSMRangeParams withLabels(boolean withLabels)

withLabels

public TSMRangeParams withLabels()

selectedLabels

public TSMRangeParams selectedLabels(String... labels)

count

public TSMRangeParams count(int count)

align

private TSMRangeParams align(byte[] raw)

align

public TSMRangeParams align(long timestamp)

This requires AGGREGATION.

alignStart

public TSMRangeParams alignStart()

This requires AGGREGATION.

alignEnd

public TSMRangeParams alignEnd()

This requires AGGREGATION.

aggregation

public TSMRangeParams aggregation(AggregationType aggregationType,
 long bucketDuration)

bucketTimestamp

public TSMRangeParams bucketTimestamp(String bucketTimestamp)

This requires AGGREGATION.

bucketTimestampLow

public TSMRangeParams bucketTimestampLow()

This requires AGGREGATION.

bucketTimestampHigh

public TSMRangeParams bucketTimestampHigh()

This requires AGGREGATION.

bucketTimestampMid

public TSMRangeParams bucketTimestampMid()

This requires AGGREGATION.

empty

public TSMRangeParams empty()

This requires AGGREGATION.

filter

public TSMRangeParams filter(String... filters)

groupBy

public TSMRangeParams groupBy(String label,
 String reduce)

addParams

public void addParams(CommandArguments args)

Specified by:

addParams in interface IParams