[
https://issues.apache.org/jira/browse/STREAMPIPES-449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433812#comment-17433812
]
Hrushikesh edited comment on STREAMPIPES-449 at 10/25/21, 3:07 PM:
-------------------------------------------------------------------
Hi,
I have a doubt related to this code.
{code:java}
@Override
public void onInvocation(ProcessorParams processorParams, SpOutputCollector
spOutputCollector, EventProcessorRuntimeContext eventProcessorRuntimeContext)
throws SpRuntimeException {
// Printing for testing
System.out.println("I am inside onInvocation method!!!");
this.keyword =
processorParams.extractor().singleValueParameter(KEYWORD_ID,String.class);
this.stringOperator =
StringOperator.valueOf(processorParams.extractor().selectedSingleValue(OPERATION_ID,String.class));
this.filterProperty =
processorParams.extractor().mappingPropertyValue(MAPPING_PROPERTY_ID);
logger.info("Text Property: " + filterProperty);
}{code}
I have a print statement to check when the onInvocation method is being
executed. The print statement in the declare Model gets printed successfully in
the terminal. I am not able to see the print statement in the onInvocation
method and in the onEvent method. The module is up and running and is also
connected to the consul.
I want to know when exactly the onInvocation & onEvent method is called
internally by streampipes.
was (Author: hrushi20):
Hi,
I have a doubt related to this code.
{code:java}
@Override
public void onInvocation(ProcessorParams processorParams, SpOutputCollector
spOutputCollector, EventProcessorRuntimeContext eventProcessorRuntimeContext)
throws SpRuntimeException {
// Printing for testing
System.out.println("I am inside onInvocation method!!!");
this.keyword =
processorParams.extractor().singleValueParameter(KEYWORD_ID,String.class);
this.stringOperator =
StringOperator.valueOf(processorParams.extractor().selectedSingleValue(OPERATION_ID,String.class));
this.filterProperty =
processorParams.extractor().mappingPropertyValue(MAPPING_PROPERTY_ID);
logger.info("Text Property: " + filterProperty);
}{code}
I have a print statement to check when the onInvocation method is being
executed. The print statement in the declare Model gets printed successfully in
the terminal. I am not able to see the print statement in the onInvocation
method and in the onEvent method.
I want to know when exactly the onInvocation & onEvent method is called
internally by streampipes.
> Update Processing Element API in module streampipes-processors-filters-jvm
> --------------------------------------------------------------------------
>
> Key: STREAMPIPES-449
> URL: https://issues.apache.org/jira/browse/STREAMPIPES-449
> Project: StreamPipes
> Issue Type: Improvement
> Components: Pipeline Elements
> Reporter: Philipp Zehnder
> Priority: Major
> Labels: pull-request-available
> Fix For: 0.69.0
>
>
> The processors in this module use the old API, where 3 classes are required
> for a single processing element.
> These should be updated to use StreamPipesDataProcessor instead of
> StreamPipesDataProcessor.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
