public class StreamEventFactory extends Object implements com.lmax.disruptor.EventFactory<StreamEvent>, Serializable
Constructor and Description |
---|
StreamEventFactory(int beforeWindowDataSize,
int onAfterWindowDataSize,
int outputDataSize)
Initialization of the factory with event data sizes
|
StreamEventFactory(MetaStreamEvent metaStreamEvent)
Initialization of the factory using MetaStreamEvent
|
Modifier and Type | Method and Description |
---|---|
StreamEvent |
newInstance()
Constructs new Events
|
public StreamEventFactory(MetaStreamEvent metaStreamEvent)
metaStreamEvent
- meta stream eventpublic StreamEventFactory(int beforeWindowDataSize, int onAfterWindowDataSize, int outputDataSize)
beforeWindowDataSize
- BeforeWindow sizeonAfterWindowDataSize
- OnAfterWindow sizeoutputDataSize
- Output Sizepublic StreamEvent newInstance()
newInstance
in interface com.lmax.disruptor.EventFactory<StreamEvent>
Copyright © 2019. All rights reserved.