.filter(SourceOperatorFactory.class::isInstance)
.map(SourceOperatorFactory.class::cast)
.map(SourceOperatorFactory::getSourceId)
.collect(toImmutableList());
checkArgument(sourceIds.size() <= 1, "Expected at most one source operator in driver facotry, but found %s", sourceIds);
<BUG>this.sourceId = sourceIds.isEmpty() ? Optional.empty() : Optional.of(sourceIds.get(0));
}</BUG>
public boolean isInputDriver()
{
return inputDriver;

.filter(SourceOperatorFactory.class::isInstance)
.map(SourceOperatorFactory.class::cast)
.map(SourceOperatorFactory::getSourceId)
.collect(toImmutableList());
checkArgument(sourceIds.size() <= 1, "Expected at most one source operator in driver facotry, but found %s", sourceIds);
this.sourceId = sourceIds.isEmpty() ? Optional.empty() : Optional.of(sourceIds.get(0));
}
public int getPipelineId()
{
return pipelineId;
}
public boolean isInputDriver()
{
return inputDriver;
