DStream::getOutputSchema

Syntax

DStream::getOutputSchema()

Arguments

None

Details

Returns the schema of the current DStream object.

Examples

aggGraph = createStreamGraph("aggregation")
engine = aggGraph.source("trade", 1000:0, `time`sym`price, [TIMESTAMP, SYMBOL, FLOAT])
	.timeSeriesEngine(windowSize=60, step=60, metrics=[<sum(price)>], 
timeColumn="time", keyColumn="sym")
engine.getOutputSchema()

/* output:
time sym sum_price
---- --- ---------
*/