throw new IOException("Invalid number of inputs"
+ ", inputCount=" + inputs.size());
}
LogicalInput in = inputs.values().iterator().next();
in.start();
List<Input> pendingInputs = new LinkedList<Input>();
pendingInputs.add(in);
processorContext.waitForAllInputsReady(pendingInputs);
LOG.info("Input is ready for consumption. Starting Output");