com.groupon.lex.metrics.history.xdr

Class TSDataOptimizerTask

java.lang.Object

com.groupon.lex.metrics.history.xdr.TSDataOptimizerTask

public class TSDataOptimizerTask
extends Object

A task that optimizes a set of files into a single table file.

Author:

ariane

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TSDataOptimizerTask.NewFile The result of installing a new optimized file.

Constructor Summary

Constructors

Constructor and Description
TSDataOptimizerTask(Path destDir) Create a new optimizer task and fill it with the given files.
TSDataOptimizerTask(Path destDir, Collection<TSData> files) Create a new optimizer task and fill it with the given files.

Method Summary

Modifier and Type	Method and Description
TSDataOptimizerTask	add(TSData tsdata) Add a file to the collection of files that will make up the final optimized file.
TSDataOptimizerTask	addAll(Collection<? extends TSData> tsdata) Add files to the collection of files that will make up the final optimized file.
CompletableFuture<TSDataOptimizerTask.NewFile>	run() Start creating the optimized file.
TSDataOptimizerTask	withCompression(Compression compression) Use the specified compression method for creating the optimized file.

Methods inherited from class java.lang.Object

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

Constructor Detail

TSDataOptimizerTask

public TSDataOptimizerTask(@NonNull
                           Path destDir,
                           @NonNull
                           Collection<TSData> files)

Create a new optimizer task and fill it with the given files.

Parameters:

destDir - the destination directory in which the new file will be placed.

files - a list of files to add.

TSDataOptimizerTask

public TSDataOptimizerTask(@NonNull
                           Path destDir)

Create a new optimizer task and fill it with the given files.

Parameters:

destDir - the destination directory in which the new file will be placed.

Method Detail

add

public TSDataOptimizerTask add(TSData tsdata)

Add a file to the collection of files that will make up the final optimized file.

Parameters:

tsdata - The TSData of which the contents are to be added to the optimized file.

Returns:

this TSDataOptimizerTask.

addAll

public TSDataOptimizerTask addAll(Collection<? extends TSData> tsdata)

Add files to the collection of files that will make up the final optimized file.

Parameters:

tsdata - The collection of TSData of which the contents are to be added to the optimized file.

Returns:

this TSDataOptimizerTask.

withCompression

public TSDataOptimizerTask withCompression(Compression compression)

Use the specified compression method for creating the optimized file.

Parameters:

compression - The compression method to use.

Returns:

this TSDataOptimizerTask.

run

public CompletableFuture<TSDataOptimizerTask.NewFile> run()

Start creating the optimized file. This operation resets the state of the optimizer task, so it can be re-used for subsequent invocations.

Returns:

A completeable future that yields the newly created file.