public class QueryProjector extends Object
Constructor and Description |
---|
QueryProjector(String outputStreamId,
Projector projector,
List<QueryEventStream> queryEventStreamList) |
Modifier and Type | Method and Description |
---|---|
StreamDefinition |
getOutputStreamDefinition() |
void |
process(AtomicEvent atomicEvent) |
void |
process(List<AtomicEvent> atomicEventList) |
void |
process(ListEvent listEvent) |
void |
setStreamJunction(StreamJunction streamJunction) |
public QueryProjector(String outputStreamId, Projector projector, List<QueryEventStream> queryEventStreamList)
public StreamDefinition getOutputStreamDefinition()
public void setStreamJunction(StreamJunction streamJunction)
public void process(AtomicEvent atomicEvent)
public void process(List<AtomicEvent> atomicEventList)
public void process(ListEvent listEvent)
Copyright © 2012. All Rights Reserved.