[
https://issues.apache.org/jira/browse/STREAMPIPES-449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17433420#comment-17433420
]
Hrushikesh edited comment on STREAMPIPES-449 at 10/24/21, 10:50 AM:
--------------------------------------------------------------------
Hi,
{code:java}
processorParams.getGraph().getOutputStream().getEventSchema();
EventFactory.fromEvents(lastEvents.get(currentSelectorPrefix), lastEvents.get
(getOtherSelectorPrefix(currentSelectorPrefix)),
outputSchema).getSubset(outputKeySelectors);
{code}
Can you explain me what this code does? Few things are missing in the api docs.
Having a bit of trouble.
Thank You
Hrushikesh
was (Author: hrushi20):
Hi,
{code:java}
processorParams.getGraph().getOutputStream().getEventSchema();{code}
Can you explain me what this code does? Few things are missing in the api docs.
Having a bit of trouble.
Thank You
Hrushikesh
> 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
> 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)
