TransactionPartitioner

java.lang.Object
- cz.o2.proxima.core.transaction.TransactionPartitioner

All Implemented Interfaces:: Partitioner, java.io.Serializable

public class TransactionPartitioner
extends java.lang.Object
implements Partitioner

See Also:: Serialized Form

- Constructor Summary
  
  Constructors
  Constructor Description
  
  TransactionPartitioner()
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  int getPartitionId(StreamElement element)
  Retrieve partition ID for the specified ingest.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  - Methods inherited from interface cz.o2.proxima.core.storage.commitlog.Partitioner
    close, setup

- Constructor Detail
  - TransactionPartitioner
```
public TransactionPartitioner()
```
- Method Detail
  - getPartitionId
```
public int getPartitionId(StreamElement element)
```
    Description copied from interface: Partitioner
    
    Retrieve partition ID for the specified ingest. All ingests that have the same partition ID are guaranteed to be written to the same Kafka partition.
    
    Specified by:
    
    getPartitionId in interface Partitioner
    
    Parameters:
    
    element - element to calculate partition for
    
    Returns:
    
    ID of partition (can be negative)