Package | Description |
---|---|
com.bigdata.counters.render | |
com.bigdata.resources |
This package provides the logic to managed the live journal and the
historical journals and index segments for a
DataService . |
com.bigdata.service |
This package provides implementations of bigdata services (metadata
service, data service, transaction manager service.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
XHTMLRenderer.acceptEvent(Event e)
Applies the
URLQueryModel.eventFilters to the event. |
protected String |
XHTMLRenderer.getEventKey(Event e)
The key for an event group is formed by combining the String value of the
fields of the event identified by the orderEventBy[] in order and using a
":" when combining two or more event fields together.
|
protected String |
XHTMLRenderer.getEventTable(Event e) |
protected void |
XHTMLRenderer.writeEventFlyover(Writer w,
Event e)
Pretty up an event by rendering onto the
Writer as an (X)HTML
table. |
Modifier and Type | Method and Description |
---|---|
BuildResult |
IndexManager.buildIndexSegment(String indexPartitionName,
ILocalBTreeView src,
boolean compactingMerge,
long commitTime,
byte[] fromKey,
byte[] toKey,
Event parentEvent)
Build an
IndexSegment from an index partition. |
static SplitResult |
SplitUtility.buildSplits(com.bigdata.resources.ViewMetadata vmd,
Split[] splits,
Event parentEvent)
Build N index segments based on those split points.
|
protected static MoveResult |
MoveTask.doAtomicUpdate(ResourceManager resourceManager,
String sourceIndexName,
BuildResult historicalWritesBuildResult,
UUID targetDataServiceUUID,
int targetIndexPartitionId,
Event parentEvent)
Submits an
MoveTask.AtomicUpdate and awaits and returns its outcome. |
protected static void |
SplitIndexPartitionTask.doSplitAtomicUpdate(ResourceManager resourceManager,
com.bigdata.resources.ViewMetadata vmd,
SplitResult result,
OverflowActionEnum action,
AtomicLong counter,
Event parentEvent) |
Constructor and Description |
---|
CompactingMergeTask.AtomicUpdateCompactingMergeTask(ResourceManager resourceManager,
IConcurrencyManager concurrencyManager,
String resource,
UUID indexUUID,
BuildResult buildResult,
Event updateEvent) |
IncrementalBuildTask.AtomicUpdateIncrementalBuildTask(ResourceManager resourceManager,
IConcurrencyManager concurrencyManager,
String resource,
UUID indexUUID,
BuildResult buildResult,
Event parentEvent) |
JoinIndexPartitionTask.AtomicUpdateJoinIndexPartition(ResourceManager resourceManager,
String[] resource,
JoinResult result,
Event updateEvent) |
MoveTask.AtomicUpdate(ResourceManager resourceManager,
String sourceIndexName,
BuildResult historicalWritesBuildResult,
UUID targetDataServiceUUID,
int targetIndexPartitionId,
Event parentEvent) |
SplitIndexPartitionTask.AtomicUpdateSplitIndexPartitionTask(ResourceManager resourceManager,
String[] resource,
OverflowActionEnum action,
UUID indexUUID,
SplitResult splitResult,
Event updateEvent) |
SplitUtility.BuildIndexSegmentSplitTask(com.bigdata.resources.ViewMetadata vmd,
Split split,
Event parentEvent)
Builds an
IndexSegment from the lastCommitTime of the old
journal. |
Modifier and Type | Field and Description |
---|---|
protected LinkedHashMap<UUID,Event> |
EventReceiver.eventCache
Basically a ring buffer of events without a capacity limit and with
random access by the event
UUID . |
Modifier and Type | Method and Description |
---|---|
Event |
Event.addDetail(String name,
Object value)
Add a detail.
|
Event |
Event.addDetails(Map<String,Object> details)
Add details.
|
Event |
Event.end()
Sends the end event.
|
static Event |
Event.fromString(String s)
Reconstruct an event object from a string.
|
Event |
Event.newSubEvent(Object minorEventType)
A child event (major type is the type of the parent).
|
Event |
Event.newSubEvent(Object minorEventType,
Map<String,Object> details)
A child event (major type is the type of the parent).
|
Event |
Event.start()
Send the start event.
|
Modifier and Type | Method and Description |
---|---|
Iterator<Event> |
IEventReportingService.rangeIterator(long fromTime,
long toTime)
Visits completed events that start in the given interval in order
by their start time.
|
Iterator<Event> |
EventReceiver.rangeIterator(long fromTime,
long toTime) |
Iterator<Event> |
LoadBalancerService.rangeIterator(long fromTime,
long toTime)
Visits completed events that start in the given interval in order
by their start time.
|
Modifier and Type | Method and Description |
---|---|
protected void |
EventReceiver.logEvent(Event e)
Logs the completed event using a tab-delimited format @ INFO on
EventReceiver.log . |
void |
EventReceiver.notifyEvent(Event e)
Accepts the event, either updates the existing event with the same
UUID or adds the event to the set of recent events, and then
prunes the set of recent events so that all completed events older than
EventReceiver.eventHistoryMillis are discarded. |
void |
LoadBalancerService.notifyEvent(Event e)
Accepts the event, either updates the existing event with the same
UUID or adds the event to the set of recent events, and then
prunes the set of recent events so that all completed events older than
#eventHistoryMillis are discarded. |
void |
IEventReceivingService.notifyEvent(Event e)
Accepts the event, either updates the existing event with the same
UUID or adds the event to the set of recent events. |
protected void |
AbstractFederation.sendEvent(Event e)
Queues up an event to be sent to the
ILoadBalancerService . |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.