com.datastax.oss.dsbulk.workflow.commons.schema

Class DefaultReadResultCounter

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultCounter

All Implemented Interfaces:

ReadResultCounter, AutoCloseable

public class DefaultReadResultCounter
extends Object
implements ReadResultCounter

Nested Class Summary

Nested classes/interfaces inherited from interface com.datastax.oss.dsbulk.workflow.commons.schema.ReadResultCounter

ReadResultCounter.CountingUnit

Constructor Summary

Constructors

Constructor and Description
DefaultReadResultCounter(CqlIdentifier keyspace, Metadata metadata, EnumSet<StatsSettings.StatisticsMode> modes, int numPartitions, ProtocolVersion protocolVersion, ConvertingCodecFactory codecFactory)

Method Summary

Modifier and Type	Method and Description
void	close()
com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultCounter.DefaultCountingUnit	newCountingUnit()
void	reportTotals()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultReadResultCounter

public DefaultReadResultCounter(CqlIdentifier keyspace,
                                Metadata metadata,
                                EnumSet<StatsSettings.StatisticsMode> modes,
                                int numPartitions,
                                ProtocolVersion protocolVersion,
                                ConvertingCodecFactory codecFactory)

Method Detail

newCountingUnit

public com.datastax.oss.dsbulk.workflow.commons.schema.DefaultReadResultCounter.DefaultCountingUnit newCountingUnit()

Specified by:

newCountingUnit in interface ReadResultCounter

close

public void close()

Specified by:

close in interface AutoCloseable

reportTotals

public void reportTotals()

Specified by:

reportTotals in interface ReadResultCounter