import timely.api.DataStream;
import timely.api.StreamProcessor;
public class DataProcessingExample {
public static void main(String[] args) {
DataStream stream = new DataStream();
stream.addSource("source1", "data_source_1");
stream.addSource("source2", "data_source_2");
stream.process("operation1", new StreamProcessor() {
@Override
public void process(String data) {
System.out.println("Processing data: " + data);
}
});
stream.start();
}
}
