Кодеры для коллекций в 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-компонент был выведен для кодирования. Несовместимое ограничение равенства.