You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2023/03/21 21:14:22 UTC
[streampipes] branch dev updated: update archetypes template (#1433)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new a42fe29c7 update archetypes template (#1433)
a42fe29c7 is described below
commit a42fe29c75c60337535faca0693e0502ecf0ac19
Author: Liu Xiao <42...@users.noreply.github.com>
AuthorDate: Wed Mar 22 05:14:15 2023 +0800
update archetypes template (#1433)
---
.../archetype-resources/src/main/java/Init.java | 30 ++++++++---------
.../__classNamePrefix__DataProcessor.java | 39 +++++++++++-----------
.../__classNamePrefix__DataSink.java | 25 +++++++-------
3 files changed, 47 insertions(+), 47 deletions(-)
diff --git a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java
index 777e6dc31..74c27462b 100644
--- a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java
+++ b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java
@@ -37,26 +37,26 @@ import ${package}.pe.${packageName}.${classNamePrefix}DataSink;
public class Init extends ExtensionsModelSubmitter {
- public static void main (String[] args) {
+ public static void main(String[] args) {
new Init().init();
}
@Override
public SpServiceDefinition provideServiceDefinition() {
return SpServiceDefinitionBuilder.create("${package}",
- "human-readable service name",
- "human-readable service description", 8090)
- .registerPipelineElement(new ${classNamePrefix}DataProcessor())
- .registerPipelineElement(new ${classNamePrefix}DataSink())
- .registerMessagingFormats(
- new JsonDataFormatFactory(),
- new CborDataFormatFactory(),
- new SmileDataFormatFactory(),
- new FstDataFormatFactory())
- .registerMessagingProtocols(
- new SpKafkaProtocolFactory(),
- new SpJmsProtocolFactory(),
- new SpMqttProtocolFactory())
- .build();
+ "human-readable service name",
+ "human-readable service description", 8090)
+ .registerPipelineElement(new ${classNamePrefix}DataProcessor())
+ .registerPipelineElement(new ${classNamePrefix}DataSink())
+ .registerMessagingFormats(
+ new JsonDataFormatFactory(),
+ new CborDataFormatFactory(),
+ new SmileDataFormatFactory(),
+ new FstDataFormatFactory())
+ .registerMessagingProtocols(
+ new SpKafkaProtocolFactory(),
+ new SpJmsProtocolFactory(),
+ new SpMqttProtocolFactory())
+ .build();
}
}
diff --git a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataProcessor.java b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataProcessor.java
index 03544f210..b67df0151 100644
--- a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataProcessor.java
+++ b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataProcessor.java
@@ -49,33 +49,34 @@ public class ${classNamePrefix}DataProcessor extends StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder.create("${package}.pe.${packageName}.processor")
- .withAssets(Assets.DOCUMENTATION, Assets.ICON)
- .withLocales(Locales.EN)
- .category(DataProcessorType.AGGREGATE)
- .requiredStream(StreamRequirementsBuilder
- .create()
- .requiredProperty(EpRequirements.anyProperty())
- .build())
- .requiredTextParameter(Labels.withId(EXAMPLE_KEY))
- .outputStrategy(OutputStrategies.append(PrimitivePropertyBuilder.create(Datatypes.String, "appendedText").build()))
- .build();
- }
+ .withAssets(Assets.DOCUMENTATION, Assets.ICON)
+ .withLocales(Locales.EN)
+ .category(DataProcessorType.AGGREGATE)
+ .requiredStream(StreamRequirementsBuilder
+ .create()
+ .requiredProperty(EpRequirements.anyProperty())
+ .build())
+ .requiredTextParameter(Labels.withId(EXAMPLE_KEY))
+ .outputStrategy(OutputStrategies.append(PrimitivePropertyBuilder.create(Datatypes.String, "appendedText").build()))
+ .build();
+ }
@Override
public void onInvocation(ProcessorParams processorParams,
- SpOutputCollector out,
- EventProcessorRuntimeContext ctx) throws SpRuntimeException {
- this.exampleText = processorParams.extractor().singleValueParameter(EXAMPLE_KEY,String.class);
+ SpOutputCollector out,
+ EventProcessorRuntimeContext ctx) throws SpRuntimeException {
+
+ this.exampleText = processorParams.extractor().singleValueParameter(EXAMPLE_KEY, String.class);
}
@Override
- public void onEvent(Event event,SpOutputCollector out){
- event.addField("appendedText", exampleText);
- out.collect(event);
+ public void onEvent(Event event, SpOutputCollector out) {
+ event.addField("appendedText", exampleText);
+ out.collect(event);
}
@Override
- public void onDetach(){
- }
+ public void onDetach() {
+ }
}
diff --git a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataSink.java b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataSink.java
index 0386df314..ecdac3746 100644
--- a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataSink.java
+++ b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/pe/__packageName__/__classNamePrefix__DataSink.java
@@ -45,23 +45,23 @@ private static final String EXAMPLE_KEY = "example-key";
@Override
public DataSinkDescription declareModel(){
- return DataSinkBuilder.create("${package}.pe.${packageName}.sink")
- .withAssets(Assets.DOCUMENTATION,Assets.ICON)
- .withLocales(Locales.EN)
- .category(DataSinkType.UNCATEGORIZED)
- .requiredStream(StreamRequirementsBuilder
- .create()
- .requiredProperty(EpRequirements.anyProperty())
- .build())
- .requiredTextParameter(Labels.withId(EXAMPLE_KEY))
- .build();
+ return DataSinkBuilder.create("${package}.pe.${packageName}.sink")
+ .withAssets(Assets.DOCUMENTATION, Assets.ICON)
+ .withLocales(Locales.EN)
+ .category(DataSinkType.UNCATEGORIZED)
+ .requiredStream(StreamRequirementsBuilder
+ .create()
+ .requiredProperty(EpRequirements.anyProperty())
+ .build())
+ .requiredTextParameter(Labels.withId(EXAMPLE_KEY))
+ .build();
}
@Override
public void onInvocation(SinkParams sinkParams,
- EventSinkRuntimeContext ctx) throws SpRuntimeException{
+ EventSinkRuntimeContext ctx) throws SpRuntimeException {
- this.exampleText = sinkParams.extractor().singleValueParameter(EXAMPLE_KEY,String.class);
+ this.exampleText = sinkParams.extractor().singleValueParameter(EXAMPLE_KEY, String.class);
}
@Override
@@ -73,5 +73,4 @@ private static final String EXAMPLE_KEY = "example-key";
public void onDetach(){
}
-
}