natashadsilva

import os
import getpass

import datetime
from streamsx.topology.context import ContextTypes, JobConfig
from streamsx.topology import context
from streamsx.topology.topology import Topology

import random, time
import typing

natashadsilva

package demo;

import java.util.Date;
import java.util.Properties;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;

natashadsilva

import os
import streamsx.ec
import streamsx.standard.utility as util
import streamsx.spl.op as op
from enum import IntEnum
from time import sleep
import time
import csv
from streamsx.topology.schema import StreamSchema

natashadsilva

namespace application;
 type Quote = rstring ticker, rstring date, rstring time, float64 askprice;
composite SimpleApp{
	graph
	   (stream<rstring filename> Beacon_2_out0) as Beacon_2 = Beacon()
        {
            param
                period : 1.0 ;
            output
                Beacon_2_out0 : filename =getApplicationDir() + "/etc/trades.csv";

natashadsilva

composite CircularFS(output Out0)
{
    graph
        (stream<rstring filename> Beacon_2_out0) as Beacon_2 = Beacon()
        {
            param
                period : 1.0 ;
            output
                Beacon_2_out0 : filename = "data.txt" ;