Package org.gridgain.tpcds

Class TpcdsDataStreamer

java.lang.Object

org.gridgain.tpcds.TpcdsDataStreamer

public class TpcdsDataStreamer
extends Object

Utility class that uses TpcdsDataGenerator to ingest the data in a specified TPC-DS table using provided DataIngestorFactory.

Constructor Summary

Constructors

Constructor	Description
TpcdsDataStreamer(DataScale dataScale, DataIngestorFactory dataIngestorFactory)	Constructor of TpcdsDataStreamer.
TpcdsDataStreamer(TpcdsDataGenerator dataGenerator, DataIngestorFactory dataIngestorFactory)	Constructor of TpcdsDataStreamer.

Method Summary

Modifier and Type	Method	Description
static void	ingestAllData(DataScale dataScale, DataIngestorFactory dataIngestorFactory)
CompletableFuture<Void>	ingestAllTablesAsync()	Ingests data for all TPC-DS base tables in parallel.
CompletableFuture<Void>	ingestDataAsync(Table table)	Ingests the data into specified TPC-DS table.

Methods inherited from class java.lang.Object

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

Constructor Details

TpcdsDataStreamer

public TpcdsDataStreamer(DataScale dataScale,
 DataIngestorFactory dataIngestorFactory)

Constructor of TpcdsDataStreamer.

Parameters:

dataScale - data scale of the generated data.

dataIngestorFactory - factory of data ingestors, responsible for insertion of generated data.

TpcdsDataStreamer

public TpcdsDataStreamer(TpcdsDataGenerator dataGenerator,
 DataIngestorFactory dataIngestorFactory)

Constructor of TpcdsDataStreamer.

Parameters:

dataGenerator - data generator for this session.

dataIngestorFactory - factory of data ingestors, responsible for insertion of generated data.

Method Details

ingestAllData

public static void ingestAllData(DataScale dataScale,
 DataIngestorFactory dataIngestorFactory)

ingestDataAsync

public CompletableFuture<Void> ingestDataAsync(Table table)

Ingests the data into specified TPC-DS table.

Parameters:

table - TPC-DS table to insert the data to.

Returns:

a future that completes when data ingestion is completed.

ingestAllTablesAsync

public CompletableFuture<Void> ingestAllTablesAsync()

Ingests data for all TPC-DS base tables in parallel.

Returns:

a future that completes when data ingestion is completed for all tables.