Package org.apache.vxquery.runtime.functions.util

Class FunctionHelper

java.lang.Object

org.apache.vxquery.runtime.functions.util.FunctionHelper

public class FunctionHelper
extends Object

Constructor Summary

Constructors

Constructor	Description
FunctionHelper()

Method Summary

Modifier and Type	Method	Description
static void	arithmeticOperation(AbstractArithmeticOperation aOp, DynamicContext dCtx, TaggedValuePointable tvp1, TaggedValuePointable tvp2, org.apache.hyracks.data.std.api.IPointable result, TypedPointables tp1, TypedPointables tp2)
static boolean	arraysEqual(byte[] bytes1, int offset1, int length1, byte[] bytes2, int offset2, int length2)
static boolean	arraysEqual(org.apache.hyracks.data.std.api.IPointable p1, org.apache.hyracks.data.std.api.IPointable p2)
static boolean	compareTaggedValues(AbstractValueComparisonOperation aOp, TaggedValuePointable tvp1, TaggedValuePointable tvp2, DynamicContext dCtx, TypedPointables tp1, TypedPointables tp2)
static int	getBaseTypeForArithmetics(int tid)
static int	getBaseTypeForComparisons(int tid)
static int	getBaseTypeForGeneralComparisons(int tid)
static void	getDoublePointable(TaggedValuePointable tvp, DataOutput dOut, TypedPointables tp)
static void	getIntegerPointable(TaggedValuePointable tvp, DataOutput dOut, TypedPointables tp)
static int	getLocalNodeId(TaggedValuePointable tvp1, TypedPointables tp)	Get the local node id from a tagged value pointable when available.
static int	getNumberOfDigits(long value)	Returns the number of digits in a long.
static long	getPowerOf10(double value, long max, long min)
static String	getStringFromPointable(org.apache.hyracks.data.std.primitive.UTF8StringPointable stringp, org.apache.hyracks.dataflow.common.comm.util.ByteBufferInputStream bbis, DataInputStream di)
static long	getTimezone(ITimezone timezonep)
static boolean	isDerivedFromDouble(int tid)
static boolean	isDerivedFromInteger(int tid)
static boolean	isDerivedFromString(int tid)
static boolean	isNumberPostive(long value)	Returns 0 if positive, nonzero if negative.
static void	printUTF8String(org.apache.hyracks.data.std.primitive.UTF8StringPointable stringp)
static void	readInDocFromPointable(org.apache.hyracks.data.std.primitive.UTF8StringPointable stringp, org.apache.hyracks.dataflow.common.comm.util.ByteBufferInputStream bbis, DataInputStream di, org.apache.hyracks.data.std.util.ArrayBackedValueStorage abvs, XMLParser parser)
static boolean	transformThenCompareMinMaxTaggedValues(AbstractValueComparisonOperation aOp, TaggedValuePointable tvp1, TaggedValuePointable tvp2, DynamicContext dCtx, TypedPointables tp1, TypedPointables tp2)
static void	writeChar(char c, DataOutput dOut)
static void	writeCharArray(char[] ch, int start, int length, DataOutput dOut)
static void	writeCharSequence(CharSequence charSequence, DataOutput dOut)
static void	writeDateAsString(IDate date, DataOutput dOut)
static void	writeNumberWithPadding(long value, int padding, DataOutput dOut)	Writes a number to the DataOutput with zeros as place holders if the number is too small to fill the padding.
static void	writeTimeAsString(ITime time, DataOutput dOut)
static void	writeTimezoneAsString(ITimezone timezone, DataOutput dOut)

Methods inherited from class java.lang.Object

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

Constructor Detail

FunctionHelper

public FunctionHelper()

Method Detail

arithmeticOperation

public static void arithmeticOperation(AbstractArithmeticOperation aOp,
                                       DynamicContext dCtx,
                                       TaggedValuePointable tvp1,
                                       TaggedValuePointable tvp2,
                                       org.apache.hyracks.data.std.api.IPointable result,
                                       TypedPointables tp1,
                                       TypedPointables tp2)
                                throws SystemException

Throws:

SystemException

arraysEqual

public static boolean arraysEqual(org.apache.hyracks.data.std.api.IPointable p1,
                                  org.apache.hyracks.data.std.api.IPointable p2)

arraysEqual

public static boolean arraysEqual(byte[] bytes1,
                                  int offset1,
                                  int length1,
                                  byte[] bytes2,
                                  int offset2,
                                  int length2)

compareTaggedValues

