org.apache.flink.connector.base.sink.writer.strategy

Class BasicResultInfo

java.lang.Object

org.apache.flink.connector.base.sink.writer.strategy.BasicResultInfo

All Implemented Interfaces:

ResultInfo

@Internal
public class BasicResultInfo
extends Object
implements ResultInfo

Dataclass to encapsulate results from completed requests.

Constructor Summary

Constructors

Constructor and Description
BasicResultInfo(int failedMessages, int batchSize)

Method Summary

Modifier and Type	Method and Description
int	getBatchSize()
int	getFailedMessages()

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicResultInfo

public BasicResultInfo(int failedMessages,
                       int batchSize)

Method Detail

getFailedMessages

public int getFailedMessages()

Specified by:

getFailedMessages in interface ResultInfo

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface ResultInfo