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

@Override
public IFilter<SimpleKinesisMessageModel> getFilter(KinesisConnectorConfiguration configuration) {
    return new AllPassFilter<SimpleKinesisMessageModel>();
}

@Override
public IFilter<byte[]> getFilter(KinesisConnectorConfiguration configuration) {
    return new AllPassFilter<>();
}

@Override
public IFilter<KinesisMessageModel> getFilter(KinesisConnectorConfiguration configuration) {
    return new AllPassFilter<KinesisMessageModel>();
}