private void resetFlushTimer()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java [242:260]

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

    private void resetFlushTimer(boolean shouldDestroyTimer) {
        if (flushInterval > 0) {
            if (shouldDestroyTimer) {
                if (timer != null) {
                    timer.cancel();
                }
                timer = new Timer(true);
            }
            TimerTask t = new TimerTask() {
                @Override
                public void run() {
                    flushByTimeImpl();
                }
            };
            if (timer != null) {
                timer.schedule(t, flushInterval);
            }
        }
    }