public class StreamTupleEntryQueue extends Object
Constructor and Description |
---|
StreamTupleEntryQueue() |
Modifier and Type | Method and Description |
---|---|
boolean |
addDelete(TupleEntry entry) |
boolean |
addInsert(TupleEntry entry) |
boolean |
addUpdate(TupleEntry entry) |
boolean |
isEmpty() |
TupleEntry |
peek() |
int |
size() |
TupleEntryQueue |
takeAllForFlushing() |
public TupleEntry peek()
public boolean addInsert(TupleEntry entry)
public boolean addUpdate(TupleEntry entry)
public boolean addDelete(TupleEntry entry)
public int size()
public boolean isEmpty()
public TupleEntryQueue takeAllForFlushing()
Copyright © 2001-2015 JBoss by Red Hat. All Rights Reserved.