Package com.illumon.iris.db.tables.dataimport.logtailer

Class DISCommandUtil

java.lang.Object

com.illumon.iris.db.tables.dataimport.logtailer.DISCommandUtil

@InternalUseOnly
public class DISCommandUtil
extends Object

Utilities for DIS command channel. This is shared by ConfigurationTools and Ingesters projects.
Deephaven internal use only, except for consuming the ActionResult class as a return value.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DISCommandUtil.ActionResult	Results of a truncate or delete operation.

Constructor Summary

Constructors

Constructor	Description
DISCommandUtil()

Method Summary

Modifier and Type	Method	Description
static DISCommandUtil.ActionResult	truncateAndDeleteIntradayPartitionImpl(com.fishlib.io.logger.Logger userLog, com.fishlib.io.logger.Logger sysLog, TableIdentifier tableIdentifier, String internalPartitionValue, String columnPartitionValue, Collection<? extends DataImportServiceConfig.DeferredEndpoint> dises, io.deephaven.enterprise.auth.TokenFactoryFactory tokenAuthenticationManager)	Send a truncate message to all listed DIS endpoints, followed by a delete message if the truncate succeeds.
static DISCommandUtil.ActionResult	truncateOrDeleteIntradayPartitionImpl(com.fishlib.io.logger.Logger userLog, com.fishlib.io.logger.Logger sysLog, TableIdentifier tableIdentifier, String internalPartitionValue, String columnPartitionValue, Collection<? extends DataImportServiceConfig.DeferredEndpoint> dises, boolean delete, boolean dryRun, io.deephaven.enterprise.auth.TokenFactoryFactory tokenAuthenticationManager)	Send a truncate or delete message to all listed DIS endpoints.

Methods inherited from class java.lang.Object

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

Constructor Details

DISCommandUtil

public DISCommandUtil()

Method Details

truncateOrDeleteIntradayPartitionImpl

@InternalUseOnly
public static DISCommandUtil.ActionResult truncateOrDeleteIntradayPartitionImpl(@NotNull
 com.fishlib.io.logger.Logger userLog,
 @NotNull
 com.fishlib.io.logger.Logger sysLog,
 @NotNull
 TableIdentifier tableIdentifier,
 @Nullable
 String internalPartitionValue,
 @NotNull
 String columnPartitionValue,
 @NotNull
 Collection<? extends DataImportServiceConfig.DeferredEndpoint> dises,
 boolean delete,
 boolean dryRun,
 @NotNull
 io.deephaven.enterprise.auth.TokenFactoryFactory tokenAuthenticationManager)

Send a truncate or delete message to all listed DIS endpoints.

Parameters:

userLog - for informational logging to the console/UI

sysLog - for logging a process log

tableIdentifier - the System table to truncate or delete

internalPartitionValue - optional internal partition to truncate or delete. Null means "all" internal partitions

columnPartitionValue - the column partition to truncate or delete

dises - collection of dises to which requests will be sent

delete - if false, truncate the location, else delete it

dryRun - if true, the DIS will not actually perform the action, but will indicate what locations would have been affected.

tokenAuthenticationManager - the TokenFactoryFactory to use for authentication, will be AuthenticationClientManager.getDefault() in most cases

Returns:

the compound result in ActionResult

truncateAndDeleteIntradayPartitionImpl

@InternalUseOnly
public static DISCommandUtil.ActionResult truncateAndDeleteIntradayPartitionImpl(@NotNull
 com.fishlib.io.logger.Logger userLog,
 @NotNull
 com.fishlib.io.logger.Logger sysLog,
 @NotNull
 TableIdentifier tableIdentifier,
 @Nullable
 String internalPartitionValue,
 @NotNull
 String columnPartitionValue,
 @NotNull
 Collection<? extends DataImportServiceConfig.DeferredEndpoint> dises,
 @NotNull
 io.deephaven.enterprise.auth.TokenFactoryFactory tokenAuthenticationManager)

Send a truncate message to all listed DIS endpoints, followed by a delete message if the truncate succeeds.

Parameters:

userLog - for informational logging

sysLog - for logging a process log

tableIdentifier - the System table to delete

internalPartitionValue - optional internal partition value to delete. Null means "all" internal partitions

columnPartitionValue - the column partition to delete

dises - collection of dises to which requests will be sent

tokenAuthenticationManager - the TokenFactoryFactory to use in authentication, will be AuthenticationClientManager.getDefault() in most cases

Returns:

the compound result in ActionResult