com.espertech.esper.event

Class EventBeanUtility

java.lang.Object

com.espertech.esper.event.EventBeanUtility

public class EventBeanUtility
extends Object

Method to getSelectListEvents events in collections to other collections or other event types.

Constructor Summary

Constructors

Constructor and Description
EventBeanUtility()

Method Summary

Modifier and Type	Method and Description
static EventBean[]	addToArray(EventBean[] array, Collection<EventBean> eventsToAdd) Expand the array passed in by the multiple elements to add.
static EventBean[]	addToArray(EventBean[] array, EventBean eventToAdd) Expand the array passed in by the single element to add.
static void	addToCollection(EventBean[] toAdd, Collection<EventBean> events)
static void	addToCollection(Set<MultiKey<EventBean>> toAdd, Collection<MultiKey<EventBean>> events)
static EventBean[]	allocatePerStreamShift(EventBean[] eventsPerStream)
protected static EventBean[]	append(EventBean[] source, EventBean[] append) Append arrays.
static void	appendEvent(StringWriter writer, EventBean theEvent)
static Object	coerce(Object target, Class coercionType)
static boolean	compareEventReferences(EventBean[] firstNonNull, EventBean[] secondNonNull)
static EventBean[]	copyArray(EventBean[] events)
static FragmentEventType	createNativeFragmentType(Class propertyType, Class genericType, EventAdapterService eventAdapterService) Create a fragment event type.
static EventBean[]	denaturalize(EventBean[] naturals)
static boolean	eventsAreEqualsAllowNull(EventBean first, EventBean second)
static EventBean[]	flatten(ArrayDeque<EventBean[]> eventVector) Flatten the vector of arrays to an array.
static UniformPair<Set<MultiKey<EventBean>>>	flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings) Flattens a list of pairs of join result sets.
static UniformPair<EventBean[]>	flattenBatchStream(List<UniformPair<EventBean[]>> updateVector) Flatten the vector of arrays to an array.
static UniformPair<EventBean[]>	flattenList(ArrayDeque<UniformPair<EventBean[]>> eventVector) Flatten the vector of arrays to an array.
static EventPropertyGetter	getAssertPropertyGetter(EventType[] eventTypes, int keyStreamNum, String property)
static EventPropertyGetter	getAssertPropertyGetter(EventType type, String propertyName)
static EventBean[]	getDistinctByProp(ArrayDeque<EventBean> events, EventBeanReader reader) Returns the distinct events by properties.
static EventBean[]	getDistinctByProp(EventBean[] events, EventBeanReader reader) Returns the distinct events by properties.
static MultiKey<EventBean>	getLastInSet(Set<MultiKey<EventBean>> events)
static MultiKeyUntyped	getMultiKey(EventBean[] eventsPerStream, ExprEvaluator[] evaluators, ExprEvaluatorContext context, Class[] coercionTypes)
static MultiKeyUntyped	getMultiKey(EventBean theEvent, EventPropertyGetter[] propertyGetters) Returns Multikey instance for given event and getters.
static MultiKeyUntyped	getMultiKey(EventBean theEvent, EventPropertyGetter[] propertyGetters, Class[] coercionTypes)
static EventBean[]	getNewDataNonRemoved(EventBean[] newData, HashSet<EventBean> removedEvents)
static EventBean[]	getNewDataNonRemoved(EventBean[] newData, HashSet<EventBean> removedEvents, EventBean[][] newEventsPerView)
static EventBean	getNonemptyFirstEvent(Collection<EventBean> matchingEvents) NOTE: Code-generation-invoked method, method name and parameter order matters
static Object	getNonemptyFirstEventUnderlying(Collection<EventBean> matchingEvents)
static Object[]	getPropertyArray(EventBean[] eventsPerStream, EventPropertyGetter[] propertyGetters, int[] streamNums)
static Object[]	getPropertyArray(EventBean theEvent, EventPropertyGetter[] propertyGetters) Returns object array containing property values of given properties, retrieved via EventPropertyGetter instances.
static String	printEvent(EventBean theEvent) Format the event and return a string representation.
static String	printEvents(EventBean[] events)
static EventBean[]	resizeArray(EventBean[] oldArray, int newSize) Resizes an array of events to a new size.
static void	safeArrayCopy(EventBean[] eventsPerStream, EventBean[] eventsLambda)
static String	summarize(EventBean theEvent)
static String	summarize(EventBean[] events)
static void	summarize(EventBean theEvent, StringWriter writer)
static String	summarizeUnderlying(Object underlying)
static void	summarizeUnderlying(Object underlying, StringWriter writer)
static EventBean[]	toArray(Collection<EventBean> eventList) Convert list of events to array, returning null for empty or null lists.
static EventBean[]	toArrayIfNotNull(EventBean optionalEvent)
static EventBean[]	toArrayNullIfEmpty(Collection<EventBean> events)
static Set<MultiKey<EventBean>>	toLinkedHashSetNullIfEmpty(Collection<MultiKey<EventBean>> events)
static Set<MultiKey<EventBean>>	toSingletonSetIfNotNull(MultiKey<EventBean> row)
static String	toString(Map<String,Object> map) Renders a map of elements, in which elements can be events or event arrays interspersed with other objects,

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBeanUtility

