override fun initializeState()

in analytics-kotlin/src/main/kotlin/services/timestream/TimestreamSink.kt [130:136]

• 7 lines of code
• 2 McCabe index (conditional complexity)

    override fun initializeState(functionInitializationContext: FunctionInitializationContext) {
        val descriptor = ListStateDescriptor("recordList", Record::class.java)
        checkPointedState = functionInitializationContext.operatorStateStore.getListState(descriptor)
        if (functionInitializationContext.isRestored) {
            bufferedRecords.addAll(checkPointedState.get())
        }
    }