public class HdfsModelExporter<T extends SequenceElement> extends java.lang.Object implements SparkModelExporter<T>
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.io.compress.CompressionCodec |
codec |
protected java.lang.String |
path |
Modifier | Constructor and Description |
---|---|
protected |
HdfsModelExporter() |
|
HdfsModelExporter(java.lang.String path) |
|
HdfsModelExporter(java.lang.String path,
org.apache.hadoop.io.compress.CompressionCodec codec) |
Modifier and Type | Method and Description |
---|---|
void |
export(org.apache.spark.api.java.JavaRDD<ExportContainer<T>> rdd)
This method will be called at final stage of SequenceVectors training, and JavaRDD being passed as argument will
|
protected java.lang.String path
protected org.apache.hadoop.io.compress.CompressionCodec codec
protected HdfsModelExporter()
public HdfsModelExporter(@NonNull java.lang.String path)
public HdfsModelExporter(@NonNull java.lang.String path, org.apache.hadoop.io.compress.CompressionCodec codec)
public void export(org.apache.spark.api.java.JavaRDD<ExportContainer<T>> rdd)
SparkModelExporter
export
in interface SparkModelExporter<T extends SequenceElement>