Кодеры для коллекций в apache spark

Есть ли способ создать Encoders для типа коллекции в apache spark. Я попробовал ниже подход, но он не работает.

import java.io.Serializable;

public class CollectionEntity<T>  implements Serializable {

    private T collectionData;

    public T getCollectionData(){
        return collectionData;
    }

    public void setCollectionData(T inputCollectionData){
        this.collectionData = inputCollectionData;
    }
}

Затем я создал дочерний класс

public class CollectionEntityForStringArray extends CollectionEntity<String[]> {
}

Но когда я пытаюсь создать кодировщик, как показано ниже, он показывает ошибку компиляции

Encoder<CollectionEntity<String[]>> collectionEncoder = Encoders.bean(CollectionEntityForStringArray.class);

Несовместимые типы. Требуется кодировщик>, но bean-компонент был выведен для кодирования. Несовместимое ограничение равенства.

0 ответов

Другие вопросы по тегам