Package org.apache.calcite.interpreter

Class AggregateNode.ScalarAccumulator

java.lang.Object

org.apache.calcite.interpreter.AggregateNode.ScalarAccumulator

All Implemented Interfaces:

AggregateNode.Accumulator

Enclosing class:

AggregateNode

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

Accumulator powered by Scalar code fragments.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) AggregateNode.ScalarAccumulatorDef	def
(package private) java.lang.Object[]	values

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ScalarAccumulator(AggregateNode.ScalarAccumulatorDef def, java.lang.Object[] values)

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

def

final AggregateNode.ScalarAccumulatorDef def

values

final java.lang.Object[] values

Constructor Detail

ScalarAccumulator

private ScalarAccumulator(AggregateNode.ScalarAccumulatorDef def,
                          java.lang.Object[] values)

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