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.

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 DataRoutingService.DataImportServiceEndpoint> dises, com.fishlib.auth.WAuthenticationClientManager authenticationClientManager)	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 DataRoutingService.DataImportServiceEndpoint> dises, boolean delete, boolean dryRun, com.fishlib.auth.WAuthenticationClientManager authenticationClientManager)	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 DataRoutingService.DataImportServiceEndpoint> dises, boolean delete, boolean dryRun, @NotNull com.fishlib.auth.WAuthenticationClientManager authenticationClientManager)

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 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.

authenticationClientManager - the WAuthenticationClientManager to use for authentication, will be WAuthenticationClientManager.DEFAULT 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 DataRoutingService.DataImportServiceEndpoint> dises, @NotNull com.fishlib.auth.WAuthenticationClientManager authenticationClientManager)

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 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

authenticationClientManager - the WAuthenticationClientManager to use in authentication, will be WAuthenticationClientManager.DEFAULT in most cases

Returns:

the compound result in ActionResult