Package com.illumon.iris.db.v2.locations.local

Class NestedPartitionedLocalTableLocationScanner

java.lang.Object

com.illumon.iris.db.v2.locations.local.NestedPartitionedLocalTableLocationScanner

All Implemented Interfaces:

com.illumon.iris.db.v2.locations.local.LocalTableLocationProvider.Scanner

public class NestedPartitionedLocalTableLocationScanner
extends Object
implements com.illumon.iris.db.v2.locations.local.LocalTableLocationProvider.Scanner

Local table location scanner that can handle two-level partitioning.

Constructor Summary

Constructors

Constructor	Description
NestedPartitionedLocalTableLocationScanner(LocalTablePathManager locationManager, TableKey tableKey)

Method Summary

Modifier and Type	Method	Description
File	computeLocationDirectory(TableKey tableKey, TableLocationKey locationKey)
String	getRoot()	Get the starting location for this scanner.
void	scanAll(Consumer<TableLocationKey> locationKeyObserver)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.v2.locations.local.LocalTableLocationProvider.Scanner

getMetadataIndex

Constructor Details

NestedPartitionedLocalTableLocationScanner

@VisibleForTesting
public NestedPartitionedLocalTableLocationScanner(@NotNull
 LocalTablePathManager locationManager,
 @NotNull
 TableKey tableKey)

Method Details

toString

public String toString()

Overrides:

toString in class Object

getRoot

public String getRoot()

Description copied from interface: com.illumon.iris.db.v2.locations.local.LocalTableLocationProvider.Scanner

Get the starting location for this scanner.

Specified by:

getRoot in interface com.illumon.iris.db.v2.locations.local.LocalTableLocationProvider.Scanner

Returns:

the starting location for this scanner

scanAll

public void scanAll(@NotNull
 Consumer<TableLocationKey> locationKeyObserver)

Specified by:

scanAll in interface com.illumon.iris.db.v2.locations.local.LocalTableLocationProvider.Scanner

computeLocationDirectory

public File computeLocationDirectory(@NotNull
 TableKey tableKey,
 @NotNull
 TableLocationKey locationKey)

Specified by:

computeLocationDirectory in interface com.illumon.iris.db.v2.locations.local.LocalTableLocationProvider.Scanner