MINOR: rename InternalProcessorContext.initialized

streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java

@@ -203,7 +203,7 @@ public ThreadCache getCache() {
     }
 
     @Override
-    public void initialized() {
+    public void initialize() {
         initialized = true;
     }
 

streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java

@@ -74,7 +74,7 @@ public Map<TopicPartition, Long> initialize() {
             );
         }
         initTopology();
-        processorContext.initialized();
+        processorContext.initialize();
         return stateMgr.checkpointed();
     }
 

streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java

@@ -57,7 +57,7 @@ public interface InternalProcessorContext extends ProcessorContext {
     /**
      * Mark this context as being initialized
      */
-    void initialized();
+    void initialize();
 
     /**
      * Mark this context as being uninitialized

streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java

@@ -69,7 +69,7 @@ public boolean initializeStateStores() {
         log.trace("Initializing state stores");
         registerStateStores();
         checkpointedOffsets = Collections.unmodifiableMap(stateMgr.checkpointed());
-        processorContext.initialized();
+        processorContext.initialize();
         taskInitialized = true;
         return true;
     }

streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java

@@ -274,7 +274,7 @@ public void initializeTopology() {
             transactionInFlight = true;
         }
 
-        processorContext.initialized();
+        processorContext.initialize();
 
         taskInitialized = true;
 

streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java

@@ -58,7 +58,7 @@ public void before() {
 
     @Test
     public void shouldThrowIllegalStateExceptionOnRegisterWhenContextIsInitialized() {
-        context.initialized();
+        context.initialize();
         try {
             context.register(stateStore, null);
             fail("should throw illegal state exception when context already initialized");

streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java

@@ -170,7 +170,7 @@ public Serde<?> valueSerde() {
 
     // state mgr will be overridden by the state dir and store maps
     @Override
-    public void initialized() {}
+    public void initialize() {}
 
     public void setStreamTime(final long currentTime) {
         streamTime = currentTime;

streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java

@@ -81,7 +81,7 @@ public void commit() {
     }
 
     @Override
-    public void initialized() {
+    public void initialize() {
         initialized = true;
     }