Package org.wso2.siddhi.query.api.execution.query

Class Query

java.lang.Object

org.wso2.siddhi.query.api.execution.query.Query

All Implemented Interfaces:

ExecutionElement

public class Query
extends Object
implements ExecutionElement

Constructor Summary

Constructors

Constructor	Description
Query()

Method Summary

Modifier and Type	Method	Description
Query	annotation(Annotation annotation)
void	deleteBy(String outputTableId, OutputStream.OutputEventType outputEventType, Expression onDeletingExpression)
void	deleteBy(String outputTableId, Expression onDeletingExpression)
boolean	equals(Object o)
Query	from(InputStream inputStream)
List<Annotation>	getAnnotations()
InputStream	getInputStream()
OutputRate	getOutputRate()
OutputStream	getOutputStream()
Selector	getSelector()
int	hashCode()
Query	insertInto(String outputStreamId)
Query	insertInto(String outputStreamId, OutputStream.OutputEventType outputEventType)
Query	insertIntoInner(String outputStreamId)
Query	insertIntoInner(String outputStreamId, OutputStream.OutputEventType outputEventType)
void	insertOverwriteBy(String outputTableId, OutputStream.OutputEventType outputEventType, Expression onUpdateExpression)
void	insertOverwriteBy(String outputTableId, Expression onUpdateExpression)
void	output(OutputRate outputRate)
Query	outStream(OutputStream outputStream)
static Query	query()
Query	returns()
Query	returns(OutputStream.OutputEventType outputEventType)
Query	select(Selector selector)
String	toString()
void	updateBy(String outputTableId, OutputStream.OutputEventType outputEventType, Expression onUpdateExpression)
void	updateBy(String outputTableId, Expression onUpdateExpression)

Methods inherited from class java.lang.Object

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

Constructor Details

Query

public Query()

Method Details

query

public static Query query()

from

public Query from(InputStream inputStream)

getInputStream

public InputStream getInputStream()

select

public Query select(Selector selector)

getSelector

public Selector getSelector()

outStream

public Query outStream(OutputStream outputStream)

insertInto

public Query insertInto(String outputStreamId,
 OutputStream.OutputEventType outputEventType)

insertInto

public Query insertInto(String outputStreamId)

insertIntoInner

public Query insertIntoInner(String outputStreamId,
 OutputStream.OutputEventType outputEventType)

insertIntoInner

public Query insertIntoInner(String outputStreamId)

returns

public Query returns()

returns

public Query returns(OutputStream.OutputEventType outputEventType)

deleteBy

public void deleteBy(String outputTableId,
 Expression onDeletingExpression)

deleteBy

public void deleteBy(String outputTableId,
 OutputStream.OutputEventType outputEventType,
 Expression onDeletingExpression)

updateBy

public void updateBy(String outputTableId,
 Expression onUpdateExpression)

updateBy

public void updateBy(String outputTableId,
 OutputStream.OutputEventType outputEventType,
 Expression onUpdateExpression)

insertOverwriteBy

public void insertOverwriteBy(String outputTableId,
 Expression onUpdateExpression)

insertOverwriteBy

public void insertOverwriteBy(String outputTableId,
 OutputStream.OutputEventType outputEventType,
 Expression onUpdateExpression)

getOutputStream

public OutputStream getOutputStream()

output

public void output(OutputRate outputRate)

getOutputRate

public OutputRate getOutputRate()

annotation

public Query annotation(Annotation annotation)

getAnnotations

public List<Annotation> getAnnotations()

Specified by:

getAnnotations in interface ExecutionElement

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object