Package org.apache.calcite.interpreter

Class AggregateNode.UdaAccumulator

java.lang.Object

org.apache.calcite.interpreter.AggregateNode.UdaAccumulator

All Implemented Interfaces:

AggregateNode.Accumulator

Enclosing class:

AggregateNode

private static class AggregateNode.UdaAccumulator
extends java.lang.Object
implements AggregateNode.Accumulator

Accumulator based upon a user-defined aggregate.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	empty
private AggregateNode.UdaAccumulatorFactory	factory
private java.lang.Object	value

Constructor Summary

Constructors

Constructor	Description
UdaAccumulator(AggregateNode.UdaAccumulatorFactory factory)

Method Summary

Modifier and Type	Method	Description
java.lang.Object	end()
void	send(Row row)

Methods inherited from class java.lang.Object

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

Field Detail

factory

private final AggregateNode.UdaAccumulatorFactory factory

value

private java.lang.Object value

empty

private boolean empty

Constructor Detail

UdaAccumulator

UdaAccumulator(AggregateNode.UdaAccumulatorFactory factory)

Method Detail

send

public void send(Row row)

Specified by:

send in interface AggregateNode.Accumulator

end

public java.lang.Object end()

Specified by:

end in interface AggregateNode.Accumulator