public IBuffer getBuffer()

in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/DynamoDBMasterToReplicasPipeline.java [48:54]

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

    public IBuffer<Record> getBuffer(final KinesisConnectorConfiguration configuration) {
        if (configuration instanceof DynamoDBStreamsConnectorConfiguration) {
            return new DynamoDBBuffer((DynamoDBStreamsConnectorConfiguration) configuration);
        } else {
            throw new IllegalArgumentException(this + " needs a DynamoDBStreamsConnectorConfiguration argument.");
        }
    }