Package io.deephaven.importers.util

Class IngesterUtils

java.lang.Object

io.deephaven.importers.util.IngesterUtils

public class IngesterUtils
extends Object

Importer utilities required for the Illumon importers

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DAY
static final long	HOUR
static final long	MINUTE
static final long	SECOND
static final long	WEEK
static final long	YEAR

Constructor Summary

Constructors

Constructor	Description
IngesterUtils(Logger log, String partition)

Method Summary

Modifier and Type	Method	Description
static Map<String,String>	getAttributesMap(@NotNull ImporterColumnDefinition importerColumnDefinition)	Utility method to get the attributes from an ImporterColumnDefinition.
static List<String>	getColumnNamesFromSchema(@Nullable io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition tableDefinition, boolean includePartitioningColumn)	Returns a list of column source names from a schema and ImportSource.
String[]	getFilenameAry(String serverName, String pattern, boolean isPrefix)	Get the list of files to be processed.

Methods inherited from class java.lang.Object

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

Field Details

SECOND

public static final long SECOND

See Also:

• Constant Field Values

MINUTE

public static final long MINUTE

See Also:

• Constant Field Values

HOUR

public static final long HOUR

See Also:

• Constant Field Values

DAY

public static final long DAY

See Also:

• Constant Field Values

WEEK

public static final long WEEK

See Also:

• Constant Field Values

YEAR

public static final long YEAR

See Also:

• Constant Field Values

Constructor Details

IngesterUtils

public IngesterUtils(Logger log,
 String partition)

Parameters:

log - the Logger

partition - the partition

Method Details

getFilenameAry

public String[] getFilenameAry(String serverName,
 String pattern,
 boolean isPrefix)

Get the list of files to be processed.

Parameters:

serverName - the server name

pattern - the pattern to match

isPrefix - true if the pattern is a prefix, false if it is a substring

Returns:

an array of file names

getColumnNamesFromSchema

public static List<String> getColumnNamesFromSchema(@Nullable
 @Nullable io.deephaven.shadow.enterprise.org.jdom2.Element sourceElement,
 @NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition tableDefinition,
 boolean includePartitioningColumn)

Returns a list of column source names from a schema and ImportSource.

Parameters:

sourceElement - optional Schema ImportSource to use when finding alternate source names for table columns

tableDefinition - TableDefinition object for the table

includePartitioningColumn - whether to include the partitioning column in the resultant list

Returns:

a list of column names.

getAttributesMap

public static Map<String,String> getAttributesMap(@NotNull
 @NotNull ImporterColumnDefinition importerColumnDefinition)

Utility method to get the attributes from an ImporterColumnDefinition.

Parameters:

importerColumnDefinition - the ImporterColumnDefinition

Returns:

a Map of the attributes.