Package com.helix.core.stream.disruptor

Class RuleEventHolder.MutableRuleEvent

java.lang.Object

com.helix.api.stream.RuleEvent

com.helix.core.stream.disruptor.RuleEventHolder.MutableRuleEvent

Enclosing class:

RuleEventHolder

public static class RuleEventHolder.MutableRuleEvent
extends RuleEvent

Pre-allocated mutable RuleEvent that avoids heap allocation in steady-state streaming.

Nested Class Summary

Nested classes/interfaces inherited from class com.helix.api.stream.RuleEvent

RuleEvent.Builder

Constructor Summary

Constructors

Constructor	Description
MutableRuleEvent()

Method Summary

Modifier and Type	Method	Description
void	clear()
ExecutionContext	getContext()
String	getEventId()
String	getRuleName()
long	getTimestamp()
String	getTopic()
void	set(String eventId, String topic, String ruleName, ExecutionContext context, long timestamp)

Methods inherited from class com.helix.api.stream.RuleEvent

builder, equals, getHeaders, hashCode, of, of, of, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

MutableRuleEvent

public MutableRuleEvent()

Method Details

set

public void set(String eventId,
 String topic,
 String ruleName,
 ExecutionContext context,
 long timestamp)

clear

public void clear()

getEventId

public String getEventId()

Overrides:

getEventId in class RuleEvent

getTopic

public String getTopic()

Overrides:

getTopic in class RuleEvent

getRuleName

public String getRuleName()

Overrides:

getRuleName in class RuleEvent

getContext

public ExecutionContext getContext()

Overrides:

getContext in class RuleEvent

getTimestamp

public long getTimestamp()

Overrides:

getTimestamp in class RuleEvent