Package io.openlineage.client.utils.filesystem

Class ObjectStorageDatasetExtractor

java.lang.Object

io.openlineage.client.utils.filesystem.ObjectStorageDatasetExtractor

All Implemented Interfaces:

FilesystemDatasetExtractor

public class ObjectStorageDatasetExtractor
extends Object
implements FilesystemDatasetExtractor

Constructor Summary

Constructors

Constructor	Description
ObjectStorageDatasetExtractor(String scheme)
ObjectStorageDatasetExtractor(String scheme, String canonicalScheme)

Method Summary

Modifier and Type	Method	Description
DatasetIdentifier	extract(URI location)
DatasetIdentifier	extract(URI location, String rawName)
boolean	isDefinedAt(URI location)

Methods inherited from class java.lang.Object

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

Constructor Details

ObjectStorageDatasetExtractor

public ObjectStorageDatasetExtractor(String scheme)

ObjectStorageDatasetExtractor

public ObjectStorageDatasetExtractor(String scheme,
 String canonicalScheme)

Parameters:

scheme - the scheme prefix this extractor matches (e.g. abfs, which also matches abfss since matching is by prefix)

canonicalScheme - the scheme emitted in the resulting namespace; matched variants are normalized to it (e.g. abfs and abfss both normalize to abfss)

Method Details

isDefinedAt

public boolean isDefinedAt(URI location)

Specified by:

isDefinedAt in interface FilesystemDatasetExtractor

extract

public DatasetIdentifier extract(URI location)

Specified by:

extract in interface FilesystemDatasetExtractor

extract

public DatasetIdentifier extract(URI location,
 String rawName)

Specified by:

extract in interface FilesystemDatasetExtractor