org.openjdk.jmc.flightrecorder

Class EventCollection

java.lang.Object

org.openjdk.jmc.flightrecorder.EventCollection

All Implemented Interfaces:

java.lang.Iterable<IItemIterable>, IItemCollection

class EventCollection
extends java.lang.Object
implements IItemCollection

Implementation of IItemCollection using IItemIterable iterators.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	EventCollection.EventTypeEntry

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Set<IRange<IQuantity>>	chunkRanges
private java.util.ArrayList<EventCollection.EventTypeEntry>	items
private java.util.Set<IType<IItem>>	types

Constructor Summary

Constructors

Modifier	Constructor and Description
private	EventCollection(java.util.ArrayList<EventCollection.EventTypeEntry> items, java.util.Set<IRange<IQuantity>> chunkRanges)

Method Summary

Modifier and Type	Method and Description
private static <V,C extends IItemConsumer<C>> V	aggregate(IAggregator<V,C> aggregator, java.util.Iterator<? extends IItemIterable> items)
EventCollection	apply(IItemFilter filter) Creates a new item collection with all items in this collection that pass through the filter.
(package private) static IItemCollection	build(EventArrays events)
private static java.util.Iterator<IItem>	buildIterator(IItem[] array, java.util.function.Predicate<? super IItem> filter)
<V,C extends IItemConsumer<C>> V	getAggregate(IAggregator<V,C> aggregator) Calculates an aggregated value for the items in this collection.
java.util.Set<IRange<IQuantity>>	getUnfilteredTimeRanges() Returns a set of IRange representations of the time ranges represented by this item collection.
boolean	hasItems()
private static boolean	isFiltered(java.util.function.Predicate<?> filter)
java.util.Iterator<IItemIterable>	iterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openjdk.jmc.common.item.IItemCollection

parallelStream, stream, values

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

types

private final java.util.Set<IType<IItem>> types

items

private final java.util.ArrayList<EventCollection.EventTypeEntry> items

chunkRanges

private final java.util.Set<IRange<IQuantity>> chunkRanges

Constructor Detail

EventCollection

private EventCollection(java.util.ArrayList<EventCollection.EventTypeEntry> items,
                        java.util.Set<IRange<IQuantity>> chunkRanges)

Method Detail

build

static IItemCollection build(EventArrays events)

apply

public EventCollection apply(IItemFilter filter)

Description copied from interface: IItemCollection

Creates a new item collection with all items in this collection that pass through the filter. The collection may be eagerly or lazily evaluated.

Specified by:

apply in interface IItemCollection

Parameters:

filter - the filter to use when selecting items for the new collection

Returns:

a new collection of items

buildIterator

private static java.util.Iterator<IItem> buildIterator(IItem[] array,
                                                       java.util.function.Predicate<? super IItem> filter)

isFiltered

private static boolean isFiltered(java.util.function.Predicate<?> filter)

iterator

public java.util.Iterator<IItemIterable> iterator()

Specified by:

iterator in interface java.lang.Iterable<IItemIterable>

hasItems

public boolean hasItems()

Specified by:

hasItems in interface IItemCollection

Returns:

true if the collections contains items, false otherwise

getAggregate

public <V,C extends IItemConsumer<C>> V getAggregate(IAggregator<V,C> aggregator)

Description copied from interface: IItemCollection

Calculates an aggregated value for the items in this collection.

Specified by:

getAggregate in interface IItemCollection

Type Parameters:

V - aggregate result value type

C - Item consumer type. See IAggregator.

Returns:

the aggregated value

aggregate

private static <V,C extends IItemConsumer<C>> V aggregate(IAggregator<V,C> aggregator,
                                                          java.util.Iterator<? extends IItemIterable> items)

getUnfilteredTimeRanges

public java.util.Set<IRange<IQuantity>> getUnfilteredTimeRanges()

Description copied from interface: IItemCollection

Returns a set of IRange representations of the time ranges represented by this item collection. This set is not affected by any filtering operations on the item collection since its use is to show the time ranges in which events could possibly have been occurred.

Specified by:

getUnfilteredTimeRanges in interface IItemCollection

Returns:

a set of IRange objects representing the time ranges available in this IItemCollection