public interface AbstractBatchDataStreamRecordMetrics
Modifier and Type | Method and Description |
---|---|
void |
addSkipListener(SkipListener skipListener)
Add a SkipListener callback to the BDS.
|
void addSkipListener(SkipListener skipListener)
Add a SkipListener callback to the BDS. The SkipListener is called by the BDS whenever the BDS fails to read or write a record and is configured to skip the failed record.
skipListener
- The user-implemented SkipListener callback.