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)
SparkModelExporterexport in interface SparkModelExporter<T extends SequenceElement>