Skip to content

Commit 7fce9c3

Browse files
committed
SDK supports checkpoint feature
1 parent 0c5e9d3 commit 7fce9c3

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -201,20 +201,20 @@ public void add(int auditID, String inlongGroupID, String inlongStreamID, Long l
201201
}
202202

203203
public void add(int auditID, String auditTag, String inlongGroupID, String inlongStreamID, Long logTime,
204-
long count, long size) {
204+
long count, long size) {
205205
long delayTime = System.currentTimeMillis() - logTime;
206206
add(auditID, auditTag, inlongGroupID, inlongStreamID, logTime, count, size,
207207
delayTime * count, DEFAULT_AUDIT_VERSION);
208208
}
209209

210210
public void add(int auditID, String inlongGroupID, String inlongStreamID, Long logTime, long count, long size,
211-
long delayTime) {
211+
long delayTime) {
212212
add(auditID, DEFAULT_AUDIT_TAG, inlongGroupID, inlongStreamID, logTime, count, size,
213213
delayTime, DEFAULT_AUDIT_VERSION);
214214
}
215215

216216
public void add(int auditID, String auditTag, String inlongGroupID, String inlongStreamID, Long logTime,
217-
long count, long size, long delayTime, long auditVersion) {
217+
long count, long size, long delayTime, long auditVersion) {
218218
StringJoiner keyJoiner = new StringJoiner(FIELD_SEPARATORS);
219219
keyJoiner.add(String.valueOf(logTime / PERIOD));
220220
keyJoiner.add(inlongGroupID);

0 commit comments

Comments
 (0)