Uses of Interface
com.pervasive.datarush.io.Path
-
Packages that use Path Package Description com.actian.dataflow.cal.yarn.server com.actian.dataflow.cal.yarn.shared com.actian.dataflow.operators.io.orc com.actian.dataflow.operators.io.parquet com.pervasive.datarush.aws.s3 com.pervasive.datarush.azure com.pervasive.datarush.cal Provides interfaces the define the "cluster abstraction layer".com.pervasive.datarush.gcp com.pervasive.datarush.graphs Provides classes and interfaces for the construction of executable dataflow graphs.com.pervasive.datarush.hadoop.io com.pervasive.datarush.io Provides classes and interfaces performing file-like I/O operations.com.pervasive.datarush.io.compression Provides classes and interfaces for supporting data compression.com.pervasive.datarush.io.configuration Provides classes and interfaces associated with filesystem configurationcom.pervasive.datarush.operators Provides classes and interfaces for developing dataflow operators.com.pervasive.datarush.operators.io Provides base file I/O components including encoders and decoders.com.pervasive.datarush.operators.io.avro Provides operators for reading and writing files in Avro format.com.pervasive.datarush.operators.io.mdf com.pervasive.datarush.operators.io.staging Provides operators for reading and writing DataRush staging datasets.com.pervasive.datarush.operators.io.textfile Provides operators for reading and writing text data. -
-
Uses of Path in com.actian.dataflow.cal.yarn.server
Methods in com.actian.dataflow.cal.yarn.server that return types with arguments of type Path Modifier and Type Method Description Map<String,Path>YarnClusterExecutor. drfsRoots()Constructors in com.actian.dataflow.cal.yarn.server with parameters of type Path Constructor Description MasterServer(com.pervasive.datarush.hadoop.shims.yarn.AMRMClient amClient, FileClient client, Path drfsBaseDir, JobServerInformation jobWorkerInfo, JobSpecifier jobSpecifier, com.pervasive.datarush.cluster.ExecutorOptions execOptions, List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors, Path cacheLocation, Path libArchiveLocation, String applicationID, int jobPriority, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences, Map<String,ApplicationResource> appResources)PartitionServer(FileClient client, Path drfsBaseDir, String nodeID, JobServerInformation jobWorkerInfo, com.pervasive.datarush.cal.dr.NodeAllocationProvider allocationProvider, JobSpecifier jobSpecifier)YarnClusterExecutor(FileClient fileClient, JobSpecifier jobSpec, com.pervasive.datarush.hadoop.shims.yarn.ContainerManager containerMgr, com.pervasive.datarush.cluster.ExecutorOptions execOptions, Path cacheLocation, Path libArchiveLocation, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPrefs, Map<String,ApplicationResource> appResources) -
Uses of Path in com.actian.dataflow.cal.yarn.shared
Methods in com.actian.dataflow.cal.yarn.shared that return Path Modifier and Type Method Description PathYarnAppMasterArgs. getCacheLocation()PathYarnAppMasterArgs. getLibArchiveLocation()Methods in com.actian.dataflow.cal.yarn.shared with parameters of type Path Modifier and Type Method Description static com.pervasive.datarush.hadoop.shims.yarn.ContainerContextContainerContextBuilder. createContext(com.pervasive.datarush.cluster.Platform targetPlatform, ClasspathSpecifier classpathSpec, String jobName, Class<?> mainClass, Path archivePath, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences)Create a container context.Constructors in com.actian.dataflow.cal.yarn.shared with parameters of type Path Constructor Description DatafileStagingManager(FileClient client, Path stagingLocation, GUID jobId)YarnAppMasterArgs(JobSpecifier jobSpec, ModuleConfiguration moduleCfg, FileMetaConfiguration fileCfg, ClasspathSpecifier classpathSpec, com.pervasive.datarush.cluster.ExecutorOptions options, List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors, Path cacheLocation, Path libArchiveLocation, int jobPriority, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences, Map<String,ApplicationResource> appResources) -
Uses of Path in com.actian.dataflow.operators.io.orc
Constructors in com.actian.dataflow.operators.io.orc with parameters of type Path Constructor Description ReadORC(Path path)Reads the file specified by the path. -
Uses of Path in com.actian.dataflow.operators.io.parquet
Constructors in com.actian.dataflow.operators.io.parquet with parameters of type Path Constructor Description ReadParquet(Path path)Reads the file specified by the path. -
Uses of Path in com.pervasive.datarush.aws.s3
Methods in com.pervasive.datarush.aws.s3 that return Path Modifier and Type Method Description PathS3FileSystemProvider. getFileSystemPath(Path path)PathS3FileSystemProvider. getPath(String path)Methods in com.pervasive.datarush.aws.s3 with parameters of type Path Modifier and Type Method Description FileSystemS3FileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)PathS3FileSystemProvider. getFileSystemPath(Path path) -
Uses of Path in com.pervasive.datarush.azure
Classes in com.pervasive.datarush.azure that implement Path Modifier and Type Class Description classAzureFilePathMethods in com.pervasive.datarush.azure that return Path Modifier and Type Method Description PathAzureFileSystem. createDirectories(Path path)PathAzureFileSystem. createDirectory(Path path)PathAzureFileSystemProvider. getFileSystemPath(Path path)PathAzureFilePath. getParent()PathAzureFileSystemProvider. getPath(String path)PathAzureFilePath. resolve(String childPath)PathAzureFilePath. toAbsolutePath()Methods in com.pervasive.datarush.azure with parameters of type Path Modifier and Type Method Description PathAzureFileSystem. createDirectories(Path path)PathAzureFileSystem. createDirectory(Path path)booleanAzureFileSystem. createNewFile(Path path)voidAzureFileSystem. delete(Path path, boolean recursively)booleanAzureFileSystem. exists(Path path)PathDetailsAzureFileSystem. getDetails(Path path)FileSystemAzureFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)PathAzureFileSystemProvider. getFileSystemPath(Path path)StringAzureFileSystem. getFileSystemType(Path path)longAzureFileSystem. getLength(Path path)SplitIteratorAzureFileSystem. getSplits(Path path, SplitOptions options)booleanAzureFileSystem. isCreatable(Path path)booleanAzureFileSystem. isDirectory(Path path)booleanAzureFileSystem. isFile(Path path)booleanAzureFileSystem. isHidden(Path path)booleanAzureFileSystem. isReadable(Path path)booleanAzureFileSystem. isWritable(Path path)List<PathDetails>AzureFileSystem. listDirectory(Path path, DirectoryFilter filter)booleanAzureFileSystem. move(FileSystem fromFS, Path from, Path to)FileChannelAzureFileSystem. newFileChannel(Path path)InputStreamAzureFileSystem. newInputStream(Path path)OutputStreamAzureFileSystem. newOutputStream(Path path, WriteMode mode)Method parameters in com.pervasive.datarush.azure with type arguments of type Path Modifier and Type Method Description InputStreamAzureFileSystem. concat(List<Path> paths, boolean ignoreNonExistent) -
Uses of Path in com.pervasive.datarush.cal
Methods in com.pervasive.datarush.cal that return Path Modifier and Type Method Description PathStorageBucket. getMyStorageLocation(NodeAllocationPlan.AssignmentPlan partitionInfo)PathStorageManager. getMyStorageLocation(StorageBucketId bucketId, NodeAllocationPlan.AssignmentPlan assignment)Returns "my" storage locationPathStorageManagerSpecifier. getWorkerStorageRoot()Returns the base storage path for this storage manager.PathClasspathSpecifier.Element. path()Returns the path of this classpath element.PathJobSpecifier. storageManagementPath()Returns the root scratch directory to use.Methods in com.pervasive.datarush.cal that return types with arguments of type Path Modifier and Type Method Description List<Path>StorageManager. getOtherStorageLocations(StorageBucketId bucketId, int maxParallelism)Returns storage locations for all workers up to the specifiedmaxParallelism.List<Path>StorageBucket. getWorkerStorageLocations(int maxParallelism)Methods in com.pervasive.datarush.cal with parameters of type Path Modifier and Type Method Description booleanStorageManagerProvider. isProvider(Path storagePath)Returns whether this provider supports the given storage pathClasspathSpecifier.ElementClasspathSpecifier.Element. path(Path path)Returns a new ClasspathElement, overriding the path.JobSpecifierJobSpecifier. storageManagementPath(Path storageManagementPath)Overrides the storageManagementPathConstructors in com.pervasive.datarush.cal with parameters of type Path Constructor Description Element(Path path)Create a new classpath for the given path.Element(Path path, CacheScopeSpecifier cacheScope, boolean dynamic, OSGIOptions osgiOptions)Create a new classpath for the given path.JobSpecifier(ResourceSpecifier requestedResources, ClusterSpecifier cluster, ClasspathSpecifier classpath, JobInformation jobInformation, Path storageManagementPath)Create a new job specifierJobSpecifier(ResourceSpecifier requestedResources, ClusterSpecifier cluster, ClasspathSpecifier classpath, JobInformation jobInformation, Path storageManagementPath, String schedulerQueue, List<String> extensionPaths)Create a new job specifier -
Uses of Path in com.pervasive.datarush.gcp
Classes in com.pervasive.datarush.gcp that implement Path Modifier and Type Class Description classGcpFilePathMethods in com.pervasive.datarush.gcp that return Path Modifier and Type Method Description PathGcpFileSystem. createDirectories(Path path)PathGcpFileSystem. createDirectory(Path path)PathGcpFileSystemProvider. getFileSystemPath(Path path)PathGcpFilePath. getParent()PathGcpFileSystemProvider. getPath(String path)PathGcpFilePath. resolve(String childPath)PathGcpFilePath. toAbsolutePath()Methods in com.pervasive.datarush.gcp with parameters of type Path Modifier and Type Method Description PathGcpFileSystem. createDirectories(Path path)PathGcpFileSystem. createDirectory(Path path)booleanGcpFileSystem. createNewFile(Path path)voidGcpFileSystem. delete(Path path, boolean recursively)booleanGcpFileSystem. exists(Path path)PathDetailsGcpFileSystem. getDetails(Path path)FileSystemGcpFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)PathGcpFileSystemProvider. getFileSystemPath(Path path)StringGcpFileSystem. getFileSystemType(Path path)longGcpFileSystem. getLength(Path path)SplitIteratorGcpFileSystem. getSplits(Path path, SplitOptions options)booleanGcpFileSystem. isCreatable(Path path)booleanGcpFileSystem. isDirectory(Path path)booleanGcpFileSystem. isFile(Path path)booleanGcpFileSystem. isHidden(Path path)booleanGcpFileSystem. isReadable(Path path)booleanGcpFileSystem. isWritable(Path path)List<PathDetails>GcpFileSystem. listDirectory(Path path, DirectoryFilter filter)booleanGcpFileSystem. move(FileSystem fromFS, Path from, Path to)FileChannelGcpFileSystem. newFileChannel(Path path)InputStreamGcpFileSystem. newInputStream(Path path)OutputStreamGcpFileSystem. newOutputStream(Path path, WriteMode mode)Method parameters in com.pervasive.datarush.gcp with type arguments of type Path Modifier and Type Method Description InputStreamGcpFileSystem. concat(List<Path> paths, boolean ignoreNonExistent) -
Uses of Path in com.pervasive.datarush.graphs
Fields in com.pervasive.datarush.graphs with type parameters of type Path Modifier and Type Field Description static EngineProperty<Path>EngineConfig. STORAGE_MANAGEMENT_PATHProperty that controls a base path to use for intermediate storage.Methods in com.pervasive.datarush.graphs that return Path Modifier and Type Method Description PathEngineConfig. getStorageManagementPath()Returns the root scratch directory to use.Methods in com.pervasive.datarush.graphs with parameters of type Path Modifier and Type Method Description EngineConfigEngineConfig. storageManagementPath(Path path)Specifies the root scratch directory to use. -
Uses of Path in com.pervasive.datarush.hadoop.io
Classes in com.pervasive.datarush.hadoop.io that implement Path Modifier and Type Class Description classHadoopFilePathImplementation of a path for the Hadoop Distributed File System (HDFS).Methods in com.pervasive.datarush.hadoop.io that return Path Modifier and Type Method Description PathHadoopFileSystemProvider. getFileSystemPath(Path path)PathHadoopFilePath. getParent()PathHadoopFileSystemProvider. getPath(String path)PathHadoopFilePath. resolve(String other)PathHadoopFilePath. toAbsolutePath()Methods in com.pervasive.datarush.hadoop.io with parameters of type Path Modifier and Type Method Description static HadoopFilePathHadoopFilePath. cast(Path p)FileSystemHadoopFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)PathHadoopFileSystemProvider. getFileSystemPath(Path path) -
Uses of Path in com.pervasive.datarush.io
Classes in com.pervasive.datarush.io that implement Path Modifier and Type Class Description classFTPPathMethods in com.pervasive.datarush.io that return Path Modifier and Type Method Description static PathPaths. asPath(File file)Converts aFileinto aPathobject.static PathPaths. asPath(String path)Parses a string representing a path into aPathobject.static Path[]Paths. asPaths(File[] files)Converts an array of files into an array of paths.PathFileClient. createDirectories(Path path)Creates the directory identified by the given path, creating any necessary parent directories.PathFileSystem. createDirectories(Path path)Creates the directory identified by the given path, creating any necessary parent directories.PathFileClient. createDirectory(Path path)Creates the directory identified by the given path.PathFileSystem. createDirectory(Path path)Creates the directory identified by the given path.PathFileClient. createTemporaryStorage()Creates a temporary storage location using default configuration.PathFileClient. createTemporaryStorage(File indexPath, Path[] storagePaths)Creates a temporary storage location using the specified configuration.PathBuiltinStreamProvider. getFileSystemPath(Path path)PathFileSystemProvider. getFileSystemPath(Path path)Returns the filesystem root path associated with the given path.PathFTPFileSystemProvider. getFileSystemPath(Path path)PathLocalFileSystemProvider. getFileSystemPath(Path path)PathSFTPFileSystemProvider. getFileSystemPath(Path path)PathURLFileSystemProvider. getFileSystemPath(Path path)PathFTPPath. getParent()PathPath. getParent()Gets the path referring to the location containing the path.PathBasicPathDetails. getPath()PathBuiltinStreamProvider. getPath(String path)PathDataSplit. getPath()Gets the path to the file on which the split is defined.PathFileSplit. getPath()PathFileSystemProvider. getPath(String path)Gets the path identified by the given string.PathFTPFileSystemProvider. getPath(String path)PathLocalFileSystemProvider. getPath(String path)PathPathDetails. getPath()Gets the path associated with the metadata.PathSFTPFileSystemProvider. getPath(String path)PathURLFileSystemProvider. getPath(String path)PathFTPPath. getRoot()abstract PathUnixStyleGlobbing.GlobDefinition. getRootPath()Gets the initial path from which globbing starts.Path[]FileClient. getTempFilesystemRootDirectories()Returns the root directories used by default for temp storage by this clientPathFTPPath. resolve(String childPath)PathPath. resolve(String childPath)Adds additional elements to the path.PathFTPPath. toAbsolutePath()PathPath. toAbsolutePath()Converts a relative path into an absolute path.Methods in com.pervasive.datarush.io that return types with arguments of type Path Modifier and Type Method Description static List<Path>Paths. asPaths(List<String> paths)Parses a string list representing a path into a list ofPath's.static List<Path>Paths. extractPaths(List<PathDetails> details)Convert a list ofPathDetailsobjects to a list ofPathobjects.static List<Path>Paths. extractPaths(List<PathDetails> details, boolean includeHidden)Convert a list ofPathDetailsobjects to a list ofPathobjects.List<Path>PathGlob. findMatches()List<Path>FileClient. listAllFiles(Path path, DirectoryFilter filter)Gets the contents of the specified directory including hidden files, applying a filter.List<Path>FileClient. listFiles(Path path)Gets the contents of the specified directory.List<Path>FileClient. listFiles(Path path, DirectoryFilter filter)Gets the contents of the specified directory, applying a filter.List<Path>FileClient. matchPaths(String pattern)Finds all paths matching the specified pattern.Methods in com.pervasive.datarush.io with parameters of type Path Modifier and Type Method Description static FileClientFileClient. configuredClient(FileMetaConfiguration configuration, ModuleConfiguration moduleConfiguration, File indexPathBase, Path[] tempFsRootDirs)Creates a new client, authorized according to the given configuration.voidFileClient. copy(Path from, Path to)Copies a file or directory from one location to another.PathFileClient. createDirectories(Path path)Creates the directory identified by the given path, creating any necessary parent directories.PathFileSystem. createDirectories(Path path)Creates the directory identified by the given path, creating any necessary parent directories.PathFileClient. createDirectory(Path path)Creates the directory identified by the given path.PathFileSystem. createDirectory(Path path)Creates the directory identified by the given path.booleanFileClient. createNewFile(Path path)Creates the file identified by the given path.booleanFileSystem. createNewFile(Path path)Creates the file identified by the given path, if it doesn't already exist.PathFileClient. createTemporaryStorage(File indexPath, Path[] storagePaths)Creates a temporary storage location using the specified configuration.voidFileClient. delete(Path path)Deletes the file or directory identified by the specified path.voidFileClient. delete(Path path, boolean recursively)Deletes the file or directory identified by the specified path.voidFileSystem. delete(Path path, boolean recursively)Deletes the file or directory identified by the specified path.booleanFileClient. exists(Path path)Indicates whether the specified path represents an existing file or directory.booleanFileSystem. exists(Path path)Indicates whether the specified path represents an existing file or directory.PathDetailsFileClient. getDetails(Path path)Returns metadata associated with the specified path.PathDetailsFileSystem. getDetails(Path path)Returns metadata associated with the specified path.FileSystemBuiltinStreamProvider. getFileSystem(FileClient fileClient, FileConfiguration configuration, Path path)FileSystemFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)Gets the file system identified by the path.FileSystemFTPFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)FileSystemLocalFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)FileSystemSFTPFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)FileSystemURLFileSystemProvider. getFileSystem(FileClient client, FileConfiguration configuration, Path path)ObjectFileClient. getFileSystemImplementation(Path path)Returns the underlying implementation object for the file system implementation of the given path.PathBuiltinStreamProvider. getFileSystemPath(Path path)PathFileSystemProvider. getFileSystemPath(Path path)Returns the filesystem root path associated with the given path.PathFTPFileSystemProvider. getFileSystemPath(Path path)PathLocalFileSystemProvider. getFileSystemPath(Path path)PathSFTPFileSystemProvider. getFileSystemPath(Path path)PathURLFileSystemProvider. getFileSystemPath(Path path)StringFileClient. getFileSystemType(Path path)Returns an identifier for the filesystem type.StringFileSystem. getFileSystemType(Path path)Returns an identifier for the filesystem type.static FilePaths. getIndexFile(Path path)Returns the index file associated with a temporary file path.longFileClient. getLength(Path path)Returns the length of the file represented by the given pathlongFileSystem. getLength(Path path)Returns the length of the file represented by the given path.SplitIteratorFileClient. getSplitIterator(Path path)Computes data splits over the specified file.SplitIteratorFileClient. getSplitIterator(Path path, SplitOptions options)Computes data splits over the specified file.SplitIteratorFileSystem. getSplits(Path path, SplitOptions options)Computes data splits over the specified file.booleanFileClient. isCreatable(Path path)Indicates whether the specified path can be created.booleanFileSystem. isCreatable(Path path)Indicates whether the specified path can be created.booleanFileClient. isDirectory(Path path)Indicates whether the specified path represents a directory.booleanFileSystem. isDirectory(Path path)Indicates whether the specified path represents a directory.booleanFileClient. isFile(Path path)Indicates whether the specified path represents a file.booleanFileSystem. isFile(Path path)Indicates whether the specified path represents a file.booleanFileClient. isHidden(Path path)Indicates whether the associated path is hidden by the file system.booleanFileSystem. isHidden(Path path)Indicates whether the associated path is hidden by the file system.booleanFileClient. isReadable(Path path)Indicates whether the specified path can be read.booleanFileSystem. isReadable(Path path)Indicates whether the specified path can be read.booleanFileClient. isWritable(Path path)Indicates whether the specified path can be written.booleanFileSystem. isWritable(Path path)Indicates whether the specified path can be written.List<Path>FileClient. listAllFiles(Path path, DirectoryFilter filter)Gets the contents of the specified directory including hidden files, applying a filter.List<PathDetails>FileClient. listDirectory(Path path)Gets the contents of the specified directory.List<PathDetails>FileClient. listDirectory(Path path, DirectoryFilter filter)Gets the contents of the specified directory, applying a filter.List<PathDetails>FileSystem. listDirectory(Path path, DirectoryFilter filter)Gets the contents of the specified directory, applying a filter.List<Path>FileClient. listFiles(Path path)Gets the contents of the specified directory.List<Path>FileClient. listFiles(Path path, DirectoryFilter filter)Gets the contents of the specified directory, applying a filter.voidFileClient. move(Path from, Path to)Moves a file or directory from one location to another.booleanFileSystem. move(FileSystem fromFS, Path from, Path to)Moves a file or directory from one location to another if possible.FileChannelFileClient. newFileChannel(Path path)Opens the specified file for random access.FileChannelFileSystem. newFileChannel(Path path)Opens the specified file for random access.InputStreamFileClient. newInputStream(Path path)Opens the specified file for reading.InputStreamFileSystem. newInputStream(Path path)Opens the specified file for reading.OutputStreamFileClient. newOutputStream(Path path, WriteMode mode)Opens the specified file for writing.OutputStreamFileSystem. newOutputStream(Path path, WriteMode mode)Opens the specified file for writing.static InputStreamSupplierInputStreamSuppliers. path(FileClient client, Path path)Returns an InputStreamSupplier that will open the specified path.static InputStreamSupplierInputStreamSuppliers. path(FileClient client, Path path, boolean ignoreNonExistent)Returns an InputStreamSupplier that will open the specified path.booleanFileClient. supportsDirectories(Path path)Indicates whether the filesystem corresponding to this path supports directoriesbooleanFileClient. supportsRandomAccess(Path path)Indicates whether the filesystem corresponding to this path supports random accessvoidFileClient. unzip(Path from, Path to)Recursively unzips the given file to a given directory/filebooleanFileClient. zipRecursively(Path from, OutputStream out, boolean ignoreNonReadable)Recursively zips the given input file/directory to the given streamMethod parameters in com.pervasive.datarush.io with type arguments of type Path Modifier and Type Method Description static InputStreamSupplierInputStreamSuppliers. combine(FileClient client, List<Path> paths, boolean ignoreNonExistant)Creates an InputStreamSupplier that will return an input stream consisting of the streams of each of the sources, combined together.InputStreamFileSystem. concat(List<Path> paths, boolean ignoreNonExistent)Returns an input stream consisting of the given list of paths concatenated together.static InputStreamSupplierInputStreamSuppliers. concat(FileClient client, List<Path> paths)Creates an InputStreamSupplier that will return an input stream consisting of the streams of each of the paths, concatenated together.static InputStreamSupplierInputStreamSuppliers. concat(FileClient client, List<Path> paths, boolean ignoreNonExistent)Creates an InputStreamSupplier that will return an input stream consisting of the streams of each of the paths, concatenated together.Constructors in com.pervasive.datarush.io with parameters of type Path Constructor Description BasicPathDetails(Path path, boolean readable, boolean writable, boolean hidden, BasicPathDetails.ObjectType type, long size)CompressedFileSplit(Path path, CompressionFormat format)Creates a split encompassing the entire file named by the path.FileSplit(Path path)Creates a split encompassing the entire file named by the path.FileSplit(Path path, long start, long length)Creates a split of the file named by the path.FileSplit(Path path, long start, long length, FileClient client)SplittableCompressedFileSplit(Path path, long startOffset, long length, CompressionFormat format)Construct an instance. -
Uses of Path in com.pervasive.datarush.io.compression
Methods in com.pervasive.datarush.io.compression with parameters of type Path Modifier and Type Method Description static CompressionFormatCompressionFormats. detectFormat(Path path)Locates the identified compression format for a file based on the path.SplitIteratorBZipCompression. getSplitIterator(FileClient client, Path filePath, SplitOptions options)SplitIteratorCompressionFormat. getSplitIterator(FileClient client, Path filePath, SplitOptions options)Create aSplitIteratorfor the given file path and options.SplitIteratorGZipCompression. getSplitIterator(FileClient client, Path filePath, SplitOptions options)SplitIteratorSnappyCompression. getSplitIterator(FileClient client, Path filePath, SplitOptions options)SplitIteratorUncompressedData. getSplitIterator(FileClient client, Path filePath, SplitOptions options) -
Uses of Path in com.pervasive.datarush.io.configuration
Methods in com.pervasive.datarush.io.configuration with parameters of type Path Modifier and Type Method Description static FileMetaConfiguration.EntryFileMetaConfiguration. entry(Path prefix, FileConfiguration configuration)Creates a new entryFileMetaConfiguration.EntryFileMetaConfiguration. findEntry(Path path)Returns the first entry whose prefix is a prefix of the given pathFileConfigurationFileMetaConfiguration. getConfiguration(Path path)Returns the configuration to be used for the given path orFileConfiguration.EMPTY_CONFIGURATIONif none found. -
Uses of Path in com.pervasive.datarush.operators
Methods in com.pervasive.datarush.operators that return Path Modifier and Type Method Description PathExecutionContext. allocateTemporaryStorage()Allocates space for storing a temporary file or files. -
Uses of Path in com.pervasive.datarush.operators.io
Methods in com.pervasive.datarush.operators.io that return Path Modifier and Type Method Description PathBasicByteSink. getPath()Gets the path identifying the byte sink.PathBasicByteSource. getPath()Gets the path identifying the byte source.Methods in com.pervasive.datarush.operators.io with parameters of type Path Modifier and Type Method Description voidAbstractReader. setSource(Path path)Sets the data source to the specified path.voidAbstractWriter. setTarget(Path path)Sets the data sink for the writer.Method parameters in com.pervasive.datarush.operators.io with type arguments of type Path Modifier and Type Method Description static ByteSourceConcatenatedByteSource. getConcatenatedSource(List<Path> paths)Creates a source which is the concatenation of the specified paths, in order.static ByteSourceConcatenatedByteSource. getConcatenatedSource(List<Path> paths, UnreadableSourceAction onUnreadable)Creates a source which is the concatenation of the specified paths, in order.Constructors in com.pervasive.datarush.operators.io with parameters of type Path Constructor Description AbstractReader(Path path)Reads the file specified by the path.AbstractWriter(Path path, WriteMode mode)Writes to the specified path in the given mode.BasicByteSink(Path path)Creates a data sink for the named path.BasicByteSink(Path path, CompressionFormat format)Creates a data sink for the named path.BasicByteSource(Path path)Creates a data source for the named path.BasicByteSource(Path path, CompressionFormat format)Creates a data source for the named path.BasicByteSource(Path path, UnreadableSourceAction onUnreadable)Creates a data source for the named path. -
Uses of Path in com.pervasive.datarush.operators.io.avro
Methods in com.pervasive.datarush.operators.io.avro with parameters of type Path Modifier and Type Method Description static AvroMetadataAvroMetadata. load(FileClient fileClient, Path path)Loads metadata from the specified Avro formatted file.Constructors in com.pervasive.datarush.operators.io.avro with parameters of type Path Constructor Description ReadAvro(Path path)Reads the file specified by the path.WriteAvro(Path path, WriteMode mode)Writes to the specified path in the given mode. -
Uses of Path in com.pervasive.datarush.operators.io.mdf
Constructors in com.pervasive.datarush.operators.io.mdf with parameters of type Path Constructor Description ReadMDF(Path path)Reads the file specified by the path. -
Uses of Path in com.pervasive.datarush.operators.io.staging
Methods in com.pervasive.datarush.operators.io.staging that return Path Modifier and Type Method Description PathDatasetIterator. getDataset()loads the next bufferConstructors in com.pervasive.datarush.operators.io.staging with parameters of type Path Constructor Description DatasetBuilder(FileClient client, Path dataset, int bufferSize, TokenEncodings baseEncodings, RecordTokenType type, WriteMode mode, int blockSize)Creates and opens the builder.DatasetIterator(FileClient fileClient, Path dataset, int bufferSize, TokenEncodings baseEncodings)Creates and opens the iterator.DatasetMetadata(FileClient fileClient, Path dataset)Creates a DatasetMetadata for an existing dataset.ReadStagingDataset(Path path)Reads the file specified by the path as staged data using default options.WriteStagingDataset(Path path, WriteMode mode)Writes to the specified path in the given mode, using default options. -
Uses of Path in com.pervasive.datarush.operators.io.textfile
Methods in com.pervasive.datarush.operators.io.textfile with parameters of type Path Modifier and Type Method Description ARFFAnalyzer.AnalysisARFFAnalyzer. analyze(Path file, CharsetEncoding encoding)Analyze the specified ARFF file expecting the described character set encoding.ARFFAnalyzer.AnalysisARFFAnalyzer. analyze(Path file, CharsetEncoding encoding, FileClient client)Analyze the specified ARFF file expecting the described character set encoding.DelimitedTextAnalyzer.AnalysisDelimitedTextAnalyzer. analyze(Path file, CharsetEncoding charsetSpec)Analyzes the specified file based on current configuration.DelimitedTextAnalyzer.AnalysisDelimitedTextAnalyzer. analyze(Path file, CharsetEncoding charsetSpec, FileClient client)Analyzes the specified file based on current configuration.FormatAnalyzer.FormatAnalysisFormatAnalyzer. analyze(Path file, CharsetEncoding encoding)Analyze the specified file expecting the described character set encoding.FormatAnalyzer.FormatAnalysisFormatAnalyzer. analyze(Path file, CharsetEncoding encoding, FileClient client)Analyze the specified file expecting the described character set encoding.JsonTextAnalyzer.JsonAnalysisJsonTextAnalyzer. analyze(Path file, CharsetEncoding charsetSpec)Analyzes the specified JSON file based on current configuration.JsonTextAnalyzer.JsonAnalysisJsonTextAnalyzer. analyze(Path file, CharsetEncoding charsetSpec, FileClient client)Analyzes the specified JSON file based on current configuration.Constructors in com.pervasive.datarush.operators.io.textfile with parameters of type Path Constructor Description AbstractTextReader(Path path)Reads the file specified by the path using default options.AbstractTextWriter(Path path, WriteMode mode)Writes text to the specified path in the given mode, using default settings.ReadARFF(Path path)Reads the file specified by the path as ARFF data using default options.ReadDelimitedText(Path path)Reads the file specified by the path as delimited text using default options.ReadFixedText(Path path)Reads the file specified by the path as fixed text using default options.ReadJSON(Path path)Reads the file specified by the path using default options.ReadLog(Path path)Reads the file specified by the path as log text using default options.WriteARFF(Path path, WriteMode mode)Writes ARFF data to the specified path in the given mode, using default settings.WriteDelimitedText(Path path, WriteMode mode)Writes delimited text to the specified path in the given mode, using default settings.WriteFixedText(Path path, WriteMode mode)Writes fixed text to the specified path in the given mode, using default settings.
-