File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed 
streaming/src/main/scala/org/apache/spark/streaming/util Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -89,16 +89,16 @@ private[streaming] class OpenHashMapBasedStateMap[K, S](
8989  extends  StateMap [K , S ] with  KryoSerializable  { self => 
9090
9191  def  this (initialCapacity : Int , deltaChainThreshold : Int )
92-       (implicit  keyClassTag : ClassTag [K ], valueClassTag : ClassTag [S ]) =  this (
92+       (implicit  keyClassTag : ClassTag [K ], stateClassTag : ClassTag [S ]) =  this (
9393    new  EmptyStateMap [K , S ],
9494    initialCapacity =  initialCapacity,
9595    deltaChainThreshold =  deltaChainThreshold)
9696
9797  def  this (deltaChainThreshold : Int )
98-       (implicit  keyClassTag : ClassTag [K ], valueClassTag : ClassTag [S ]) =  this (
98+       (implicit  keyClassTag : ClassTag [K ], stateClassTag : ClassTag [S ]) =  this (
9999    initialCapacity =  DEFAULT_INITIAL_CAPACITY , deltaChainThreshold =  deltaChainThreshold)
100100
101-   def  this ()(implicit  keyClassTag : ClassTag [K ], valueClassTag : ClassTag [S ]) =  {
101+   def  this ()(implicit  keyClassTag : ClassTag [K ], stateClassTag : ClassTag [S ]) =  {
102102    this (DELTA_CHAIN_LENGTH_THRESHOLD )
103103  }
104104
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments