| 15 | } |
| 16 | |
| 17 | bool StandaloneCall::getNextTuplesInternal(ExecutionContext* context) { |
| 18 | if (standaloneCallInfo.hasExecuted) { |
| 19 | return false; |
| 20 | } |
| 21 | standaloneCallInfo.hasExecuted = true; |
| 22 | switch (standaloneCallInfo.option->optionType) { |
| 23 | case main::OptionType::CONFIGURATION: { |
| 24 | const auto configurationOption = |
| 25 | common::dynamic_cast_checked<const main::ConfigurationOption*>( |
| 26 | standaloneCallInfo.option); |
| 27 | configurationOption->setContext(context->clientContext, standaloneCallInfo.optionValue); |
| 28 | break; |
| 29 | } |
| 30 | case main::OptionType::EXTENSION: |
| 31 | context->clientContext->setExtensionOption(standaloneCallInfo.option->name, |
| 32 | standaloneCallInfo.optionValue); |
| 33 | break; |
| 34 | } |
| 35 | metrics->numOutputTuple.incrementByOne(); |
| 36 | return true; |
| 37 | } |
| 38 | |
| 39 | } // namespace processor |
| 40 | } // namespace lbug |
nothing calls this directly
no test coverage detected