@Test public void getInput_GivenApplicationDetailSpecifyingExactlyOneInput_ShouldReturnThatInput() { AwsResource expected = new AwsResource(streamArnPrefix + "example-stream-name"); configureInputs(inputStreamDescription(expected)); Assert.assertEquals(expected, wrapper.getInput()); }
public AwsResource getInput() { InputDescription desc = applicationDetailSupplier.get().inputDescriptions().get(0); String arn; if (desc.kinesisStreamsInputDescription() != null) { arn = desc.kinesisStreamsInputDescription().resourceARN(); } else { throw new IllegalStateException("Unknown type for input named: " + desc.namePrefix()); } return new AwsResource(arn); }
ApplicationIOProvider { public AwsResource getInput() { InputDescription desc = applicationDetailSupplier.get().inputDescriptions().get(0); String arn; if (desc.kinesisStreamsInputDescription() != null) { arn = desc.kinesisStreamsInputDescription().resourceARN(); } else { throw new IllegalStateException("Unknown type for input named: " + desc.namePrefix()); } return new AwsResource(arn); } }
ApplicationIOProvider { public AwsResource getInput() { InputDescription desc = applicationDetailSupplier.get().inputDescriptions().get(0); String arn; if (desc.kinesisStreamsInputDescription() != null) { arn = desc.kinesisStreamsInputDescription().resourceARN(); } else { throw new IllegalStateException("Unknown type for input named: " + desc.namePrefix()); } return new AwsResource(arn); } ApplicationIOProvider(String applicationName);  ApplicationIOProvider(KinesisAnalyticsClient client, String applicationName); }
ApplicationIOProvider { public AwsResource getInput() { InputDescription desc = applicationDetailSupplier.get().inputDescriptions().get(0); String arn; if (desc.kinesisStreamsInputDescription() != null) { arn = desc.kinesisStreamsInputDescription().resourceARN(); } else { throw new IllegalStateException("Unknown type for input named: " + desc.namePrefix()); } return new AwsResource(arn); } ApplicationIOProvider(String applicationName);  ApplicationIOProvider(KinesisAnalyticsClient client, String applicationName); AwsResource getInput(); AwsResource getOutput(String name); }
ApplicationIOProvider { public AwsResource getInput() { InputDescription desc = applicationDetailSupplier.get().inputDescriptions().get(0); String arn; if (desc.kinesisStreamsInputDescription() != null) { arn = desc.kinesisStreamsInputDescription().resourceARN(); } else { throw new IllegalStateException("Unknown type for input named: " + desc.namePrefix()); } return new AwsResource(arn); } ApplicationIOProvider(String applicationName);  ApplicationIOProvider(KinesisAnalyticsClient client, String applicationName); AwsResource getInput(); AwsResource getOutput(String name);  }