Class AGGCommand

java.lang.Object

org.infinispan.server.resp.RespCommand

org.infinispan.server.resp.commands.sortedset.internal.AGGCommand

All Implemented Interfaces:

BaseResp3Command, Resp3Command

Direct Known Subclasses:

ZINTER, ZINTERSTORE, ZUNION, ZUNIONSTORE

public abstract class AGGCommand
extends RespCommand
implements Resp3Command

Common implementation for UNION and INTER commands

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static enum	AGGCommand.AGGCommandType

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AGGREGATE
static final String	WEIGHTS
static final String	WITHSCORES

Fields inherited from class RespCommand

log

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AGGCommand(int arity, int firstKeyPos, int lastKeyPos, int steps, AGGCommand.AGGCommandType aggCommandType, long aclMask)

Method Summary

Modifier and Type	Method	Description
CompletionStage<RespRequestHandler>	perform(Resp3Handler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)

Methods inherited from class RespCommand

aclMask, extractKeys, fromByteBuf, fromString, getArity, getFirstKeyPos, getLastKeyPos, getName, getSteps, handleException, hasValidNumberOfArguments, match, size, toString

Methods inherited from class Object

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

Methods inherited from interface BaseResp3Command

aclMask

Field Details

WEIGHTS

public static final String WEIGHTS

See Also:

• Constant Field Values

AGGREGATE

public static final String AGGREGATE

See Also:

• Constant Field Values

WITHSCORES

public static final String WITHSCORES

See Also:

• Constant Field Values

Constructor Details

AGGCommand

protected AGGCommand(int arity,
 int firstKeyPos,
 int lastKeyPos,
 int steps,
 AGGCommand.AGGCommandType aggCommandType,
 long aclMask)

Method Details

perform

public CompletionStage<RespRequestHandler> perform(Resp3Handler handler,
 io.netty.channel.ChannelHandlerContext ctx,
 List<byte[]> arguments)

Specified by:

perform in interface Resp3Command