public void initializeState()

in analytics/src/main/java/com/amazonaws/services/timestream/TimestreamSink.java [148:158]

• 9 lines of code
• 3 McCabe index (conditional complexity)

    public void initializeState(FunctionInitializationContext functionInitializationContext) throws Exception {
        ListStateDescriptor<Record> descriptor = new ListStateDescriptor<>("recordList", Record.class);

        checkPointedState = functionInitializationContext.getOperatorStateStore().getListState(descriptor);

        if (functionInitializationContext.isRestored()) {
            for (Record element : checkPointedState.get()) {
                bufferedRecords.add(element);
            }
        }
    }