net.sansa_stack.datalake.spark

Class NTtoDF

java.lang.Object

net.sansa_stack.datalake.spark.NTtoDF

All Implemented Interfaces:

Serializable

public class NTtoDF
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NTtoDF()

Method Summary

Modifier and Type	Method and Description
NTtoDF	options(Map<String,String> options)
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	read(String input_path, org.apache.spark.sql.SparkSession spark)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NTtoDF

public NTtoDF()

Method Detail

options

public NTtoDF options(Map<String,String> options)

read

public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> read(String input_path,
                                                                   org.apache.spark.sql.SparkSession spark)