Package org.rumbledb.runtime.functions.input

Class FileSystemUtil

java.lang.Object

org.rumbledb.runtime.functions.input.FileSystemUtil

public class FileSystemUtil
extends Object

Constructor Summary

Constructors

Constructor	Description
FileSystemUtil()

Method Summary

Modifier and Type	Method	Description
static void	append(URI locator, List<String> content, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static void	checkAllowed(URI uri, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static void	checkForAbsoluteAndNoWildcards(URI locator, ExceptionMetadata metadata)
static String	convertURIToStringForSpark(URI uri)
static boolean	delete(URI locator, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static boolean	exists(URI locator, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static InputStream	getDataInputStream(URI locator, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static InputStream	getDataInputStreamHTML(URI locator, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static String	readContent(URI locator, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static URI	resolveURI(URI base, String url, ExceptionMetadata metadata)
static URI	resolveURIAgainstWorkingDirectory(String url, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)
static void	write(URI locator, List<String> content, RumbleRuntimeConfiguration conf, ExceptionMetadata metadata)

Methods inherited from class java.lang.Object

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

Constructor Details

FileSystemUtil

public FileSystemUtil()

Method Details

checkAllowed

public static void checkAllowed(URI uri,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

resolveURI

public static URI resolveURI(URI base,
 String url,
 ExceptionMetadata metadata)

convertURIToStringForSpark

public static String convertURIToStringForSpark(URI uri)

resolveURIAgainstWorkingDirectory

public static URI resolveURIAgainstWorkingDirectory(String url,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

exists

public static boolean exists(URI locator,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

delete

public static boolean delete(URI locator,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

getDataInputStream

public static InputStream getDataInputStream(URI locator,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

getDataInputStreamHTML

public static InputStream getDataInputStreamHTML(URI locator,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

readContent

public static String readContent(URI locator,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

write

public static void write(URI locator,
 List<String> content,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

append

public static void append(URI locator,
 List<String> content,
 RumbleRuntimeConfiguration conf,
 ExceptionMetadata metadata)

checkForAbsoluteAndNoWildcards

public static void checkForAbsoluteAndNoWildcards(URI locator,
 ExceptionMetadata metadata)