Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-03-03 07:59:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Small fix after rebase

Browse Source
This commit is contained in:
samhjelmfelt 2019-05-20 16:07:22 -07:00 committed by Mark Payne
parent 60b8fcac1b
commit 650c6aa820
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessContext.java
View File

@ -27,6 +27,7 @@ import org.apache.nifi.components.state.StateManager;
import org.apache.nifi.controller.ControllerService;
import org.apache.nifi.controller.ControllerServiceInitializationContext;
import org.apache.nifi.controller.ControllerServiceLookup;
import org.apache.nifi.controller.NodeTypeProvider;
import org.apache.nifi.logging.ComponentLog;
import org.apache.nifi.processor.Processor;
import org.apache.nifi.processor.Relationship;
@ -392,6 +393,20 @@ public class StatelessProcessContext implements SchedulingContext, ControllerSer
return stateManager;
}
@Override
public NodeTypeProvider getNodeTypeProvider() {
return new NodeTypeProvider() {
@Override
public boolean isClustered() {
return false;
}
@Override
public boolean isPrimary() {
return true;
}
};
}
@Override
public String getName() {
return componentName;

2
nifi-stateless/nifi-stateless-core/src/main/java/org/apache/nifi/stateless/core/StatelessProcessorWrapper.java
View File

@ -66,7 +66,7 @@ public class StatelessProcessorWrapper extends AbstractStatelessComponent implem
private volatile boolean initialized = false;
StatelessProcessorWrapper(final String id, final Processor processor, final StatelessProcessorWrapper parent, final StatelessControllerServiceLookup lookup, final VariableRegistry registry,
public StatelessProcessorWrapper(final String id, final Processor processor, final StatelessProcessorWrapper parent, final StatelessControllerServiceLookup lookup, final VariableRegistry registry,
final boolean materializeContent, final ClassLoader classLoader) throws InvocationTargetException, IllegalAccessException {
this.processor = processor;