Java 类com.amazonaws.services.kinesis.connectors.impl.BasicMemoryBuffer 实例源码

@Override
public IBuffer<SimpleKinesisMessageModel> getBuffer(KinesisConnectorConfiguration configuration) {
    return new BasicMemoryBuffer<SimpleKinesisMessageModel>(configuration);
}

@Override
public IBuffer<byte[]> getBuffer(KinesisConnectorConfiguration configuration) {
    return new BasicMemoryBuffer<>(configuration);
}

@Override
public IBuffer<KinesisMessageModel> getBuffer(KinesisConnectorConfiguration configuration) {
    return new BasicMemoryBuffer<KinesisMessageModel>(configuration);
}