InternalTopologyBuilder.GlobalStore (kafka 2.6.1.100-eep-810 API)

java.lang.Object
- org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.GlobalStore

All Implemented Interfaces:: TopologyDescription.GlobalStore

Enclosing class:: InternalTopologyBuilder

public static final class InternalTopologyBuilder.GlobalStore
extends Object
implements TopologyDescription.GlobalStore

Constructor Summary

Constructors
Constructor Description

GlobalStore(String sourceName, String processorName, String storeName, String topicName, int id)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object o)`
`int`	`hashCode()`
`int`	`id()`
`TopologyDescription.Processor`	`processor()`	The processor node maintaining the global store.
`TopologyDescription.Source`	`source()`	The source node reading from a "global" topic.
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - GlobalStore
```
public GlobalStore(String sourceName,
                   String processorName,
                   String storeName,
                   String topicName,
                   int id)
```
- Method Detail
  - id
```
public int id()
```
    Specified by:
    
    id in interface TopologyDescription.GlobalStore
  - source
```
public TopologyDescription.Source source()
```
    Description copied from interface: TopologyDescription.GlobalStore
    
    The source node reading from a "global" topic.
    
    Specified by:
    
    source in interface TopologyDescription.GlobalStore
    
    Returns:
    
    the "global" source node
  - processor
```
public TopologyDescription.Processor processor()
```
    Description copied from interface: TopologyDescription.GlobalStore
    
    The processor node maintaining the global store.
    
    Specified by:
    
    processor in interface TopologyDescription.GlobalStore
    
    Returns:
    
    the "global" processor node
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object