public void invoke()

in flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java [203:215]

• 10 lines of code
• 5 McCabe index (conditional complexity)

    public void invoke(T value, Context context) throws Exception {
        checkErrorAndRethrow();

        mutator.mutate(mutationConverter.convertToMutation(value));

        // flush when the buffer number of mutations greater than the configured max size.
        if (bufferFlushMaxMutations > 0
                && numPendingRequests.incrementAndGet() >= bufferFlushMaxMutations) {
            flush();
        } else if (bufferFlushMaxMutations == 0 && bufferFlushMaxSizeInBytes == 0) {
            flush();
        }
    }