public class MultiDataSetDeserializationCallback extends java.lang.Object implements PortableDataStreamMDSCallback
Constructor and Description |
---|
MultiDataSetDeserializationCallback() |
Modifier and Type | Method and Description |
---|---|
MultiDataSet |
compute(org.apache.spark.input.PortableDataStream pds)
This method should do something, and return DataSet after all
|
public MultiDataSet compute(org.apache.spark.input.PortableDataStream pds)
PortableDataStreamMDSCallback
compute
in interface PortableDataStreamMDSCallback