public EventBeanUtility()

Method Detail

allocatePerStreamShift

public static EventBean[] allocatePerStreamShift(EventBean[] eventsPerStream)

getNonemptyFirstEventUnderlying

public static Object getNonemptyFirstEventUnderlying(Collection<EventBean> matchingEvents)

getNonemptyFirstEvent

public static EventBean getNonemptyFirstEvent(Collection<EventBean> matchingEvents)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

matchingEvents - events

Returns:

event

getAssertPropertyGetter

public static EventPropertyGetter getAssertPropertyGetter(EventType type,
                                                          String propertyName)

getAssertPropertyGetter

public static EventPropertyGetter getAssertPropertyGetter(EventType[] eventTypes,
                                                          int keyStreamNum,
                                                          String property)

resizeArray

public static EventBean[] resizeArray(EventBean[] oldArray,
                                      int newSize)

Resizes an array of events to a new size.

Returns the same array reference if the size is the same.

Parameters:

oldArray - array to resize

newSize - new array size

Returns:

resized array

flattenList

public static UniformPair<EventBean[]> flattenList(ArrayDeque<UniformPair<EventBean[]>> eventVector)

Flatten the vector of arrays to an array. Return null if an empty vector was passed, else return an array containing all the events.

Parameters:

eventVector - vector

Returns:

array with all events

flatten

public static EventBean[] flatten(ArrayDeque<EventBean[]> eventVector)

Flatten the vector of arrays to an array. Return null if an empty vector was passed, else return an array containing all the events.

Parameters:

eventVector - vector

Returns:

array with all events

flattenBatchStream

public static UniformPair<EventBean[]> flattenBatchStream(List<UniformPair<EventBean[]>> updateVector)

Flatten the vector of arrays to an array. Return null if an empty vector was passed, else return an array containing all the events.

Parameters:

updateVector - is a list of updates of old and new events

Returns:

array with all events

append

protected static EventBean[] append(EventBean[] source,
                                    EventBean[] append)

Append arrays.

Parameters:

source - array

append - array

Returns:

appended array

toArray

public static EventBean[] toArray(Collection<EventBean> eventList)

Convert list of events to array, returning null for empty or null lists.

Parameters:

eventList - is a list of events to convert

Returns:

array of events

getPropertyArray

public static Object[] getPropertyArray(EventBean theEvent,
                                        EventPropertyGetter[] propertyGetters)

Returns object array containing property values of given properties, retrieved via EventPropertyGetter instances.

Parameters:

theEvent - - event to get property values from

propertyGetters - - getters to use for getting property values

Returns:

object array with property values

getPropertyArray

public static Object[] getPropertyArray(EventBean[] eventsPerStream,
                                        EventPropertyGetter[] propertyGetters,
                                        int[] streamNums)

getMultiKey

public static MultiKeyUntyped getMultiKey(EventBean theEvent,
                                          EventPropertyGetter[] propertyGetters)

Returns Multikey instance for given event and getters.

Parameters:

theEvent - - event to get property values from

propertyGetters - - getters for access to properties

Returns:

MultiKey with property values

getMultiKey

public static MultiKeyUntyped getMultiKey(EventBean theEvent,
                                          EventPropertyGetter[] propertyGetters,
                                          Class[] coercionTypes)

getMultiKey

public static MultiKeyUntyped getMultiKey(EventBean[] eventsPerStream,
                                          ExprEvaluator[] evaluators,
                                          ExprEvaluatorContext context,
                                          Class[] coercionTypes)

