@Test public void testGetOutputPorts() throws Exception { Map<String, PortType> result = importer.getOutputPorts(); assertNotNull(result); assertNotNull(result.get(PORT_OUT_PROJECT)); assertTrue(result.get(PORT_OUT_PROJECT) instanceof AvroPortType); assertTrue(Project.SCHEMA$ == ((AvroPortType)result.get(PORT_OUT_PROJECT)).getSchema()); }
@Override public Map<String, PortType> getOutputPorts() { return outputPorts; }
StreamingProjectImporter implements Process { @Override public Map<String, PortType> getOutputPorts() { return outputPorts; } }
StreamingProjectImporter implements Process { @Override public Map<String, PortType> getOutputPorts() { return outputPorts; } StreamingProjectImporter(); }
StreamingProjectImporter implements Process { @Override public Map<String, PortType> getOutputPorts() { return outputPorts; } StreamingProjectImporter(); @Override Map<String, PortType> getInputPorts(); @Override Map<String, PortType> getOutputPorts(); @Override void run(PortBindings portBindings, Configuration conf, Map<String, String> parameters); }
StreamingProjectImporter implements Process { @Override public Map<String, PortType> getOutputPorts() { return outputPorts; } StreamingProjectImporter(); @Override Map<String, PortType> getInputPorts(); @Override Map<String, PortType> getOutputPorts(); @Override void run(PortBindings portBindings, Configuration conf, Map<String, String> parameters);  }