public class ConnectionStats extends Object
Constructor and Description |
---|
ConnectionStats() |
Modifier and Type | Method and Description |
---|---|
long |
getAbortedTransactions() |
long |
getAutoFlushCount() |
long |
getCommittedTransactions() |
LongAdder |
getCreatedPartitions() |
long |
getMetastoreCalls() |
long |
getRecordsSize() |
long |
getRecordsWritten() |
LongAdder |
getTotalPartitions() |
void |
incrementAbortedTransactions() |
void |
incrementAutoFlushCount() |
void |
incrementCommittedTransactions() |
void |
incrementCreatedPartitions(long delta)
Increment by delta the number of created partitions.
|
void |
incrementMetastoreCalls() |
void |
incrementRecordsSize(long delta) |
void |
incrementRecordsWritten() |
void |
incrementTotalPartitions(long delta)
Increment by delta the total partitions.
|
String |
toString() |
public void incrementRecordsWritten()
public void incrementCommittedTransactions()
public void incrementAbortedTransactions()
public void incrementAutoFlushCount()
public void incrementMetastoreCalls()
public void incrementRecordsSize(long delta)
public void incrementCreatedPartitions(long delta)
delta
- to increment by.public void incrementTotalPartitions(long delta)
delta
- to increment by.public long getRecordsWritten()
public long getRecordsSize()
public long getCommittedTransactions()
public long getAbortedTransactions()
public long getAutoFlushCount()
public long getMetastoreCalls()
public LongAdder getTotalPartitions()
public LongAdder getCreatedPartitions()
Copyright © 2022 The Apache Software Foundation. All rights reserved.