cel() {
> isRunning = false;
> }
>
> @Override
> public void run(SourceFunction.SourceContext ctx)
> throws Exception {
> while (isRunning) {
> //TODO: query Google Finance API
> ctx.collect("12.5");
> }
> }
> }
>
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/How-do-I-use-
> values-from-a-data-stream-to-create-a-new-streaming-data-
> source-tp10680.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
public void run(SourceFunction.SourceContext ctx)
throws Exception {
while (isRunning) {
//TODO: query Google Finance API
ctx.collect("12.5");
}
}
}
--
View this message in context:
http://apache-flink-us
