public class Accumulators
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
Accumulators(org.apache.spark.api.java.JavaSparkContext sc) |
Modifier and Type | Method and Description |
---|---|
void |
incNumBatches(int val) |
void |
incNumColumns(int val) |
void |
incNumHashes(int val) |
void |
incNumRecordsAfterFilter(int val) |
void |
incNumRecordsFiltered(int val) |
void |
incNumRecordsReceived(int val) |
java.lang.Integer |
numBatchesGetValue() |
java.lang.Integer |
numColumnsGetValue() |
java.lang.Integer |
numHashesGetValue() |
java.lang.Integer |
numRecordsFilteredGetValue() |
java.lang.Integer |
numRecordsReceivedGetValue() |
java.lang.Integer |
numRecordsRecordsAfterFilterGetValue() |
void |
printAll() |
void |
resetAll() |
public java.lang.Integer numRecordsReceivedGetValue()
public void incNumRecordsReceived(int val)
public java.lang.Integer numRecordsFilteredGetValue()
public void incNumRecordsFiltered(int val)
public java.lang.Integer numRecordsRecordsAfterFilterGetValue()
public void incNumRecordsAfterFilter(int val)
public java.lang.Integer numHashesGetValue()
public void incNumHashes(int val)
public java.lang.Integer numColumnsGetValue()
public void incNumColumns(int val)
public java.lang.Integer numBatchesGetValue()
public void incNumBatches(int val)
public void resetAll()
public void printAll()