import io.trickle.*;
import io.trickle.datasource.*;
import io.trickle.pipeline.*;
import io.trickle.pipeline.processors.*;
import io.trickle.pipeline.sinks.*;
public class TrafficDataAnalysis {
public static void main(String[] args) {
DataSource<RawTrafficData> dataSource = new TrafficDataSource();
Pipeline<RawTrafficData, AnalyzedTrafficData> pipeline = new Pipeline<>(
new PreProcessor(),
new RealTimeAnalyzer(),
new ResultSaver()
);
dataSource.addSink(pipeline);
dataSource.start();
}
}
import io.trickle.*;
import io.trickle.datasource.*;
import io.trickle.pipeline.*;
import io.trickle.pipeline.processors.*;
import io.trickle.pipeline.sinks.*;
public class RealTimeDataProcessing {
public static void main(String[] args) {
DataSource<RealTimeData> dataSource = new RealTimeDataSource();
Pipeline<RealTimeData, ProcessedData> pipeline = new Pipeline<>(
new RealTimeProcessor(),
new DataStorage()
);
dataSource.addSink(pipeline);
dataSource.start();
}
}
