io.druid.segment.loading

Class LocalFileTimestampVersionFinder

java.lang.Object

io.druid.segment.loading.LocalDataSegmentPuller

io.druid.segment.loading.LocalFileTimestampVersionFinder

All Implemented Interfaces:

SearchableVersionedDataFinder<URI>, DataSegmentPuller, URIDataPuller

public class LocalFileTimestampVersionFinder
extends LocalDataSegmentPuller
implements SearchableVersionedDataFinder<URI>

This is implemented explicitly for URIExtractionNamespaceFunctionFactory If you have a use case for this interface beyond URIExtractionNamespaceFunctionFactory please bring it up in the dev list.

Field Summary

Fields

Modifier and Type	Field and Description
static String	URI_SCHEME

Fields inherited from class io.druid.segment.loading.LocalDataSegmentPuller

DEFAULT_RETRY_COUNT

Constructor Summary

Constructors

Constructor and Description
LocalFileTimestampVersionFinder()

Method Summary

Modifier and Type	Method and Description
URI	getLatestVersion(URI uri, Pattern pattern) Matches based on a pattern in the file name.

Methods inherited from class io.druid.segment.loading.LocalDataSegmentPuller

buildFileObject, getInputStream, getSegmentFiles, getSegmentFiles, getVersion, shouldRetryPredicate

Methods inherited from class java.lang.Object

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

Field Detail

URI_SCHEME

public static final String URI_SCHEME

See Also:

Constant Field Values

Constructor Detail

LocalFileTimestampVersionFinder

public LocalFileTimestampVersionFinder()

Method Detail

getLatestVersion

public URI getLatestVersion(URI uri,
                            @Nullable
                            Pattern pattern)

Matches based on a pattern in the file name. Returns the file with the latest timestamp.

Specified by:

getLatestVersion in interface SearchableVersionedDataFinder<URI>

Parameters:

uri - If it is a file, then the parent is searched. If it is a directory, then the directory is searched.

pattern - The matching filter to down-select the file names in the directory of interest. Passing `null` results in matching any file

Returns:

The URI of the most recently modified file which matches the pattern, or `null` if it cannot be found