public static boolean compareTaggedValues(AbstractValueComparisonOperation aOp,
                                          TaggedValuePointable tvp1,
                                          TaggedValuePointable tvp2,
                                          DynamicContext dCtx,
                                          TypedPointables tp1,
                                          TypedPointables tp2)
                                   throws SystemException

Throws:

SystemException

getBaseTypeForArithmetics

public static int getBaseTypeForArithmetics(int tid)
                                     throws SystemException

Throws:

SystemException

getBaseTypeForComparisons

public static int getBaseTypeForComparisons(int tid)
                                     throws SystemException

Throws:

SystemException

getBaseTypeForGeneralComparisons

public static int getBaseTypeForGeneralComparisons(int tid)
                                            throws SystemException

Throws:

SystemException

getDoublePointable

public static void getDoublePointable(TaggedValuePointable tvp,
                                      DataOutput dOut,
                                      TypedPointables tp)
                               throws SystemException,
                                      IOException

Throws:

SystemException

IOException

getIntegerPointable

public static void getIntegerPointable(TaggedValuePointable tvp,
                                       DataOutput dOut,
                                       TypedPointables tp)
                                throws SystemException,
                                       IOException

Throws:

SystemException

IOException

getLocalNodeId

public static int getLocalNodeId(TaggedValuePointable tvp1,
                                 TypedPointables tp)

Get the local node id from a tagged value pointable when available.

Parameters:

tvp1 - pointable

tp - Typed pointable

Returns:

local node id

getNumberOfDigits

public static int getNumberOfDigits(long value)

Returns the number of digits in a long. A few special cases that needed attention.

Parameters:

value - value

Returns:

Number of digits

getPowerOf10

public static long getPowerOf10(double value,
                                long max,
                                long min)

getStringFromPointable

public static String getStringFromPointable(org.apache.hyracks.data.std.primitive.UTF8StringPointable stringp,
                                            org.apache.hyracks.dataflow.common.comm.util.ByteBufferInputStream bbis,
                                            DataInputStream di)
                                     throws SystemException

Throws:

SystemException

getTimezone

public static long getTimezone(ITimezone timezonep)

isDerivedFromDouble

public static boolean isDerivedFromDouble(int tid)

isDerivedFromInteger

public static boolean isDerivedFromInteger(int tid)

isDerivedFromString

public static boolean isDerivedFromString(int tid)

isNumberPostive

public static boolean isNumberPostive(long value)

Returns 0 if positive, nonzero if negative.

Parameters:

value - value

Returns:

boolean

printUTF8String

public static void printUTF8String(org.apache.hyracks.data.std.primitive.UTF8StringPointable stringp)

readInDocFromPointable

public static void readInDocFromPointable(org.apache.hyracks.data.std.primitive.UTF8StringPointable stringp,
                                          org.apache.hyracks.dataflow.common.comm.util.ByteBufferInputStream bbis,
                                          DataInputStream di,
                                          org.apache.hyracks.data.std.util.ArrayBackedValueStorage abvs,
                                          XMLParser parser)
                                   throws org.apache.hyracks.api.exceptions.HyracksDataException

Throws:

org.apache.hyracks.api.exceptions.HyracksDataException

transformThenCompareMinMaxTaggedValues

public static boolean transformThenCompareMinMaxTaggedValues(AbstractValueComparisonOperation aOp,
                                                             TaggedValuePointable tvp1,
                                                             TaggedValuePointable tvp2,
                                                             DynamicContext dCtx,
                                                             TypedPointables tp1,
                                                             TypedPointables tp2)
                                                      throws SystemException

Throws:

SystemException

writeChar

public static void writeChar(char c,
                             DataOutput dOut)

writeCharSequence

public static void writeCharSequence(CharSequence charSequence,
                                     DataOutput dOut)

writeCharArray

public static void writeCharArray(char[] ch,
                                  int start,
                                  int length,
                                  DataOutput dOut)

writeDateAsString

public static void writeDateAsString(IDate date,
                                     DataOutput dOut)

writeNumberWithPadding

public static void writeNumberWithPadding(long value,
                                          int padding,
                                          DataOutput dOut)

Writes a number to the DataOutput with zeros as place holders if the number is too small to fill the padding.

Parameters:

value - value

padding - padding

dOut - data output

writeTimeAsString

public static void writeTimeAsString(ITime time,
                                     DataOutput dOut)

writeTimezoneAsString

public static void writeTimezoneAsString(ITimezone timezone,
                                         DataOutput dOut)