public IEmitter getEmitter()

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

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

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

    }