streamcruncher.test.func.generic
Class TimeWF2PartitionAggTest.TestAggregatorHelper

java.lang.Object
  streamcruncher.api.aggregator.AbstractAggregatorHelper
      streamcruncher.test.func.generic.TimeWF2PartitionAggTest.TestAggregatorHelper

Enclosing class:

TimeWF2PartitionAggTest

public static class TimeWF2PartitionAggTest.TestAggregatorHelper
extends AbstractAggregatorHelper

Constructor Summary

TimeWF2PartitionAggTest.TestAggregatorHelper()

Method Summary

java.lang.String

getAggregatedColumnDDLFragment(DBName dbName, java.lang.String[] params, java.util.LinkedHashMap<java.lang.String,java.lang.String> columnNamesAndTypes)

Methods inherited from class streamcruncher.api.aggregator.AbstractAggregatorHelper

getAggregatorClass, getFunctionName

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeWF2PartitionAggTest.TestAggregatorHelper

public TimeWF2PartitionAggTest.TestAggregatorHelper()

Method Detail

getAggregatedColumnDDLFragment

public java.lang.String getAggregatedColumnDDLFragment(DBName dbName,
                                                       java.lang.String[] params,
                                                       java.util.LinkedHashMap<java.lang.String,java.lang.String> columnNamesAndTypes)
                                                throws java.lang.Exception

Specified by:

getAggregatedColumnDDLFragment in class AbstractAggregatorHelper

params - That parameters that were provided in the Query to the Function. Ex: A definition such as with custom(test_fn, order_id, J) as test_fn_val) will produce String[]{"order_id", "J"}

columnNamesAndTypes - The names and SQL Native Types in the Source Table.

Returns:

"varchar2(10)" or "integer".

Throws:

java.lang.Exception - If aggregation is not possible on the columns chosen.