CombinedConsumer

java.lang.Object

com.semedy.reasoner.edb.persistentstore.CombinedConsumer

All Implemented Interfaces:: ExternalSortTuplesConsumer

public class CombinedConsumer extends Object implements ExternalSortTuplesConsumer

Constructor Summary

Constructors

Constructor

Description

CombinedConsumer(ExternalSortTuplesConsumer[] consumers)

CombinedConsumer(List<ExternalSortTuplesConsumer> consumers)
Method Summary

Modifier and Type

Method

Description

void

close()

void

consume(byte[] tuple)

void

consume(long[] tuple)

void

init()

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- CombinedConsumer
  
  public CombinedConsumer(ExternalSortTuplesConsumer[] consumers)
- CombinedConsumer
  
  public CombinedConsumer(List<ExternalSortTuplesConsumer> consumers)
Method Details
- consume
  
  public void consume(byte[] tuple) throws IOException, EDBException
  
  Specified by:
  
  consume in interface ExternalSortTuplesConsumer
  
  Throws:
  
  IOException
  
  EDBException
- close
  
  public void close() throws IOException, EDBException
  
  Specified by:
  
  close in interface ExternalSortTuplesConsumer
  
  Throws:
  
  IOException
  
  EDBException
- init
  
  public void init() throws IOException, EDBException
  
  Specified by:
  
  init in interface ExternalSortTuplesConsumer
  
  Throws:
  
  IOException
  
  EDBException
- consume
  
  public void consume(long[] tuple) throws IOException
  
  Specified by:
  
  consume in interface ExternalSortTuplesConsumer
  
  Throws:
  
  IOException