private static StreamingFileSink createS3SinkFromStaticConfig()

in src/main/java/com/amazonaws/services/kinesisanalytics/S3StreamingSinkJob.java [42:49]

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

    private static StreamingFileSink<String> createS3SinkFromStaticConfig() {

        final StreamingFileSink<String> sink = StreamingFileSink
                .forRowFormat(new Path(s3SinkPath), new SimpleStringEncoder<String>("UTF-8"))
                .withBucketAssigner(new DateTimeBucketAssigner("yyyy-MM-dd--HH"))
                .build();
        return sink;
    }