private static FlinkKinesisProducer createSinkFromApplicationConfig()

in kinesis-data-analytics-sse/src/main/java/com/amazonaws/services/kinesisanalytics/SSEConsumer.java [24:31]

• 8 lines of code
• 1 McCabe index (conditional complexity)

    private static FlinkKinesisProducer<String> createSinkFromApplicationConfig() throws IOException {
        Map<String, Properties> applicationProperties = KinesisAnalyticsRuntime.getApplicationProperties();
        Properties producerProperties = applicationProperties.get(PRODUCER_CONFIG_PROPERTIES);
        FlinkKinesisProducer<String> sink = new FlinkKinesisProducer<>(new SimpleStringSchema(), producerProperties);
        sink.setDefaultStream(applicationProperties.get(OUTPUT_STREAM_PROPERTIES).getProperty(DEFAULT_STREAM));
        sink.setDefaultPartition("0");
        return sink;
    }