Open the IDE of your choice and create a new maven project. Add the following dependencies to your pom file:
Now you need to create three new classes:
First, create a new class MyStreamController
as follows:
import org.streampipes.model.SpDataStream; import org.streampipes.model.graph.DataSourceDescription; import org.streampipes.sources.AbstractAlreadyExistingStream; public class MyStreamController extends AbstractAlreadyExistingStream { @Override public SpDataStream declareModel(DataSourceDescription sep) { } }
Next, create a new class MyStreamSource
as follows:
import org.streampipes.container.declarer.EventStreamDeclarer; import org.streampipes.container.declarer.SemanticEventProducerDeclarer; import org.streampipes.model.graph.DataSourceDescription; import java.util.List; public class MyStreamSource implements SemanticEventProducerDeclarer { @Override public DataSourceDescription declareModel() { return null; } @Override public List<EventStreamDeclarer> getEventStreams() { return null; } }
The complete SDK reference for defining data processors will follow soon. Please check the SDK's Javadoc for now!