Package io.deephaven.enterprise.lastbystate

Class LastByPartitionedTableFactory

java.lang.Object

io.deephaven.enterprise.lastbystate.LastByPartitionedTableFactory

public class LastByPartitionedTableFactory
extends Object

The LastByPartitionedTableFactory attaches to an Enterprise DataImportServer and produces a Core PartitionedTable with one constituent entry per partition for a given namespace and table name. Each constituent represents the last row for the key configured in the import state.

Method Summary

Modifier and Type	Method	Description
PartitionedTable	createPartitionedTable(@NotNull String namespace, @NotNull String tableName, @NotNull String columnPartitionValue)	This method is the same as createPartitionedTable(String, String, String, String) with a null viewName.
PartitionedTable	createPartitionedTable(@NotNull String namespace, @NotNull String tableName, @NotNull String columnPartitionValue, String viewName)	Create a last-by indexed PartitionedTable for intraday data from the specified namespace, table name, and column partition value.
static LastByPartitionedTableFactory	forDataImportServer(@NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.DataImportServer dataImportServer)	Build a LastByTableMapFactory consuming data and last-by indexes from the supplied DataImportServer.

Methods inherited from class java.lang.Object

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

Method Details

forDataImportServer

public static LastByPartitionedTableFactory forDataImportServer(@NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.DataImportServer dataImportServer)

Build a LastByTableMapFactory consuming data and last-by indexes from the supplied DataImportServer.

Parameters:

dataImportServer - The data import server to consume data and last-by indexes from

Returns:

The new factory

createPartitionedTable

public PartitionedTable createPartitionedTable(@NotNull
 @NotNull String namespace,
 @NotNull
 @NotNull String tableName,
 @NotNull
 @NotNull String columnPartitionValue)

This method is the same as createPartitionedTable(String, String, String, String) with a null viewName.

Parameters:

namespace - The namespace

tableName - The table name

columnPartitionValue - The column partition value

Returns:

A new PartitionedTable as specified

createPartitionedTable

public PartitionedTable createPartitionedTable(@NotNull
 @NotNull String namespace,
 @NotNull
 @NotNull String tableName,
 @NotNull
 @NotNull String columnPartitionValue,
 String viewName)

Create a last-by indexed PartitionedTable for intraday data from the specified namespace, table name, and column partition value. This table map will be keyed by TableLocation, and each table will represent a last-by view of one partition of the data.

Parameters:

namespace - The namespace

tableName - The table name

columnPartitionValue - The column partition value

viewName - The name of this particular last-by view, also passed to LastByImportState instances (may be null)

Returns:

A new PartitionedTable as specified