coerce

public static Object coerce(Object target,
                            Class coercionType)

printEvent

public static String printEvent(EventBean theEvent)

Format the event and return a string representation.

Parameters:

theEvent - is the event to format.

Returns:

string representation of event

printEvents

public static String printEvents(EventBean[] events)

appendEvent

public static void appendEvent(StringWriter writer,
                               EventBean theEvent)

flattenBatchJoin

public static UniformPair<Set<MultiKey<EventBean>>> flattenBatchJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinPostings)

Flattens a list of pairs of join result sets.

Parameters:

joinPostings - is the list

Returns:

is the consolidate sets

addToArray

public static EventBean[] addToArray(EventBean[] array,
                                     EventBean eventToAdd)

Expand the array passed in by the single element to add.

Parameters:

array - to expand

eventToAdd - element to add

Returns:

resized array

addToArray

public static EventBean[] addToArray(EventBean[] array,
                                     Collection<EventBean> eventsToAdd)

Expand the array passed in by the multiple elements to add.

Parameters:

array - to expand

eventsToAdd - elements to add

Returns:

resized array

createNativeFragmentType

public static FragmentEventType createNativeFragmentType(Class propertyType,
                                                         Class genericType,
                                                         EventAdapterService eventAdapterService)

Create a fragment event type.

Parameters:

propertyType - property return type

genericType - property generic type parameter, or null if none

eventAdapterService - for event types

Returns:

fragment type

getDistinctByProp

public static EventBean[] getDistinctByProp(ArrayDeque<EventBean> events,
                                            EventBeanReader reader)

Returns the distinct events by properties.

Parameters:

events - to inspect

reader - for retrieving properties

Returns:

distinct events

getDistinctByProp

public static EventBean[] getDistinctByProp(EventBean[] events,
                                            EventBeanReader reader)

Returns the distinct events by properties.

Parameters:

events - to inspect

reader - for retrieving properties

Returns:

distinct events

denaturalize

public static EventBean[] denaturalize(EventBean[] naturals)

eventsAreEqualsAllowNull

public static boolean eventsAreEqualsAllowNull(EventBean first,
                                               EventBean second)

summarize

public static String summarize(EventBean theEvent)

summarize

public static void summarize(EventBean theEvent,
                             StringWriter writer)

summarizeUnderlying

public static String summarizeUnderlying(Object underlying)

summarizeUnderlying

public static void summarizeUnderlying(Object underlying,
                                       StringWriter writer)

summarize

public static String summarize(EventBean[] events)

safeArrayCopy

public static void safeArrayCopy(EventBean[] eventsPerStream,
                                 EventBean[] eventsLambda)

getNewDataNonRemoved

public static EventBean[] getNewDataNonRemoved(EventBean[] newData,
                                               HashSet<EventBean> removedEvents)

getNewDataNonRemoved

public static EventBean[] getNewDataNonRemoved(EventBean[] newData,
                                               HashSet<EventBean> removedEvents,
                                               EventBean[][] newEventsPerView)

toString

public static String toString(Map<String,Object> map)

Renders a map of elements, in which elements can be events or event arrays interspersed with other objects,

Parameters:

map - to render

Returns:

comma-separated list of map entry name-value pairs

addToCollection

public static void addToCollection(EventBean[] toAdd,
                                   Collection<EventBean> events)

addToCollection

public static void addToCollection(Set<MultiKey<EventBean>> toAdd,
                                   Collection<MultiKey<EventBean>> events)

toArrayNullIfEmpty

public static EventBean[] toArrayNullIfEmpty(Collection<EventBean> events)

toLinkedHashSetNullIfEmpty

public static Set<MultiKey<EventBean>> toLinkedHashSetNullIfEmpty(Collection<MultiKey<EventBean>> events)

toSingletonSetIfNotNull

public static Set<MultiKey<EventBean>> toSingletonSetIfNotNull(MultiKey<EventBean> row)

getLastInSet

public static MultiKey<EventBean> getLastInSet(Set<MultiKey<EventBean>> events)

toArrayIfNotNull

public static EventBean[] toArrayIfNotNull(EventBean optionalEvent)

compareEventReferences

public static boolean compareEventReferences(EventBean[] firstNonNull,
                                             EventBean[] secondNonNull)

copyArray

public static EventBean[] copyArray(EventBean[] events)