Внедрение Spring Batch с базой данных Cassandra

Question

Я пытаюсь изменить существующее весеннее пакетное задание (XML config), которое считывает данные из базы данных Oracle и записывает в файл TXT и XML в требуемом формате, но теперь я хочу изменить ту же реализацию для чтения данных из базы данных Cassandra вместо Oracleно я не вижу ни одного доступного имитатора Item Reader для JdbcCursorItemReader в весенней партии для Cassandra db.

Может кто-нибудь сказать мне, какой ItemReader я должен использовать для чтения данных из Cassandra db?ИЛИ Нужно ли создавать собственный ItemReader для чтения данных из Cassandra db?

Answer 1

Вы можете создать CustomItemReader

public class CustomItemReader implements ItemReader<List<YOUR_DOMAIN_OBJECT>> {

    @PostConstruct
    public void init() throws IOException {
        //establish cassandra db connection
    }

    @Override
    public List<YOUR_DOMAIN_OBJECT> read()
        throws Exception{

        //user cassandra connection to read data and build List<YOUR_DOMAIN_OBJECT>

       return data;
    }

}