Examples of PartitionMetaData

Examples of gov.nasa.arc.mct.buffer.internal.PartitionMetaData

            LOGGER.error("Exception in loadAllPartitionInformation", e);
        }
    }


    public PartitionMetaData removePartitionMetaData(int bufferPartition) {
        PartitionMetaData pObj = super.removePartitionMetaData(bufferPartition);
        if (pObj == null) { return null; }


        try {
            getMetaStoreIndex().delete(pObj.getPartitionId());
        } catch (Exception e) {
            LOGGER.error("Exception in getData", e);
        } finally {
            if (metaEnv != null) {
                metaEnv.flush();

View Full Code Here

Examples of gov.nasa.arc.mct.buffer.internal.PartitionMetaData

        return pObj;
    }
    
    public Set<String> resetPartitionMetaData(int bufferPartition) {
        Set<String> rowoverFeedIDs = super.resetPartitionMetaData(bufferPartition);
        PartitionMetaData pObj = getPartitionMetaData(bufferPartition);
        if (pObj != null) {
            try {
                getMetaStoreIndex().putNoReturn(pObj);
            } catch (Exception e) {
                LOGGER.error("Exception in getData", e);

View Full Code Here

Examples of gov.nasa.arc.mct.buffer.internal.PartitionMetaData

        return rowoverFeedIDs;
    }


    @Override
    public void writePartitionMetaData(int bufferPartition) {
        PartitionMetaData pObj = getPartitionMetaData(bufferPartition);
        if (pObj == null) {
            return;
        }
        
        try {

View Full Code Here

Examples of gov.nasa.arc.mct.buffer.internal.PartitionMetaData

        }
    }


    @Override
    public void writeCurrentBufferPartition(int newCurrentBufferPartition) {
        PartitionMetaData existingPartitionMetaData = getPartitionMetaData(this.currentPartition);
        PartitionMetaData newPartitionMetaData = getPartitionMetaData(newCurrentBufferPartition);
        if (existingPartitionMetaData != null) {
            existingPartitionMetaData.setCurrentPartition(false);
        }
        
        if (newPartitionMetaData == null) {
            newPartitionMetaData = new PartitionMetaData(newCurrentBufferPartition);
            synchronized(this) {
                this.partitionMetaDatas[newCurrentBufferPartition] = newPartitionMetaData;
            }
        }
        newPartitionMetaData.setCurrentPartition(true);
        
        boolean failed = false;
        try {
            if (existingPartitionMetaData != null) {
                getMetaStoreIndex().putNoReturn(existingPartitionMetaData);

View Full Code Here

Examples of kafka.javaapi.PartitionMetadata

    }
    return offsets[0];
  }


  public boolean isLeaderPresent() {
    PartitionMetadata metadata = fetchPartitonMetadata();
    return !(metadata == null || metadata.errorCode() != ErrorMapping.NoError());
  }

View Full Code Here

Examples of kafka.javaapi.PartitionMetadata

  }


  private void findLeader() {
    closeConsumer();


    PartitionMetadata metadata = fetchPartitonMetadata();
    if (metadata == null) {
      String message = String.format("Could not find leader for topic %s, partition %d",
                                     topic, partition);
      LOG.error(message);
      throw new RuntimeException(message);
    }


    if (metadata.leader() == null) {
      LOG.warn("Can't find leader for topic {} and partition {} with brokers {}.",
               topic, partition, replicaBrokers, ErrorMapping.exceptionFor(metadata.errorCode()));
      throw new RuntimeException(ErrorMapping.exceptionFor(metadata.errorCode()));
    }
    consumer = new SimpleConsumer(metadata.leader().host(), metadata.leader().port(), TIMEOUT_MS, BUFFER_SIZE_BYTES,
                                  clientName);
    saveReplicaBrokers(metadata);
  }

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.